kvs

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Mar 22, 2019 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	DurationSeconds = prometheus.NewHistogramVec(
		prometheus.HistogramOpts{
			Namespace: namespace,
			Subsystem: subsystem,
			Name:      "duration_seconds",
			Help:      "The index operation durations in seconds.",
		},
		[]string{
			"func",
		},
	)
	OperationsTotal = prometheus.NewCounterVec(
		prometheus.CounterOpts{
			Namespace: namespace,
			Subsystem: subsystem,
			Name:      "operations_total",
			Help:      "The number of index operations.",
		},
		[]string{
			"func",
		},
	)
)

Functions

func RecordMetrics 

func RecordMetrics(start time.Time, funcName string)

Types

type GRPCClient added in v0.5.0 

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

func NewGRPCClient added in v0.5.0 

func NewGRPCClient(address string) (*GRPCClient, error)

func (*GRPCClient) Close added in v0.5.0 

func (c *GRPCClient) Close() error

func (*GRPCClient) Delete added in v0.5.0 

func (c *GRPCClient) Delete(req *kvs.KeyValuePair, opts ...grpc.CallOption) error

func (*GRPCClient) Get added in v0.5.0 

func (c *GRPCClient) Get(req *kvs.KeyValuePair, opts ...grpc.CallOption) (*kvs.KeyValuePair, error)

func (*GRPCClient) Join added in v0.5.0 

func (c *GRPCClient) Join(req *raft.Node, opts ...grpc.CallOption) error

func (*GRPCClient) Leave added in v0.5.0 

func (c *GRPCClient) Leave(req *raft.Node, opts ...grpc.CallOption) error

func (*GRPCClient) Put added in v0.5.0 

func (c *GRPCClient) Put(req *kvs.KeyValuePair, opts ...grpc.CallOption) error

func (*GRPCClient) Snapshot added in v0.5.0 

func (c *GRPCClient) Snapshot(opts ...grpc.CallOption) error

type GRPCServer added in v0.5.0 

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

func NewGRPCServer added in v0.5.0 

func NewGRPCServer(grpcAddr string, service *GRPCService, logger *log.Logger) (*GRPCServer, error)

func (*GRPCServer) Start added in v0.5.0 

func (s *GRPCServer) Start() error

func (*GRPCServer) Stop added in v0.5.0 

func (s *GRPCServer) Stop() error

type GRPCService added in v0.5.0 

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

func NewGRPCService added in v0.5.0 

func NewGRPCService(raftServer *RaftServer, logger *log.Logger) (*GRPCService, error)

func (*GRPCService) Delete added in v0.5.0 

func (s *GRPCService) Delete(ctx context.Context, req *kvs.KeyValuePair) (*empty.Empty, error)

func (*GRPCService) Get added in v0.5.0 

func (s *GRPCService) Get(ctx context.Context, req *kvs.KeyValuePair) (*kvs.KeyValuePair, error)

func (*GRPCService) GetCluster added in v0.5.0 

func (s *GRPCService) GetCluster(ctx context.Context, req *empty.Empty) (*raft.Cluster, error)

func (*GRPCService) GetNode added in v0.5.0 

func (s *GRPCService) GetNode(ctx context.Context, req *empty.Empty) (*raft.Node, error)

func (*GRPCService) Join added in v0.5.0 

func (s *GRPCService) Join(ctx context.Context, req *raft.Node) (*empty.Empty, error)

func (*GRPCService) Leave added in v0.5.0 

func (s *GRPCService) Leave(ctx context.Context, req *raft.Node) (*empty.Empty, error)

func (*GRPCService) Put added in v0.5.0 

func (s *GRPCService) Put(ctx context.Context, req *kvs.KeyValuePair) (*empty.Empty, error)

func (*GRPCService) Snapshot added in v0.5.0 

func (s *GRPCService) Snapshot(ctx context.Context, req *empty.Empty) (*empty.Empty, error)

type HTTPServer added in v0.5.0 

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

func NewHTTPServer added in v0.5.0 

func NewHTTPServer(httpAddr string, grpcClient *GRPCClient, logger *log.Logger, httpLogger *log.Logger) (*HTTPServer, error)

func (*HTTPServer) Start added in v0.5.0 

func (s *HTTPServer) Start() error

func (*HTTPServer) Stop added in v0.5.0 

func (s *HTTPServer) Stop() error

type KVS added in v0.5.0 

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

func NewKVS added in v0.5.0 

func NewKVS(dir string, valueDir string, logger *log.Logger) (*KVS, error)

func (*KVS) Close added in v0.5.0 

func (b *KVS) Close() error

func (*KVS) Delete added in v0.5.0 

func (b *KVS) Delete(key []byte) error

func (*KVS) Get added in v0.5.0 

func (b *KVS) Get(key []byte) ([]byte, error)

func (*KVS) Set added in v0.5.0 

func (b *KVS) Set(key []byte, value []byte) error

func (*KVS) SnapshotItems added in v0.5.0 

func (b *KVS) SnapshotItems() <-chan *kvs.KeyValuePair

type KVSFSMSnapshot added in v0.5.0 

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

func (*KVSFSMSnapshot) Persist added in v0.5.0 

func (f *KVSFSMSnapshot) Persist(sink raft.SnapshotSink) error

func (*KVSFSMSnapshot) Release added in v0.5.0 

func (f *KVSFSMSnapshot) Release()

type RaftFSM added in v0.5.0 

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

func NewRaftFSM added in v0.5.0 

func NewRaftFSM(path string, logger *log.Logger) (*RaftFSM, error)

func (*RaftFSM) Apply added in v0.5.0 

func (f *RaftFSM) Apply(l *raft.Log) interface{}

func (*RaftFSM) Close added in v0.5.0 

func (f *RaftFSM) Close() error

func (*RaftFSM) Get added in v0.5.0 

func (f *RaftFSM) Get(key []byte) ([]byte, error)

func (*RaftFSM) GetMetadata added in v0.5.0 

func (f *RaftFSM) GetMetadata(nodeId string) (*blastraft.Node, error)

func (*RaftFSM) Restore added in v0.5.0 

func (f *RaftFSM) Restore(rc io.ReadCloser) error

func (*RaftFSM) Snapshot added in v0.5.0 

func (f *RaftFSM) Snapshot() (raft.FSMSnapshot, error)

type RaftServer added in v0.5.0 

type RaftServer struct {
	Node *blastraft.Node

	BindAddr string
	DataDir  string
	// contains filtered or unexported fields
}

func NewRaftServer added in v0.5.0 

func NewRaftServer(node *blastraft.Node, bootstrap bool, logger *log.Logger) (*RaftServer, error)

func (*RaftServer) Delete added in v0.5.0 

func (s *RaftServer) Delete(kvp *kvs.KeyValuePair) error

func (*RaftServer) Get added in v0.5.0 

func (s *RaftServer) Get(kvp *kvs.KeyValuePair) (*kvs.KeyValuePair, error)

func (*RaftServer) GetCluster added in v0.5.0 

func (s *RaftServer) GetCluster() (*blastraft.Cluster, error)

func (*RaftServer) GetNode added in v0.5.0 

func (s *RaftServer) GetNode() (*blastraft.Node, error)

func (*RaftServer) Join added in v0.5.0 

func (s *RaftServer) Join(node *blastraft.Node) error

func (*RaftServer) LeaderAddress added in v0.5.0 

func (s *RaftServer) LeaderAddress(timeout time.Duration) (raft.ServerAddress, error)

func (*RaftServer) LeaderID added in v0.5.0 

func (s *RaftServer) LeaderID(timeout time.Duration) (raft.ServerID, error)

func (*RaftServer) Leave added in v0.5.0 

func (s *RaftServer) Leave(node *blastraft.Node) error

func (*RaftServer) Set added in v0.5.0 

func (s *RaftServer) Set(kvp *kvs.KeyValuePair) error

func (*RaftServer) Snapshot added in v0.5.0 

func (s *RaftServer) Snapshot() error

func (*RaftServer) Start added in v0.5.0 

func (s *RaftServer) Start() error

func (*RaftServer) Stop added in v0.5.0 

func (s *RaftServer) Stop() error

func (*RaftServer) WaitForDetectLeader added in v0.5.0 

func (s *RaftServer) WaitForDetectLeader(timeout time.Duration) error

type RootHandler 

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

func NewRootHandler 

func NewRootHandler(logger *log.Logger) *RootHandler

func (*RootHandler) ServeHTTP 

func (h *RootHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Server 

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

func NewServer 

func NewServer(nodeId string, bindAddr string, grpcAddr string, httpAddr string, dataDir string, joinAddr string, logger *log.Logger, httpLogger *log.Logger) (*Server, error)

func (*Server) Start 

func (s *Server) Start()

func (*Server) Stop 

func (s *Server) Stop()

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.