manager

package
v0.8.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewGRPCContext added in v0.8.0 

func NewGRPCContext() (context.Context, context.CancelFunc)

Types

type GRPCClient added in v0.8.0 

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

func NewGRPCClient added in v0.8.0 

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

func (*GRPCClient) Cancel added in v0.8.0 

func (c *GRPCClient) Cancel()

func (*GRPCClient) Close added in v0.8.0 

func (c *GRPCClient) Close() error

func (*GRPCClient) ClusterInfo added in v0.8.0 

func (c *GRPCClient) ClusterInfo(req *empty.Empty, opts ...grpc.CallOption) (*management.ClusterInfoResponse, error)

func (*GRPCClient) ClusterJoin added in v0.8.0 

func (c *GRPCClient) ClusterJoin(req *management.ClusterJoinRequest, opts ...grpc.CallOption) (*empty.Empty, error)

func (*GRPCClient) ClusterLeave added in v0.8.0 

func (c *GRPCClient) ClusterLeave(req *management.ClusterLeaveRequest, opts ...grpc.CallOption) (*empty.Empty, error)

func (*GRPCClient) ClusterWatch added in v0.8.0 

func (c *GRPCClient) ClusterWatch(req *empty.Empty, opts ...grpc.CallOption) (management.Management_ClusterWatchClient, error)

func (*GRPCClient) Delete added in v0.8.0 

func (c *GRPCClient) Delete(req *management.DeleteRequest, opts ...grpc.CallOption) (*empty.Empty, error)

func (*GRPCClient) Get added in v0.8.0 

func (c *GRPCClient) Get(req *management.GetRequest, opts ...grpc.CallOption) (*management.GetResponse, error)

func (*GRPCClient) GetAddress added in v0.8.0 

func (c *GRPCClient) GetAddress() string

func (*GRPCClient) NodeHealthCheck added in v0.8.0 

func (c *GRPCClient) NodeHealthCheck(req *management.NodeHealthCheckRequest, opts ...grpc.CallOption) (*management.NodeHealthCheckResponse, error)

func (*GRPCClient) NodeInfo added in v0.8.0 

func (c *GRPCClient) NodeInfo(req *empty.Empty, opts ...grpc.CallOption) (*management.NodeInfoResponse, error)

func (*GRPCClient) Set added in v0.8.0 

func (c *GRPCClient) Set(req *management.SetRequest, opts ...grpc.CallOption) (*empty.Empty, error)

func (*GRPCClient) Snapshot added in v0.8.0 

func (c *GRPCClient) Snapshot(req *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)

func (*GRPCClient) Watch added in v0.8.0 

func (c *GRPCClient) Watch(req *management.WatchRequest, opts ...grpc.CallOption) (management.Management_WatchClient, error)

type GRPCGateway added in v0.8.0 

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

func NewGRPCGateway added in v0.8.0 

func NewGRPCGateway(grpcGatewayAddr string, grpcAddr string, logger *zap.Logger) (*GRPCGateway, error)

func (*GRPCGateway) GetAddress added in v0.8.0 

func (s *GRPCGateway) GetAddress() (string, error)

func (*GRPCGateway) Start added in v0.8.0 

func (s *GRPCGateway) Start() error

func (*GRPCGateway) Stop added in v0.8.0 

func (s *GRPCGateway) Stop() error

type GRPCServer added in v0.8.0 

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

func NewGRPCServer added in v0.8.0 

func NewGRPCServer(grpcAddr string, service management.ManagementServer, logger *zap.Logger) (*GRPCServer, error)

func (*GRPCServer) GetAddress added in v0.8.0 

func (s *GRPCServer) GetAddress() (string, error)

func (*GRPCServer) Start added in v0.8.0 

func (s *GRPCServer) Start() error

func (*GRPCServer) Stop added in v0.8.0 

func (s *GRPCServer) Stop() error

type GRPCService 

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

func NewGRPCService 

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

func (*GRPCService) ClusterInfo added in v0.8.0 

func (s *GRPCService) ClusterInfo(ctx context.Context, req *empty.Empty) (*management.ClusterInfoResponse, error)

func (*GRPCService) ClusterJoin added in v0.8.0 

func (s *GRPCService) ClusterJoin(ctx context.Context, req *management.ClusterJoinRequest) (*empty.Empty, error)

func (*GRPCService) ClusterLeave added in v0.8.0 

func (s *GRPCService) ClusterLeave(ctx context.Context, req *management.ClusterLeaveRequest) (*empty.Empty, error)

func (*GRPCService) ClusterWatch added in v0.8.0 

func (s *GRPCService) ClusterWatch(req *empty.Empty, server management.Management_ClusterWatchServer) error

func (*GRPCService) Delete added in v0.8.0 

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

func (*GRPCService) Get added in v0.8.0 

func (s *GRPCService) Get(ctx context.Context, req *management.GetRequest) (*management.GetResponse, error)

func (*GRPCService) NodeHealthCheck added in v0.8.0 

func (s *GRPCService) NodeHealthCheck(ctx context.Context, req *management.NodeHealthCheckRequest) (*management.NodeHealthCheckResponse, error)

func (*GRPCService) NodeID added in v0.7.1 

func (s *GRPCService) NodeID() string

func (*GRPCService) NodeInfo added in v0.8.0 

func (s *GRPCService) NodeInfo(ctx context.Context, req *empty.Empty) (*management.NodeInfoResponse, error)

func (*GRPCService) Set added in v0.8.0 

func (s *GRPCService) Set(ctx context.Context, req *management.SetRequest) (*empty.Empty, error)

func (*GRPCService) Snapshot 

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

func (*GRPCService) Start 

func (s *GRPCService) Start() error

func (*GRPCService) Stop 

func (s *GRPCService) Stop() error

func (*GRPCService) Watch added in v0.8.0 

func (s *GRPCService) Watch(req *management.WatchRequest, server management.Management_WatchServer) error

type HTTPServer added in v0.8.0 

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

func NewHTTPServer added in v0.8.0 

func NewHTTPServer(httpAddr string, router *Router, logger *zap.Logger, httpLogger accesslog.Logger) (*HTTPServer, error)

func (*HTTPServer) Start added in v0.8.0 

func (s *HTTPServer) Start() error

func (*HTTPServer) Stop added in v0.8.0 

func (s *HTTPServer) Stop() error

type JsonMarshaler added in v0.8.0 

type JsonMarshaler struct{}

func (*JsonMarshaler) ContentType added in v0.8.0 

func (*JsonMarshaler) ContentType() string

ContentType always Returns "application/json".

func (*JsonMarshaler) Delimiter added in v0.8.0 

func (j *JsonMarshaler) Delimiter() []byte

Delimiter for newline encoded JSON streams.

func (*JsonMarshaler) Marshal added in v0.8.0 

func (j *JsonMarshaler) Marshal(v interface{}) ([]byte, error)

Marshal marshals "v" into JSON

func (*JsonMarshaler) NewDecoder added in v0.8.0 

func (j *JsonMarshaler) NewDecoder(r io.Reader) runtime.Decoder

NewDecoder returns a Decoder which reads JSON stream from "r".

func (*JsonMarshaler) NewEncoder added in v0.8.0 

func (j *JsonMarshaler) NewEncoder(w io.Writer) runtime.Encoder

NewEncoder returns an Encoder which writes JSON stream into "w".

func (*JsonMarshaler) Unmarshal added in v0.8.0 

func (j *JsonMarshaler) Unmarshal(data []byte, v interface{}) error

Unmarshal unmarshals JSON data into "v".

type RaftFSM 

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

func NewRaftFSM 

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

func (*RaftFSM) Apply 

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

func (*RaftFSM) DeleteNode added in v0.8.0 

func (f *RaftFSM) DeleteNode(nodeId string) error

func (*RaftFSM) DeleteValue added in v0.7.1 

func (f *RaftFSM) DeleteValue(key string) error

func (*RaftFSM) GetNode added in v0.8.0 

func (f *RaftFSM) GetNode(nodeId string) (*management.Node, error)

func (*RaftFSM) GetValue added in v0.7.1 

func (f *RaftFSM) GetValue(key string) (interface{}, error)

func (*RaftFSM) Restore 

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

func (*RaftFSM) SetNode added in v0.8.0 

func (f *RaftFSM) SetNode(node *management.Node) error

func (*RaftFSM) SetValue added in v0.7.1 

func (f *RaftFSM) SetValue(key string, value interface{}, merge bool) error

func (*RaftFSM) Snapshot 

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

func (*RaftFSM) Start 

func (f *RaftFSM) Start() error

func (*RaftFSM) Stop 

func (f *RaftFSM) Stop() error

type RaftFSMSnapshot 

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

func (*RaftFSMSnapshot) Persist 

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

func (*RaftFSMSnapshot) Release 

func (f *RaftFSMSnapshot) Release()

type RaftServer 

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

func NewRaftServer 

func NewRaftServer(node *management.Node, dataDir string, raftStorageType string, indexMapping *mapping.IndexMappingImpl, indexType string, indexStorageType string, bootstrap bool, logger *zap.Logger) (*RaftServer, error)

func (*RaftServer) DeleteNode added in v0.7.1 

func (s *RaftServer) DeleteNode(nodeId string) error

func (*RaftServer) DeleteValue added in v0.7.1 

func (s *RaftServer) DeleteValue(key string) error

func (*RaftServer) GetCluster added in v0.7.1 

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

func (*RaftServer) GetNode added in v0.7.1 

func (s *RaftServer) GetNode(id string) (*management.Node, error)

func (*RaftServer) GetValue added in v0.7.1 

func (s *RaftServer) GetValue(key string) (interface{}, error)

func (*RaftServer) IsLeader 

func (s *RaftServer) IsLeader() bool

func (*RaftServer) LeaderAddress 

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

func (*RaftServer) LeaderID 

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

func (*RaftServer) NodeAddress added in v0.8.0 

func (s *RaftServer) NodeAddress() string

func (*RaftServer) NodeID added in v0.7.1 

func (s *RaftServer) NodeID() string

func (*RaftServer) SetNode added in v0.7.1 

func (s *RaftServer) SetNode(node *management.Node) error

func (*RaftServer) SetValue added in v0.7.1 

func (s *RaftServer) SetValue(key string, value interface{}) error

func (*RaftServer) Snapshot 

func (s *RaftServer) Snapshot() error

func (*RaftServer) Start 

func (s *RaftServer) Start() error

func (*RaftServer) State 

func (s *RaftServer) State() raft.RaftState

func (*RaftServer) Stats 

func (s *RaftServer) Stats() map[string]string

func (*RaftServer) Stop 

func (s *RaftServer) Stop() error

func (*RaftServer) WaitForDetectLeader 

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

type RootHandler 

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

func NewRootHandler 

func NewRootHandler(logger *zap.Logger) *RootHandler

func (*RootHandler) ServeHTTP 

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

type Router added in v0.8.0 

type Router struct {
	mux.Router
	// contains filtered or unexported fields
}

func NewRouter 

func NewRouter(logger *zap.Logger) (*Router, error)

func (*Router) Close added in v0.8.0 

func (r *Router) Close() error

type Server 

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

func NewServer 

func NewServer(peerGrpcAddr string, node *management.Node, dataDir string, raftStorageType string, indexMapping *mapping.IndexMappingImpl, indexType string, indexStorageType string, logger *zap.Logger, grpcLogger *zap.Logger, httpLogger accesslog.Logger) (*Server, error)

func (*Server) BindAddress added in v0.8.0 

func (s *Server) BindAddress() string

func (*Server) GrpcAddress added in v0.8.0 

func (s *Server) GrpcAddress() string

func (*Server) HttpAddress added in v0.8.0 

func (s *Server) HttpAddress() string

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.