consumer

Documentation

Index

• func ProcessBatch(_ context.Context, msg []DataBatch) error
• func ProcessBatchErr(ctx context.Context, msg []DataBatchErr) error
• func ProcessSingle(_ context.Context, msg DataSingle) error
• func ProcessSingleByte(ctx context.Context, raw []byte) error
• func RunExampleBatch(ctx context.Context) error
• func RunExampleBatchErr(ctx context.Context) error
• func RunExampleSingle(ctx context.Context) error
• func RunExampleSingleByte(ctx context.Context) error
• func RunExampleSingleWithHandler(ctx context.Context) error
• type DataBatch
• type DataBatchErr
• type DataSingle

Functions

func ProcessBatch

func ProcessBatch(_ context.Context, msg []DataBatch) error

func ProcessBatchErr

func ProcessBatchErr(ctx context.Context, msg []DataBatchErr) error

func ProcessSingle

func ProcessSingle(_ context.Context, msg DataSingle) error

func ProcessSingleByte

func ProcessSingleByte(ctx context.Context, raw []byte) error

func RunExampleBatch

func RunExampleBatch(ctx context.Context) error

func RunExampleBatchErr

func RunExampleBatchErr(ctx context.Context) error

func RunExampleSingle

func RunExampleSingle(ctx context.Context) error

func RunExampleSingleByte

func RunExampleSingleByte(ctx context.Context) error

func RunExampleSingleWithHandler

func RunExampleSingleWithHandler(ctx context.Context) error

Types

type DataBatch

type DataBatch struct {
	Test       int  `json:"test"`
	IsErr      bool `json:"is_err"`
	IsErrFatal bool `json:"is_err_fatal"`
}

type DataBatchErr

type DataBatchErr struct {
	Test       int  `json:"test"`
	IsErr      bool `json:"is_err"`
	IsErrFatal bool `json:"is_err_fatal"`
}

type DataSingle

type DataSingle struct {
	Test       int    `json:"test"`
	Timeout    string `json:"timeout"`
	IsErr      bool   `json:"is_err"`
	IsErrFatal bool   `json:"is_err_fatal"`
}