processor

Documentation

Index

• type DownstreamProcessor
  • func (d *DownstreamProcessor) Process(ctx context.Context, msg datapack.Message) *ProcessResp
• type HttpDispatchProcess
  • func NewHttpDispatcher(timeout time.Duration) *HttpDispatchProcess
  • func (d *HttpDispatchProcess) Process(ctx context.Context, msg datapack.Message) *ProcessResp
• type ProcessResp
  • func PushToProcessor(msg datapack.Message) *ProcessResp
• type Processor
• type RemoteDispatchProcess

Types

type DownstreamProcessor

type DownstreamProcessor struct {
}

func (*DownstreamProcessor) Process

func (d *DownstreamProcessor) Process(ctx context.Context, msg datapack.Message) *ProcessResp

type HttpDispatchProcess

type HttpDispatchProcess struct {
	// contains filtered or unexported fields
}

func NewHttpDispatcher

func NewHttpDispatcher(timeout time.Duration) *HttpDispatchProcess

func (*HttpDispatchProcess) Process

func (d *HttpDispatchProcess) Process(ctx context.Context, msg datapack.Message) *ProcessResp

type ProcessResp

type ProcessResp struct {
	Success bool
	Finish  bool

	Content interface{}
	// contains filtered or unexported fields
}

func PushToProcessor

func PushToProcessor(msg datapack.Message) *ProcessResp

type Processor

type Processor interface {
	Process(ctx context.Context, msg datapack.Message) *ProcessResp
}

type RemoteDispatchProcess

type RemoteDispatchProcess interface {
	Processor

	GetRemoteServices(serviceName string) []transport.RemoteService
	LoadBalanceSort([]transport.RemoteService) []transport.RemoteService
	DoDispatch() *ProcessResp
}