input

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 Input

Variables

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

Functions

func WrapWithBatchMsgLoop

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

func WrapWithSingleMsgLoop

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

Types

type Input

type Input interface {
	plug.Parter
	DoInput()
}