http

Documentation

Index

• type TaskExecutor
  • func NewTaskExecutor(httpHandler *http.HttpHandler, grpcHandler *grpc.GrpcHandler, ...) *TaskExecutor
  • func (executor *TaskExecutor) Execute(context message.Context, input interface{}, taskConfig *model.Task) (interface{}, *model.Task, errors.Error)
• type TaskResult

Types

type TaskExecutor

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

func NewTaskExecutor

func NewTaskExecutor(
	httpHandler *http.HttpHandler,
	grpcHandler *grpc.GrpcHandler,
	pubsubHandler *pubsub.PubSubHandler,
	natsHandler *nats.NatsHandler,
	redisstream *redisstream.RedisStreamHandler,
	logger zerolog.Logger,
) *TaskExecutor

func (*TaskExecutor) Execute

func (executor *TaskExecutor) Execute(context message.Context, input interface{}, taskConfig *model.Task) (interface{}, *model.Task, errors.Error)

type TaskResult

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