matching

package

v0.3.11 Latest Latest Go to latest Published: Apr 16, 2018 License: MIT Imports: 28 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/mfateev/cadence

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func NewService(params *service.BootstrapParams) common.Daemon
type Config
- func NewConfig(dc *dynamicconfig.Collection) *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
type Service
- func (s *Service) Start()
- func (s *Service) Stop()

Constants ¶

This section is empty.

Variables ¶

View Source

var (

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

Functions ¶

func NewService ¶

func NewService(params *service.BootstrapParams) common.Daemon

NewService builds a new cadence-matching service

Types ¶

type Config ¶ added in v0.3.0

type Config struct {
	EnableSyncMatch dynamicconfig.BoolPropertyFn

	// taskListManager configuration
	RangeSize                 int64
	GetTasksBatchSize         dynamicconfig.IntPropertyFn
	UpdateAckInterval         dynamicconfig.DurationPropertyFn
	IdleTasklistCheckInterval dynamicconfig.DurationPropertyFn
	// Time to hold a poll request before returning an empty response if there are no tasks
	LongPollExpirationInterval dynamicconfig.DurationPropertyFn
	MinTaskThrottlingBurstSize dynamicconfig.IntPropertyFn

	// taskWriter configuration
	OutstandingTaskAppendsThreshold int
	MaxTaskBatchSize                int
}

Config represents configuration for cadence-matching service

func NewConfig ¶ added in v0.3.0

func NewConfig(dc *dynamicconfig.Collection) *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 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
	DescribeTaskList(ctx context.Context, request *m.DescribeTaskListRequest) (*workflow.DescribeTaskListResponse, 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

NewHandler creates a thrift handler for the history service

func (*Handler) AddActivityTask ¶

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

AddActivityTask - adds an activity task.

func (*Handler) AddDecisionTask ¶

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

AddDecisionTask - adds a decision task.

func (*Handler) CancelOutstandingPoll ¶ added in v0.3.2

func (h *Handler) CancelOutstandingPoll(ctx context.Context,
	request *m.CancelOutstandingPollRequest) error

CancelOutstandingPoll is used to cancel outstanding pollers

func (*Handler) DescribeTaskList ¶ added in v0.3.5

func (h *Handler) DescribeTaskList(ctx context.Context, request *m.DescribeTaskListRequest) (*gen.DescribeTaskListResponse, error)

DescribeTaskList returns information about the target tasklist, right now this API returns the pollers which polled this tasklist in last few minutes.

func (*Handler) Health ¶ added in v0.3.0

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

Health is for health check

func (*Handler) PollForActivityTask ¶

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

PollForActivityTask - long poll for an activity task.

func (*Handler) PollForDecisionTask ¶

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

PollForDecisionTask - long poll for a decision task.

func (*Handler) QueryWorkflow ¶ added in v0.3.2

func (h *Handler) QueryWorkflow(ctx context.Context,
	queryRequest *m.QueryWorkflowRequest) (*gen.QueryWorkflowResponse, error)

QueryWorkflow queries a given workflow synchronously and return the query result.

func (*Handler) RespondQueryTaskCompleted ¶ added in v0.3.2

func (h *Handler) RespondQueryTaskCompleted(ctx context.Context, request *m.RespondQueryTaskCompletedRequest) error

RespondQueryTaskCompleted responds a query task completed

func (*Handler) Start ¶

func (h *Handler) Start() 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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL