manager

package

Go to main page

Versions in this module

v0

v0.8.1

Sep 22, 2019

v0.8.0

Aug 28, 2019

Changes in this version

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

+ type GRPCClient struct

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

+ func (c *GRPCClient) Cancel()

+ func (c *GRPCClient) Close() error

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

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

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

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

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

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

+ func (c *GRPCClient) GetAddress() string

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

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

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

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

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

+ type GRPCGateway struct

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

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

+ func (s *GRPCGateway) Start() error

+ func (s *GRPCGateway) Stop() error

+ type GRPCServer struct

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

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

+ func (s *GRPCServer) Start() error

+ func (s *GRPCServer) Stop() error

type GRPCService

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

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

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

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

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

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

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

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

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

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

+ type HTTPServer struct

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

+ func (s *HTTPServer) Start() error

+ func (s *HTTPServer) Stop() error

+ type JsonMarshaler struct

+ func (*JsonMarshaler) ContentType() string

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

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

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

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

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

type RaftFSM

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

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

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

type RaftServer

+ func (s *RaftServer) NodeAddress() string

+ type Router struct

+ func (r *Router) Close() error

type Server

+ func (s *Server) BindAddress() string

+ func (s *Server) GrpcAddress() string

+ func (s *Server) HttpAddress() string

v0.7.1

Jul 17, 2019

Changes in this version

type GRPCService

+ func (s *GRPCService) DeleteValue(ctx context.Context, req *protobuf.DeleteValueRequest) (*empty.Empty, error)

+ func (s *GRPCService) GetValue(ctx context.Context, req *protobuf.GetValueRequest) (*protobuf.GetValueResponse, error)

+ func (s *GRPCService) NodeID() string

+ func (s *GRPCService) SetValue(ctx context.Context, req *protobuf.SetValueRequest) (*empty.Empty, error)

+ func (s *GRPCService) WatchStore(req *protobuf.WatchStoreRequest, server protobuf.Blast_WatchStoreServer) error

type RaftFSM

+ func (f *RaftFSM) DeleteNodeConfig(nodeId string) error

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

+ func (f *RaftFSM) GetNodeConfig(nodeId string) (map[string]interface{}, error)

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

+ func (f *RaftFSM) SetNodeConfig(nodeId string, nodeConfig map[string]interface{}) error

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

type RaftServer

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

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

+ func (s *RaftServer) GetCluster() (map[string]interface{}, error)

+ func (s *RaftServer) GetNode(id string) (map[string]interface{}, error)

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

+ func (s *RaftServer) NodeID() string

+ func (s *RaftServer) SetNode(nodeId string, nodeConfig map[string]interface{}) error

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

v0.7.0

Jul 3, 2019

v0.6.1

Jun 21, 2019

v0.6.0

Jun 19, 2019

Changes in this version

+ var DurationSeconds = prometheus.NewHistogramVec(prometheus.HistogramOpts{ ... }, []string{ ... })

+ var OperationsTotal = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ func NewRouter(grpcAddr string, logger *log.Logger) (*blasthttp.Router, error)

+ func RecordMetrics(start time.Time, funcName string)

+ type DeleteHandler struct

+ func NewDeleteHandler(client *grpc.Client, logger *log.Logger) *DeleteHandler

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

+ type GRPCService struct

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

+ func (s *GRPCService) DeleteNode(ctx context.Context, req *protobuf.DeleteNodeRequest) (*empty.Empty, error)

+ func (s *GRPCService) DeleteState(ctx context.Context, req *protobuf.DeleteStateRequest) (*empty.Empty, error)

+ func (s *GRPCService) GetCluster(ctx context.Context, req *empty.Empty) (*protobuf.GetClusterResponse, error)

+ func (s *GRPCService) GetMetadata(ctx context.Context, req *protobuf.GetMetadataRequest) (*protobuf.GetMetadataResponse, error)

+ func (s *GRPCService) GetNode(ctx context.Context, req *protobuf.GetNodeRequest) (*protobuf.GetNodeResponse, error)

+ func (s *GRPCService) GetNodeState(ctx context.Context, req *protobuf.GetNodeStateRequest) (*protobuf.GetNodeStateResponse, error)

+ func (s *GRPCService) GetState(ctx context.Context, req *protobuf.GetStateRequest) (*protobuf.GetStateResponse, error)

+ func (s *GRPCService) SetNode(ctx context.Context, req *protobuf.SetNodeRequest) (*empty.Empty, error)

+ func (s *GRPCService) SetState(ctx context.Context, req *protobuf.SetStateRequest) (*empty.Empty, error)

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

+ func (s *GRPCService) Start() error

+ func (s *GRPCService) Stop() error

+ func (s *GRPCService) WatchCluster(req *empty.Empty, server protobuf.Blast_WatchClusterServer) error

+ func (s *GRPCService) WatchState(req *protobuf.WatchStateRequest, server protobuf.Blast_WatchStateServer) error

+ type GetHandler struct

+ func NewGetHandler(client *grpc.Client, logger *log.Logger) *GetHandler

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

+ type PutHandler struct

+ func NewPutHandler(client *grpc.Client, logger *log.Logger) *PutHandler

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

+ type RaftFSM struct

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

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

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

+ func (f *RaftFSM) GetMetadata(id string) (map[string]interface{}, error)

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

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

+ func (f *RaftFSM) Start() error

+ func (f *RaftFSM) Stop() error

+ type RaftFSMSnapshot struct

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

+ func (f *RaftFSMSnapshot) Release()

+ type RaftServer struct

+ func NewRaftServer(id string, metadata map[string]interface{}, bootstrap bool, ...) (*RaftServer, error)

+ func (s *RaftServer) DeleteMetadata(id string) error

+ func (s *RaftServer) DeleteState(key string) error

+ func (s *RaftServer) GetMetadata(id string) (map[string]interface{}, error)

+ func (s *RaftServer) GetServers() (map[string]interface{}, error)

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

+ func (s *RaftServer) IsLeader() bool

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

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

+ func (s *RaftServer) SetMetadata(id string, metadata map[string]interface{}) error

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

+ func (s *RaftServer) Snapshot() error

+ func (s *RaftServer) Start() error

+ func (s *RaftServer) State() string

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

+ func (s *RaftServer) Stop() error

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

+ type RootHandler struct

+ func NewRootHandler(logger *log.Logger) *RootHandler

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

+ type Server struct

+ func NewServer(id string, metadata map[string]interface{}, peerAddr string, ...) (*Server, error)

+ func (s *Server) Start()

+ func (s *Server) Stop()

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL