process

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 Process

Variables

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

Functions

func WrapWithBatchMsgLoop

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

func WrapWithSingleMsgLoop

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

Types

type Process

type Process interface {
	plug.Parter
	DoProcess()
}