bamboo

type BambooRequestProducer interface {
	Produce(ctx context.Context, resultChannel string, heartbeatIntervalSec int, jobTimeoutSec int, headers map[string]string, data []byte) error
	Close(ctx context.Context) error
}

type BambooResultSubscriber interface {
	Ping(ctx context.Context) error
	Subscribe(ctx context.Context, resultChannel string, heartbeatIntervalSec int, jobTimeoutSec int) ([]byte, error)
}

type BambooWorker interface {
	Run(ctx context.Context) error
}

type ByteArreayResult struct {
	Value []byte
	Error error
}

type LogConfigFunc func(ctx context.Context, headers map[string]string) context.Context

type RedisBambooHeartbeatPublisher interface {
	Run(ctx context.Context)
}

type RedisJob interface {
	Run(ctx context.Context) error
}

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

type ResponseType int32

type WorkerFunc func(ctx context.Context, headers map[string]string, data []byte, aborted <-chan interface{}) ([]byte, error)

type WorkerParameter struct {
	Carrier              map[string]string `` /* 155-byte string literal not displayed */
	Headers              map[string]string `` /* 155-byte string literal not displayed */
	ResultChannel        string            `protobuf:"bytes,3,opt,name=resultChannel,proto3" json:"resultChannel,omitempty"`
	HeartbeatIntervalSec int32             `protobuf:"varint,4,opt,name=heartbeatIntervalSec,proto3" json:"heartbeatIntervalSec,omitempty"`
	JobTimeoutSec        int32             `protobuf:"varint,5,opt,name=jobTimeoutSec,proto3" json:"jobTimeoutSec,omitempty"`
	Data                 []byte            `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type WorkerResponse struct {
	Type ResponseType `protobuf:"varint,1,opt,name=type,proto3,enum=bamboo.ResponseType" json:"type,omitempty"`
	Data []byte       `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}