cluster

Documentation

Index

• type Cluster
• type Option
  • func WithFaultTolerant(faultTolerant string) Option
  • func WithLoadBalance(loadBalance string) Option
  • func WithNodes(nodes []rpc.Node) Option
  • func WithRetryCount(retryCount int) Option
  • func WithRetryInterval(retryInterval int) Option
• type SawtoothCluster
  • func NewSawtoothClusterWithOptions(opts ...Option) *SawtoothCluster
  • func (c *SawtoothCluster) Invoke(ctx context.Context, inv invocation.Invocation) invocation.Result

Types

type Cluster

type Cluster interface {
	// Invoke invokes the invocation and return the result
	Invoke(ctx context.Context, invocation invocation.Invocation) invocation.Result
}

type Option

type Option func(c *SawtoothCluster)

func WithFaultTolerant

func WithFaultTolerant(faultTolerant string) Option

func WithLoadBalance

func WithLoadBalance(loadBalance string) Option

func WithNodes

func WithNodes(nodes []rpc.Node) Option

func WithRetryCount

func WithRetryCount(retryCount int) Option

func WithRetryInterval

func WithRetryInterval(retryInterval int) Option

type SawtoothCluster

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

func NewSawtoothClusterWithOptions

func NewSawtoothClusterWithOptions(opts ...Option) *SawtoothCluster

func (*SawtoothCluster) Invoke

func (c *SawtoothCluster) Invoke(ctx context.Context, inv invocation.Invocation) invocation.Result