oortstore

package
v0.0.0-...-a36e63d Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 1, 2016 License: Apache-2.0, Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type OortGroupConfig 

type OortGroupConfig struct {
	Debug              bool
	Profile            bool
	ListenAddr         string `toml:"ListenAddress"` //another example
	MutualTLS          bool
	InsecureSkipVerify bool
	CertFile           string
	KeyFile            string
	CAFile             string
	MetricsAddr        string
	MetricsCollectors  string
}

type OortGroupStore 

type OortGroupStore struct {
	sync.RWMutex

	Config *OortGroupConfig `toml:"OortGroupStoreConfig"` // load config using an explicit/different config header

	GroupStoreConfig store.GroupStoreConfig
	TCPMsgRingConfig ring.TCPMsgRingConfig
	// contains filtered or unexported fields
}

func NewGroupStore 

func NewGroupStore(oort *oort.Server, logger zap.Logger, loggerName string) (*OortGroupStore, error)

func (*OortGroupStore) Delete 

func (s *OortGroupStore) Delete(ctx context.Context, req *groupproto.DeleteRequest) (*groupproto.DeleteResponse, error)

func (*OortGroupStore) ListenAndServe 

func (s *OortGroupStore) ListenAndServe()

func (*OortGroupStore) Lookup 

func (s *OortGroupStore) Lookup(ctx context.Context, req *groupproto.LookupRequest) (*groupproto.LookupResponse, error)

func (*OortGroupStore) LookupGroup 

func (s *OortGroupStore) LookupGroup(ctx context.Context, req *groupproto.LookupGroupRequest) (*groupproto.LookupGroupResponse, error)

func (*OortGroupStore) Read 

func (s *OortGroupStore) Read(ctx context.Context, req *groupproto.ReadRequest) (*groupproto.ReadResponse, error)

func (*OortGroupStore) ReadGroup 

func (s *OortGroupStore) ReadGroup(ctx context.Context, req *groupproto.ReadGroupRequest) (*groupproto.ReadGroupResponse, error)

func (*OortGroupStore) Start 

func (s *OortGroupStore) Start()

func (*OortGroupStore) Stats 

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

func (*OortGroupStore) Stop 

func (s *OortGroupStore) Stop()

func (*OortGroupStore) StopListenAndServe 

func (s *OortGroupStore) StopListenAndServe()

func (*OortGroupStore) StreamDelete 

func (s *OortGroupStore) StreamDelete(stream groupproto.GroupStore_StreamDeleteServer) error

func (*OortGroupStore) StreamLookup 

func (s *OortGroupStore) StreamLookup(stream groupproto.GroupStore_StreamLookupServer) error

func (*OortGroupStore) StreamLookupGroup 

func (s *OortGroupStore) StreamLookupGroup(stream groupproto.GroupStore_StreamLookupGroupServer) error

func (*OortGroupStore) StreamRead 

func (s *OortGroupStore) StreamRead(stream groupproto.GroupStore_StreamReadServer) error

func (*OortGroupStore) StreamReadGroup 

func (s *OortGroupStore) StreamReadGroup(stream groupproto.GroupStore_StreamReadGroupServer) error

func (*OortGroupStore) StreamWrite 

func (s *OortGroupStore) StreamWrite(stream groupproto.GroupStore_StreamWriteServer) error

func (*OortGroupStore) UpdateRing 

func (s *OortGroupStore) UpdateRing(ring ring.Ring)

func (*OortGroupStore) Wait 

func (s *OortGroupStore) Wait()

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

func (*OortGroupStore) Write 

func (s *OortGroupStore) Write(ctx context.Context, req *groupproto.WriteRequest) (*groupproto.WriteResponse, error)

type OortValueConfig 

type OortValueConfig struct {
	Debug              bool
	Profile            bool
	ListenAddr         string `toml:"ListenAddress"` //another example
	InsecureSkipVerify bool
	MutualTLS          bool
	CertFile           string
	KeyFile            string
	CAFile             string
	MetricsAddr        string
	MetricsCollectors  string
}

type OortValueStore 

type OortValueStore struct {
	sync.RWMutex

	Config *OortValueConfig `toml:"OortValueStoreConfig"` // load config using an explicit/different config header

	ValueStoreConfig store.ValueStoreConfig
	TCPMsgRingConfig ring.TCPMsgRingConfig
	// contains filtered or unexported fields
}

func NewValueStore 

func NewValueStore(oort *oort.Server, logger zap.Logger, loggerName string) (*OortValueStore, error)

func (*OortValueStore) Delete 

func (s *OortValueStore) Delete(ctx context.Context, req *valueproto.DeleteRequest) (*valueproto.DeleteResponse, error)

func (*OortValueStore) ListenAndServe 

func (s *OortValueStore) ListenAndServe()

func (*OortValueStore) Lookup 

func (s *OortValueStore) Lookup(ctx context.Context, req *valueproto.LookupRequest) (*valueproto.LookupResponse, error)

func (*OortValueStore) Read 

func (s *OortValueStore) Read(ctx context.Context, req *valueproto.ReadRequest) (*valueproto.ReadResponse, error)

func (*OortValueStore) Start 

func (s *OortValueStore) Start()

func (*OortValueStore) Stats 

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

func (*OortValueStore) Stop 

func (s *OortValueStore) Stop()

func (*OortValueStore) StopListenAndServe 

func (s *OortValueStore) StopListenAndServe()

func (*OortValueStore) StreamDelete 

func (s *OortValueStore) StreamDelete(stream valueproto.ValueStore_StreamDeleteServer) error

func (*OortValueStore) StreamLookup 

func (s *OortValueStore) StreamLookup(stream valueproto.ValueStore_StreamLookupServer) error

func (*OortValueStore) StreamRead 

func (s *OortValueStore) StreamRead(stream valueproto.ValueStore_StreamReadServer) error

func (*OortValueStore) StreamWrite 

func (s *OortValueStore) StreamWrite(stream valueproto.ValueStore_StreamWriteServer) error

func (*OortValueStore) UpdateRing 

func (s *OortValueStore) UpdateRing(ring ring.Ring)

func (*OortValueStore) Wait 

func (s *OortValueStore) Wait()

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

func (*OortValueStore) Write 

func (s *OortValueStore) Write(ctx context.Context, req *valueproto.WriteRequest) (*valueproto.WriteResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.