transit

Documentation

Index

• Variables
• func WrapWithBatchMsgLoop(ctx context.Context, wg *sync.WaitGroup, group string, ...) func()
• func WrapWithSingleMsgLoop(ctx context.Context, wg *sync.WaitGroup, group string, ...) func()
• type Transit

Variables

var (
	Plugin = make(map[string]Transit)
)

Functions

func WrapWithBatchMsgLoop

func WrapWithBatchMsgLoop(ctx context.Context, wg *sync.WaitGroup, group string, coreFunc func([]byte) ([]protocol.Job, error)) func()

func WrapWithSingleMsgLoop

func WrapWithSingleMsgLoop(ctx context.Context, wg *sync.WaitGroup, group string, coreFunc func([]byte) (protocol.Job, error)) func()

Types

type Transit

type Transit interface {
	plug.Parter
	DoTransit()
}