raft

package
v0.4.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Cluster 

type Cluster struct {
	Nodes                []*Node  `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Cluster) Descriptor 

func (*Cluster) Descriptor() ([]byte, []int)

func (*Cluster) GetNodes 

func (m *Cluster) GetNodes() []*Node

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) Reset 

func (m *Cluster) Reset()

func (*Cluster) String 

func (m *Cluster) String() string

func (*Cluster) XXX_DiscardUnknown 

func (m *Cluster) XXX_DiscardUnknown()

func (*Cluster) XXX_Marshal 

func (m *Cluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Cluster) XXX_Merge 

func (m *Cluster) XXX_Merge(src proto.Message)

func (*Cluster) XXX_Size 

func (m *Cluster) XXX_Size() int

func (*Cluster) XXX_Unmarshal 

func (m *Cluster) XXX_Unmarshal(b []byte) error

type GetClusterResponse 

type GetClusterResponse struct {
	Cluster              *Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetClusterResponse) Descriptor 

func (*GetClusterResponse) Descriptor() ([]byte, []int)

func (*GetClusterResponse) GetCluster 

func (m *GetClusterResponse) GetCluster() *Cluster

func (*GetClusterResponse) ProtoMessage 

func (*GetClusterResponse) ProtoMessage()

func (*GetClusterResponse) Reset 

func (m *GetClusterResponse) Reset()

func (*GetClusterResponse) String 

func (m *GetClusterResponse) String() string

func (*GetClusterResponse) XXX_DiscardUnknown 

func (m *GetClusterResponse) XXX_DiscardUnknown()

func (*GetClusterResponse) XXX_Marshal 

func (m *GetClusterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetClusterResponse) XXX_Merge 

func (m *GetClusterResponse) XXX_Merge(src proto.Message)

func (*GetClusterResponse) XXX_Size 

func (m *GetClusterResponse) XXX_Size() int

func (*GetClusterResponse) XXX_Unmarshal 

func (m *GetClusterResponse) XXX_Unmarshal(b []byte) error

type GetNodeResponse 

type GetNodeResponse struct {
	Node                 *Node    `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetNodeResponse) Descriptor 

func (*GetNodeResponse) Descriptor() ([]byte, []int)

func (*GetNodeResponse) GetNode 

func (m *GetNodeResponse) GetNode() *Node

func (*GetNodeResponse) ProtoMessage 

func (*GetNodeResponse) ProtoMessage()

func (*GetNodeResponse) Reset 

func (m *GetNodeResponse) Reset()

func (*GetNodeResponse) String 

func (m *GetNodeResponse) String() string

func (*GetNodeResponse) XXX_DiscardUnknown 

func (m *GetNodeResponse) XXX_DiscardUnknown()

func (*GetNodeResponse) XXX_Marshal 

func (m *GetNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetNodeResponse) XXX_Merge 

func (m *GetNodeResponse) XXX_Merge(src proto.Message)

func (*GetNodeResponse) XXX_Size 

func (m *GetNodeResponse) XXX_Size() int

func (*GetNodeResponse) XXX_Unmarshal 

func (m *GetNodeResponse) XXX_Unmarshal(b []byte) error

type JoinRequest 

type JoinRequest struct {
	Node                 *Node    `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JoinRequest) Descriptor 

func (*JoinRequest) Descriptor() ([]byte, []int)

func (*JoinRequest) GetNode 

func (m *JoinRequest) GetNode() *Node

func (*JoinRequest) ProtoMessage 

func (*JoinRequest) ProtoMessage()

func (*JoinRequest) Reset 

func (m *JoinRequest) Reset()

func (*JoinRequest) String 

func (m *JoinRequest) String() string

func (*JoinRequest) XXX_DiscardUnknown 

func (m *JoinRequest) XXX_DiscardUnknown()

func (*JoinRequest) XXX_Marshal 

func (m *JoinRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JoinRequest) XXX_Merge 

func (m *JoinRequest) XXX_Merge(src proto.Message)

func (*JoinRequest) XXX_Size 

func (m *JoinRequest) XXX_Size() int

func (*JoinRequest) XXX_Unmarshal 

func (m *JoinRequest) XXX_Unmarshal(b []byte) error

type LeaveRequest 

type LeaveRequest struct {
	Node                 *Node    `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LeaveRequest) Descriptor 

func (*LeaveRequest) Descriptor() ([]byte, []int)

func (*LeaveRequest) GetNode 

func (m *LeaveRequest) GetNode() *Node

func (*LeaveRequest) ProtoMessage 

func (*LeaveRequest) ProtoMessage()

func (*LeaveRequest) Reset 

func (m *LeaveRequest) Reset()

func (*LeaveRequest) String 

func (m *LeaveRequest) String() string

func (*LeaveRequest) XXX_DiscardUnknown 

func (m *LeaveRequest) XXX_DiscardUnknown()

func (*LeaveRequest) XXX_Marshal 

func (m *LeaveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LeaveRequest) XXX_Merge 

func (m *LeaveRequest) XXX_Merge(src proto.Message)

func (*LeaveRequest) XXX_Size 

func (m *LeaveRequest) XXX_Size() int

func (*LeaveRequest) XXX_Unmarshal 

func (m *LeaveRequest) XXX_Unmarshal(b []byte) error

type Node 

type Node struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	BindAddr             string   `protobuf:"bytes,2,opt,name=bind_addr,json=bindAddr,proto3" json:"bind_addr,omitempty"`
	GrpcAddr             string   `protobuf:"bytes,3,opt,name=grpc_addr,json=grpcAddr,proto3" json:"grpc_addr,omitempty"`
	HttpAddr             string   `protobuf:"bytes,4,opt,name=http_addr,json=httpAddr,proto3" json:"http_addr,omitempty"`
	Leader               bool     `protobuf:"varint,5,opt,name=leader,proto3" json:"leader,omitempty"`
	DataDir              string   `protobuf:"bytes,6,opt,name=data_dir,json=dataDir,proto3" json:"data_dir,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Node) Descriptor 

func (*Node) Descriptor() ([]byte, []int)

func (*Node) GetBindAddr 

func (m *Node) GetBindAddr() string

func (*Node) GetDataDir 

func (m *Node) GetDataDir() string

func (*Node) GetGrpcAddr 

func (m *Node) GetGrpcAddr() string

func (*Node) GetHttpAddr 

func (m *Node) GetHttpAddr() string

func (*Node) GetId 

func (m *Node) GetId() string

func (*Node) GetLeader 

func (m *Node) GetLeader() bool

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) String 

func (m *Node) String() string

func (*Node) XXX_DiscardUnknown 

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal 

func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Node) XXX_Merge 

func (m *Node) XXX_Merge(src proto.Message)

func (*Node) XXX_Size 

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal 

func (m *Node) XXX_Unmarshal(b []byte) 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.