Functions — github.com/dionysia-dev/dionysia

hub / github.com/dionysia-dev/dionysia / functions

Functions106 in github.com/dionysia-dev/dionysia

⨍ Functions 106◇ Types & classes 45

↓ 7 callersMethodGetInput

(context.Context, uuid.UUID)

internal/service/input.go:47

↓ 5 callersMethodEXPECT

EXPECT returns an object that allows the caller to indicate expected use.

internal/mocks/store.go:39

↓ 5 callersFunctionNewMockInputStore

NewMockInputStore creates a new mock instance.

internal/mocks/store.go:32

↓ 4 callersMethodGet

(context.Context, uuid.UUID)

internal/service/routing.go:11

↓ 4 callersFunctionHandleValidationError

HandleValidationError validate and handle errors of structs that has `validator/v10` rules

internal/api/response.go:31

↓ 4 callersFunctionNewInputHandler

(store db.InputStore)

internal/service/input.go:56

↓ 3 callersMethodCreateInput

(context.Context, *Input)

internal/service/input.go:46

↓ 3 callersMethodDeleteInput

(context.Context, uuid.UUID)

internal/service/input.go:48

↓ 3 callersMethodEnqueue

(*asynq.Task, ...asynq.Option)

internal/queue/client.go:9

↓ 3 callersMethodExecute

()

internal/service/command.go:106

↓ 3 callersFunctionNewPackageTask

(id uuid.UUID, input Input, cfg *config.Config)

internal/service/packaging.go:26

↓ 3 callersMethodPackageStream

(context.Context, uuid.UUID)

internal/service/notification.go:14

↓ 3 callersMethodUpdate

(context.Context, Origin)

internal/service/routing.go:10

↓ 2 callersMethodEXPECT

EXPECT returns an object that allows the caller to indicate expected use.

internal/mocks/queue.go:37

↓ 2 callersMethodEXPECT

EXPECT returns an object that allows the caller to indicate expected use.

internal/mocks/routing.go:39

↓ 2 callersFunctionFromInput

(input service.Input)

internal/api/request.go:46

↓ 2 callersMethodGet

(ctx context.Context, id uuid.UUID)

internal/db/redistore/store.go:51

↓ 2 callersFunctionNewMockClient

NewMockClient creates a new mock instance.

internal/mocks/queue.go:30

↓ 2 callersFunctionNewMockOriginStore

NewMockOriginStore creates a new mock instance.

internal/mocks/routing.go:32

↓ 2 callersFunctionNewNotificationHandler

(c queue.Client, store db.InputStore, cfg *config.Config)

internal/service/notification.go:23

↓ 2 callersFunctionNewOriginHandler

(store OriginStore)

internal/service/routing.go:28

↓ 2 callersMethodUpdate

Update updates the origin in the store with the given ttl. It uses a lua script to ensure that the origin is only updated if the address (value) is th

internal/db/redistore/store.go:29

↓ 1 callersMethodAuthenticate

(context.Context, IngestAuth)

internal/service/input.go:49

↓ 1 callersMethodBuild

(id, address, output string, input Input)

internal/service/command.go:77

↓ 1 callersMethodCreateInput

(context.Context, *model.Input)

internal/db/store.go:17

↓ 1 callersMethodDeleteInput

(context.Context, uuid.UUID)

internal/db/store.go:19

↓ 1 callersFunctionExecute

()

cmd/root.go:25

↓ 1 callersFunctionFromOrigin

(origin service.Origin)

internal/api/request.go:107

↓ 1 callersMethodGet

(context.Context, uuid.UUID)

internal/service/routing.go:21

↓ 1 callersMethodGetInput

(context.Context, uuid.UUID)

internal/db/store.go:18

↓ 1 callersFunctionHandleStreamPackageTask

(_ context.Context, t *asynq.Task)

internal/service/packaging.go:40

↓ 1 callersFunctionNewAPICmd

()

cmd/api.go:18

↓ 1 callersFunctionNewClient

(cfg *config.Config)

internal/db/redistore/client.go:8

↓ 1 callersFunctionNewDefaultCommandConfig

()

internal/service/command.go:22

↓ 1 callersFunctionNewGPACCommand

(id, address, output string, input Input)

internal/service/command.go:139

↓ 1 callersFunctionNewGPACCommandBuilder

(config *CommandConfig)

internal/service/command.go:73

↓ 1 callersFunctionNewInputController

(inputHandler service.InputHandler)

internal/api/controller.go:23

↓ 1 callersFunctionNewNotificationController

(nh service.NotificationHandler)

internal/api/controller.go:175

↓ 1 callersFunctionNewOriginController

(oh service.OriginHandler)

internal/api/controller.go:212

↓ 1 callersFunctionNewOriginStore

(client *redis.Client, cfg *config.Config)

internal/db/redistore/store.go:17

↓ 1 callersFunctionNewPlayoutServer

()

cmd/playout.go:13

↓ 1 callersFunctionNewRootCmd

()

cmd/root.go:10

↓ 1 callersFunctionNewWorker

()

cmd/worker.go:15

↓ 1 callersMethodToInput

()

internal/api/request.go:16

↓ 1 callersMethodToOrigin

()

internal/api/request.go:100

↓ 1 callersMethodUpdate

(context.Context, Origin)

internal/service/routing.go:20

↓ 1 callersFunctionmigrate

(db *gorm.DB)

internal/db/migrate.go:8

MethodAuthenticate

(ctx context.Context, authData IngestAuth)

internal/service/input.go:136

MethodAuthenticate

(ctx *gin.Context)

internal/api/controller.go:133

MethodCreateInput

CreateInput mocks base method.

internal/mocks/store.go:44

MethodCreateInput

CreateInput indicates an expected call of CreateInput.

internal/mocks/store.go:52

MethodCreateInput

(ctx context.Context, in *Input)

internal/service/input.go:62

MethodCreateInput

@Summary Create an input @Description Create an input ready to be ingested @Accept json @Produce json @Param input body api.InputData true "Input data

internal/api/controller.go:36

MethodCreateInput

(ctx context.Context, input *model.Input)

internal/db/store.go:32

MethodDeleteInput

DeleteInput mocks base method.

internal/mocks/store.go:58

MethodDeleteInput

DeleteInput indicates an expected call of DeleteInput.

internal/mocks/store.go:66

MethodDeleteInput

(ctx context.Context, id uuid.UUID)

internal/service/input.go:132

MethodDeleteInput

@Summary Delete input @Description Delete input by ID @Produce json @Param id path string true "Input ID" @Success 200 {object} api.SuccessResponse @F

internal/api/controller.go:110

MethodDeleteInput

(ctx context.Context, id uuid.UUID)

internal/db/store.go:47

MethodEXPECT

EXPECT returns an object that allows the caller to indicate expected use.

internal/mocks/routing.go:91

MethodEnqueue

Enqueue mocks base method.

internal/mocks/queue.go:42

MethodEnqueue

Enqueue indicates an expected call of Enqueue.

internal/mocks/queue.go:55

MethodEnqueuePackaging

@Summary Enqueue packacing job @Description Enqueue packaging job using input URL, format and ID @Produce json @Param id query string true "Input ID"

internal/api/controller.go:189

MethodGet

Get mocks base method.

internal/mocks/routing.go:44

MethodGet

Get indicates an expected call of Get.

internal/mocks/routing.go:53

MethodGet

Get mocks base method.

internal/mocks/routing.go:96

MethodGet

Get indicates an expected call of Get.

internal/mocks/routing.go:105

MethodGet

(ctx context.Context, id uuid.UUID)

internal/service/routing.go:38

MethodGetInput

GetInput mocks base method.

internal/mocks/store.go:72

MethodGetInput

GetInput indicates an expected call of GetInput.

internal/mocks/store.go:81

MethodGetInput

(ctx context.Context, id uuid.UUID)

internal/service/input.go:98

MethodGetInput

@Summary Get input @Description Get input information by ID @Produce json @Param id path string true "Input ID" @Success 200 {object} api.SuccessRespo

internal/api/controller.go:77

MethodGetInput

(ctx context.Context, id uuid.UUID)

internal/db/store.go:36

MethodGetOrigin

(ctx *gin.Context)

internal/api/controller.go:247

FunctionNew

()

internal/logging/logging.go:5

FunctionNew

(cfg *config.Config)

internal/playout/playout.go:15

FunctionNew

@title Streaming Platform API @version 1.0 @description Manage your streaming workflow @BasePath /api/v1

internal/api/api.go:25

FunctionNew

(cfg *config.Config)

internal/db/conn.go:9

FunctionNew

()

internal/config/config.go:20

FunctionNewClient

(cfg *config.Config)

internal/queue/client.go:12

FunctionNewDBInputStore

(db *gorm.DB)

internal/db/store.go:26

FunctionNewMockOriginHandler

NewMockOriginHandler creates a new mock instance.

internal/mocks/routing.go:84

FunctionNewServer

(cfg *config.Config)

internal/queue/server.go:8

MethodPackageStream

(ctx context.Context, id uuid.UUID)

internal/service/notification.go:31

FunctionRun

(lc fx.Lifecycle, srv *asynq.Server)

internal/task/runner.go:12

FunctionTestCreateInput

(t *testing.T)

internal/service/input_test.go:16

FunctionTestDeleteInput

(t *testing.T)

internal/service/input_test.go:70

FunctionTestGPACCommandExecute

(t *testing.T)

internal/service/command_test.go:10

FunctionTestGetInput

(t *testing.T)

internal/service/input_test.go:37

FunctionTestHandleStreamPackageTaskFailUnmarshal

(t *testing.T)

internal/service/packaging_test.go:12

FunctionTestHandleValidationError

(t *testing.T)

internal/api/response_test.go:15

FunctionTestOriginHandlerGet

(t *testing.T)

internal/service/routing_test.go:33

FunctionTestOriginHandlerUpdate

(t *testing.T)

internal/service/routing_test.go:14

FunctionTestOriginStoreUpdate

(t *testing.T)

internal/db/redistore/store_test.go:18

FunctionTestPackageStreamEnqueueFailure

(t *testing.T)

internal/service/notification_test.go:47

FunctionTestPackageStreamSuccess

(t *testing.T)

internal/service/notification_test.go:18

MethodUpdate

Update mocks base method.

internal/mocks/routing.go:59

MethodUpdate

Update indicates an expected call of Update.

internal/mocks/routing.go:67

MethodUpdate

Update mocks base method.

internal/mocks/routing.go:111

MethodUpdate

Update indicates an expected call of Update.

internal/mocks/routing.go:119

next →1–100 of 106, ranked by callers