server

Documentation

Overview

Package server provides a server implementation of a single node of an Oort cluster.

Index

• type GroupStore
  • func NewGroupStore(cfg *GroupStoreConfig) (*GroupStore, chan error, error)
  • func (s *GroupStore) Delete(stream groupproto.GroupStore_DeleteServer) error
  • func (s *GroupStore) Lookup(stream groupproto.GroupStore_LookupServer) error
  • func (s *GroupStore) LookupGroup(stream groupproto.GroupStore_LookupGroupServer) error
  • func (s *GroupStore) Read(stream groupproto.GroupStore_ReadServer) error
  • func (s *GroupStore) ReadGroup(stream groupproto.GroupStore_ReadGroupServer) error
  • func (s *GroupStore) Shutdown(ctx context.Context) error
  • func (s *GroupStore) Startup(ctx context.Context) error
  • func (s *GroupStore) Stats() []byte
  • func (s *GroupStore) Wait()
  • func (s *GroupStore) Write(stream groupproto.GroupStore_WriteServer) error
• type GroupStoreConfig
• type ValueStore
  • func NewValueStore(cfg *ValueStoreConfig) (*ValueStore, chan error, error)
  • func (s *ValueStore) Delete(stream valueproto.ValueStore_DeleteServer) error
  • func (s *ValueStore) Lookup(stream valueproto.ValueStore_LookupServer) error
  • func (s *ValueStore) Read(stream valueproto.ValueStore_ReadServer) error
  • func (s *ValueStore) Shutdown(ctx context.Context) error
  • func (s *ValueStore) Startup(ctx context.Context) error
  • func (s *ValueStore) Stats() []byte
  • func (s *ValueStore) Wait()
  • func (s *ValueStore) Write(stream valueproto.ValueStore_WriteServer) error
• type ValueStoreConfig

Types

type GroupStore

type GroupStore struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewGroupStore

func NewGroupStore(cfg *GroupStoreConfig) (*GroupStore, chan error, error)

func (*GroupStore) Delete

func (s *GroupStore) Delete(stream groupproto.GroupStore_DeleteServer) error

func (*GroupStore) Lookup

func (s *GroupStore) Lookup(stream groupproto.GroupStore_LookupServer) error

func (*GroupStore) LookupGroup

func (s *GroupStore) LookupGroup(stream groupproto.GroupStore_LookupGroupServer) error

func (*GroupStore) Read

func (s *GroupStore) Read(stream groupproto.GroupStore_ReadServer) error

func (*GroupStore) ReadGroup

func (s *GroupStore) ReadGroup(stream groupproto.GroupStore_ReadGroupServer) error

func (*GroupStore) Shutdown

func (s *GroupStore) Shutdown(ctx context.Context) error

func (*GroupStore) Startup

func (s *GroupStore) Startup(ctx context.Context) error

func (*GroupStore) Stats

func (s *GroupStore) Stats() []byte

func (*GroupStore) Wait

func (s *GroupStore) Wait()

Wait isn't implemented yet, need graceful shutdowns in grpc

func (*GroupStore) Write

func (s *GroupStore) Write(stream groupproto.GroupStore_WriteServer) error

type GroupStoreConfig

type GroupStoreConfig struct {
	GRPCAddressIndex int
	ReplAddressIndex int
	GRPCCertFile     string
	GRPCKeyFile      string
	ReplCertFile     string
	ReplKeyFile      string
	CAFile           string
	Path             string
	Scale            float64
	Ring             ring.Ring
	Logger           *zap.Logger
}

type ValueStore

type ValueStore struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewValueStore

func NewValueStore(cfg *ValueStoreConfig) (*ValueStore, chan error, error)

func (*ValueStore) Delete

func (s *ValueStore) Delete(stream valueproto.ValueStore_DeleteServer) error

func (*ValueStore) Lookup

func (s *ValueStore) Lookup(stream valueproto.ValueStore_LookupServer) error

func (*ValueStore) Read

func (s *ValueStore) Read(stream valueproto.ValueStore_ReadServer) error

func (*ValueStore) Shutdown

func (s *ValueStore) Shutdown(ctx context.Context) error

func (*ValueStore) Startup

func (s *ValueStore) Startup(ctx context.Context) error

func (*ValueStore) Stats

func (s *ValueStore) Stats() []byte

func (*ValueStore) Wait

func (s *ValueStore) Wait()

Wait isn't implemented yet, need graceful shutdowns in grpc

func (*ValueStore) Write

func (s *ValueStore) Write(stream valueproto.ValueStore_WriteServer) error

type ValueStoreConfig

type ValueStoreConfig struct {
	GRPCAddressIndex int
	ReplAddressIndex int
	GRPCCertFile     string
	GRPCKeyFile      string
	ReplCertFile     string
	ReplKeyFile      string
	CAFile           string
	Path             string
	Scale            float64
	Ring             ring.Ring
	Logger           *zap.Logger
}