matching

type Config struct {
	EnableSyncMatch bool
	// Time to hold a poll request before returning an empty response if there are no tasks
	LongPollExpirationInterval time.Duration

	// taskListManager configuration
	RangeSize         int64
	GetTasksBatchSize int
	UpdateAckInterval time.Duration

	// taskWriter configuration
	OutstandingTaskAppendsThreshold int
	MaxTaskBatchSize                int
}

type Engine interface {
	Stop()
	AddDecisionTask(addRequest *m.AddDecisionTaskRequest) error
	AddActivityTask(addRequest *m.AddActivityTaskRequest) error
	PollForDecisionTask(ctx context.Context, request *m.PollForDecisionTaskRequest) (*m.PollForDecisionTaskResponse, error)
	PollForActivityTask(ctx context.Context, request *m.PollForActivityTaskRequest) (*workflow.PollForActivityTaskResponse, error)
	QueryWorkflow(ctx context.Context, request *m.QueryWorkflowRequest) (*workflow.QueryWorkflowResponse, error)
	RespondQueryTaskCompleted(ctx context.Context, request *m.RespondQueryTaskCompletedRequest) error
	CancelOutstandingPoll(ctx context.Context, request *m.CancelOutstandingPollRequest) error
}

type Handler struct {
	service.Service
	// contains filtered or unexported fields
}

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