matching

Documentation

Index

• Variables
• func NewService(params *service.BootstrapParams, config *Config) common.Daemon
• type Config
  • func NewConfig() *Config
• type Engine
  • func NewEngine(taskManager persistence.TaskManager, historyService history.Client, ...) Engine
• type Handler
  • func NewHandler(sVice service.Service, config *Config, taskPersistence persistence.TaskManager) (*Handler, []thrift.TChanServer)
  • func (h *Handler) AddActivityTask(ctx thrift.Context, addRequest *m.AddActivityTaskRequest) error
  • func (h *Handler) AddDecisionTask(ctx thrift.Context, addRequest *m.AddDecisionTaskRequest) error
  • func (h *Handler) Health(ctx thrift.Context) (*health.HealthStatus, error)
  • func (h *Handler) PollForActivityTask(ctx thrift.Context, pollRequest *m.PollForActivityTaskRequest) (*gen.PollForActivityTaskResponse, error)
  • func (h *Handler) PollForDecisionTask(ctx thrift.Context, pollRequest *m.PollForDecisionTaskRequest) (*m.PollForDecisionTaskResponse, error)
  • func (h *Handler) Start(thriftService []thrift.TChanServer) error
  • func (h *Handler) Stop()
• type Service
  • func (s *Service) Start()
  • func (s *Service) Stop()

Variables

var (

	// ErrNoTasks is exported temporarily for integration test
	ErrNoTasks = errors.New("No tasks")
)

Functions

func NewService

func NewService(params *service.BootstrapParams, config *Config) common.Daemon

NewService builds a new cadence-matching service

Types

type Config

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
}

Config represents configuration for cadence-matching service

func NewConfig

func NewConfig() *Config

NewConfig returns new service config with default values

type Engine

type Engine interface {
	Stop()
	AddDecisionTask(addRequest *m.AddDecisionTaskRequest) error
	AddActivityTask(addRequest *m.AddActivityTaskRequest) error
	PollForDecisionTask(ctx thrift.Context, request *m.PollForDecisionTaskRequest) (*m.PollForDecisionTaskResponse, error)
	PollForActivityTask(ctx thrift.Context, request *m.PollForActivityTaskRequest) (*workflow.PollForActivityTaskResponse, error)
}

Engine exposes interfaces for clients to poll for activity and decision tasks.

func NewEngine

func NewEngine(taskManager persistence.TaskManager,
	historyService history.Client,
	config *Config,
	logger bark.Logger,
	metricsClient metrics.Client) Engine

NewEngine creates an instance of matching engine

type Handler

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

Handler - Thrift handler inteface for history service

func NewHandler

func NewHandler(sVice service.Service, config *Config, taskPersistence persistence.TaskManager) (*Handler, []thrift.TChanServer)

NewHandler creates a thrift handler for the history service

func (*Handler) AddActivityTask

func (h *Handler) AddActivityTask(ctx thrift.Context, addRequest *m.AddActivityTaskRequest) error

AddActivityTask - adds an activity task.

func (*Handler) AddDecisionTask

func (h *Handler) AddDecisionTask(ctx thrift.Context, addRequest *m.AddDecisionTaskRequest) error

AddDecisionTask - adds a decision task.

func (*Handler) Health

func (h *Handler) Health(ctx thrift.Context) (*health.HealthStatus, error)

Health is for health check

func (*Handler) PollForActivityTask

func (h *Handler) PollForActivityTask(ctx thrift.Context,
	pollRequest *m.PollForActivityTaskRequest) (*gen.PollForActivityTaskResponse, error)

PollForActivityTask - long poll for an activity task.

func (*Handler) PollForDecisionTask

func (h *Handler) PollForDecisionTask(ctx thrift.Context,
	pollRequest *m.PollForDecisionTaskRequest) (*m.PollForDecisionTaskResponse, error)

PollForDecisionTask - long poll for a decision task.

func (*Handler) Start

func (h *Handler) Start(thriftService []thrift.TChanServer) error

Start starts the handler

func (*Handler) Stop

func (h *Handler) Stop()

Stop stops the handler

type Service

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

Service represents the cadence-matching service

func (*Service) Start

func (s *Service) Start()

Start starts the service

func (*Service) Stop

func (s *Service) Stop()

Stop stops the service