services

Documentation

Index

• func GetStorageService(ctx types.Context, name string) types.StorageService
• func Init(ctx types.Context, config gofig.Config) error
• func StorageServices(ctx types.Context) <-chan types.StorageService
• func TaskEnqueue(ctx types.Context, run types.TaskRunFunc, schema []byte) *types.Task
• func TaskInspect(ctx types.Context, taskID int) *types.Task
• func TaskTrack(ctx types.Context) *types.Task
• func TaskWait(ctx types.Context, taskID int)
• func TaskWaitAll(ctx types.Context, taskIDs ...int)
• func TaskWaitAllC(ctx types.Context, taskIDs ...int) <-chan int
• func TaskWaitC(ctx types.Context, taskID int) <-chan int
• func Tasks(ctx types.Context) <-chan *types.Task

Functions

func GetStorageService

func GetStorageService(
	ctx types.Context, name string) types.StorageService

GetStorageService returns the storage service specified by the given name; otherwise a nil value is returned if no such service exists.

func Init

func Init(ctx types.Context, config gofig.Config) error

Init initializes the types.

func StorageServices

func StorageServices(ctx types.Context) <-chan types.StorageService

StorageServices returns a channel on which all the storage services are received.

func TaskEnqueue

func TaskEnqueue(
	ctx types.Context,
	run types.TaskRunFunc,
	schema []byte) *types.Task

TaskEnqueue enqueues a task for execution.

func TaskInspect

func TaskInspect(ctx types.Context, taskID int) *types.Task

TaskInspect returns the task with the specified ID.

func TaskTrack

func TaskTrack(ctx types.Context) *types.Task

TaskTrack creates a new, trackable task.

func TaskWait

func TaskWait(ctx types.Context, taskID int)

TaskWait blocks until the specified task is completed.

func TaskWaitAll

func TaskWaitAll(ctx types.Context, taskIDs ...int)

TaskWaitAll blocks until all the specified task are complete.

func TaskWaitAllC

func TaskWaitAllC(ctx types.Context, taskIDs ...int) <-chan int

TaskWaitAllC returns a channel that is closed only when all the specified tasks are completed.

func TaskWaitC

func TaskWaitC(ctx types.Context, taskID int) <-chan int

TaskWaitC returns a channel that is closed only when the specified task is completed.

func Tasks

func Tasks(ctx types.Context) <-chan *types.Task

Tasks returns a channel on which all tasks are received.