coordination

Documentation

Index

• Constants
• type Service
  • func NewInMemoryService(serverName string) *Service
  • func NewRedisService(ctx context.Context, serverName string, factory *meta.RedisPoolFactory) (*Service, error)
  • func (s *Service) Close() error
  • func (s *Service) CreateLock(name string) locks.Lock
  • func (s *Service) GetJitsuInstancesInCluster() ([]string, error)

Constants

const CollectionLockTimeout = time.Minute

Types

type Service

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

Service is a coordination service which is responsible for all distributed operations like: - distributed locks - obtain cluster information

func NewInMemoryService

func NewInMemoryService(serverName string) *Service

NewInMemoryService returns configured inmemory Service

func NewRedisService

func NewRedisService(ctx context.Context, serverName string, factory *meta.RedisPoolFactory) (*Service, error)

NewRedisService returns configured Redis Service

func (*Service) Close

func (s *Service) Close() error

func (*Service) CreateLock

func (s *Service) CreateLock(name string) locks.Lock

CreateLock proxies request to the locks.LockFactory

func (*Service) GetJitsuInstancesInCluster

func (s *Service) GetJitsuInstancesInCluster() ([]string, error)

GetJitsuInstancesInCluster proxies request to the clusters.Manager