cluster

Documentation

Index

• func NewClusterProxy(manager *Manager) model.FlowServiceServer
• type Manager
  • func NewManager(settings *Settings, extractor sharding.ShardExtractor) *Manager
  • func (m *Manager) GetClient(flowID string) (model.FlowServiceClient, error)
  • func (m *Manager) GetClients() (clients []model.FlowServiceClient, err error)
  • func (m *Manager) LocalShards() (shards []int)
• type Settings

Functions

func NewClusterProxy

func NewClusterProxy(manager *Manager) model.FlowServiceServer

NewClusterProxy creates a proxy service that forwards requests to the appropriate nodes based on the request shard

Types

type Manager

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

Manager manages cluster allocation and shard info

func NewManager

func NewManager(settings *Settings, extractor sharding.ShardExtractor) *Manager

NewManager creates a new cluster manager

func (*Manager) GetClient

func (m *Manager) GetClient(flowID string) (model.FlowServiceClient, error)

GetClient returns a GRPC client for the specified graph

func (*Manager) GetClients

func (m *Manager) GetClients() (clients []model.FlowServiceClient, err error)

GetClients returns GRPC clients for all the nodes

func (*Manager) LocalShards

func (m *Manager) LocalShards() (shards []int)

LocalShards returns a slice of the shards associated with this clster member

type Settings

type Settings struct {
	NodeCount  int
	NodeID     int
	NodePrefix string
	NodePort   int
}

Settings holds config for clustering and information about the current node