intra

package
v0.0.0-...-7f8ad27 Latest Latest
Warning

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

 Go to latest Published: Oct 20, 2018 License: MIT Imports: 5 Imported by: 1

Documentation

Overview

Package intra is a generated protocol buffer package.

It is generated from these files: 

node.proto

It has these top-level messages: 

CreateInfo
CreateResponse
PeerInfo
LeaderRequest
LeaderResponse
AppendEntriesRequest
AppendEntriesResponse
RaftLog
RequestVoteRequest
RequestVoteResponse
UpdateResponse
UpdateConfigRequest
UpdateConfigResponse
StatusRequest
StatusResponse
StatusBufferInfo

Index

Constants

This section is empty.

Variables

View Source 
var RaftLog_LogType_name = map[int32]string{
	0: "LogCommand",
	1: "LogNoop",
	2: "LogAddPeer",
	3: "LogRemovePeer",
	4: "LogBarrier",
}
View Source 
var RaftLog_LogType_value = map[string]int32{
	"LogCommand":    0,
	"LogNoop":       1,
	"LogAddPeer":    2,
	"LogRemovePeer": 3,
	"LogBarrier":    4,
}

Functions

func RegisterNodeRaftServer 

func RegisterNodeRaftServer(s *grpc.Server, srv NodeRaftServer)

func RegisterNodeServer 

func RegisterNodeServer(s *grpc.Server, srv NodeServer)

Types

type AppendEntriesRequest 

type AppendEntriesRequest struct {
	BufferName        string     `protobuf:"bytes,1,opt,name=BufferName,json=bufferName" json:"BufferName,omitempty"`
	Term              uint64     `protobuf:"varint,2,opt,name=Term,json=term" json:"Term,omitempty"`
	Leader            []byte     `protobuf:"bytes,3,opt,name=Leader,json=leader,proto3" json:"Leader,omitempty"`
	PrevLogEntry      uint64     `protobuf:"varint,4,opt,name=PrevLogEntry,json=prevLogEntry" json:"PrevLogEntry,omitempty"`
	PrevLogTerm       uint64     `protobuf:"varint,5,opt,name=PrevLogTerm,json=prevLogTerm" json:"PrevLogTerm,omitempty"`
	Entries           []*RaftLog `protobuf:"bytes,6,rep,name=Entries,json=entries" json:"Entries,omitempty"`
	LeaderCommitIndex uint64     `protobuf:"varint,7,opt,name=LeaderCommitIndex,json=leaderCommitIndex" json:"LeaderCommitIndex,omitempty"`
}

func (*AppendEntriesRequest) Descriptor 

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

func (*AppendEntriesRequest) GetBufferName 

func (m *AppendEntriesRequest) GetBufferName() string

func (*AppendEntriesRequest) GetEntries 

func (m *AppendEntriesRequest) GetEntries() []*RaftLog

func (*AppendEntriesRequest) GetLeader 

func (m *AppendEntriesRequest) GetLeader() []byte

func (*AppendEntriesRequest) GetLeaderCommitIndex 

func (m *AppendEntriesRequest) GetLeaderCommitIndex() uint64

func (*AppendEntriesRequest) GetPrevLogEntry 

func (m *AppendEntriesRequest) GetPrevLogEntry() uint64

func (*AppendEntriesRequest) GetPrevLogTerm 

func (m *AppendEntriesRequest) GetPrevLogTerm() uint64

func (*AppendEntriesRequest) GetTerm 

func (m *AppendEntriesRequest) GetTerm() uint64

func (*AppendEntriesRequest) ProtoMessage 

func (*AppendEntriesRequest) ProtoMessage()

func (*AppendEntriesRequest) Reset 

func (m *AppendEntriesRequest) Reset()

func (*AppendEntriesRequest) String 

func (m *AppendEntriesRequest) String() string

type AppendEntriesResponse 

type AppendEntriesResponse struct {
	Term           uint64 `protobuf:"varint,1,opt,name=Term,json=term" json:"Term,omitempty"`
	LastLog        uint64 `protobuf:"varint,2,opt,name=LastLog,json=lastLog" json:"LastLog,omitempty"`
	Success        bool   `protobuf:"varint,3,opt,name=Success,json=success" json:"Success,omitempty"`
	NoRetryBackoff bool   `protobuf:"varint,4,opt,name=NoRetryBackoff,json=noRetryBackoff" json:"NoRetryBackoff,omitempty"`
}

func (*AppendEntriesResponse) Descriptor 

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

func (*AppendEntriesResponse) GetLastLog 

func (m *AppendEntriesResponse) GetLastLog() uint64

func (*AppendEntriesResponse) GetNoRetryBackoff 

func (m *AppendEntriesResponse) GetNoRetryBackoff() bool

func (*AppendEntriesResponse) GetSuccess 

func (m *AppendEntriesResponse) GetSuccess() bool

func (*AppendEntriesResponse) GetTerm 

func (m *AppendEntriesResponse) GetTerm() uint64

func (*AppendEntriesResponse) ProtoMessage 

func (*AppendEntriesResponse) ProtoMessage()

func (*AppendEntriesResponse) Reset 

func (m *AppendEntriesResponse) Reset()

func (*AppendEntriesResponse) String 

func (m *AppendEntriesResponse) String() string

type CreateInfo 

type CreateInfo struct {
	Name       string      `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	BufferSize uint64      `protobuf:"varint,2,opt,name=buffer_size,json=bufferSize" json:"buffer_size,omitempty"`
	Peers      []*PeerInfo `protobuf:"bytes,3,rep,name=peers" json:"peers,omitempty"`
}

func (*CreateInfo) Descriptor 

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

func (*CreateInfo) GetBufferSize 

func (m *CreateInfo) GetBufferSize() uint64

func (*CreateInfo) GetName 

func (m *CreateInfo) GetName() string

func (*CreateInfo) GetPeers 

func (m *CreateInfo) GetPeers() []*PeerInfo

func (*CreateInfo) ProtoMessage 

func (*CreateInfo) ProtoMessage()

func (*CreateInfo) Reset 

func (m *CreateInfo) Reset()

func (*CreateInfo) String 

func (m *CreateInfo) String() string

type CreateResponse 

type CreateResponse struct {
}

func (*CreateResponse) Descriptor 

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

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) Reset 

func (m *CreateResponse) Reset()

func (*CreateResponse) String 

func (m *CreateResponse) String() string

type LeaderRequest 

type LeaderRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
}

func (*LeaderRequest) Descriptor 

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

func (*LeaderRequest) GetName 

func (m *LeaderRequest) GetName() string

func (*LeaderRequest) ProtoMessage 

func (*LeaderRequest) ProtoMessage()

func (*LeaderRequest) Reset 

func (m *LeaderRequest) Reset()

func (*LeaderRequest) String 

func (m *LeaderRequest) String() string

type LeaderResponse 

type LeaderResponse struct {
	Addr string `protobuf:"bytes,1,opt,name=addr" json:"addr,omitempty"`
}

func (*LeaderResponse) Descriptor 

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

func (*LeaderResponse) GetAddr 

func (m *LeaderResponse) GetAddr() string

func (*LeaderResponse) ProtoMessage 

func (*LeaderResponse) ProtoMessage()

func (*LeaderResponse) Reset 

func (m *LeaderResponse) Reset()

func (*LeaderResponse) String 

func (m *LeaderResponse) String() string

type NodeClient 

type NodeClient interface {
	Create(ctx context.Context, in *CreateInfo, opts ...grpc.CallOption) (*CreateResponse, error)
	UpdateConfig(ctx context.Context, in *UpdateConfigRequest, opts ...grpc.CallOption) (*UpdateConfigResponse, error)
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	Leader(ctx context.Context, in *LeaderRequest, opts ...grpc.CallOption) (*LeaderResponse, error)
}

func NewNodeClient 

func NewNodeClient(cc *grpc.ClientConn) NodeClient

type NodeRaftClient 

type NodeRaftClient interface {
	AppendEntries(ctx context.Context, in *AppendEntriesRequest, opts ...grpc.CallOption) (*AppendEntriesResponse, error)
	RequestVote(ctx context.Context, in *RequestVoteRequest, opts ...grpc.CallOption) (*RequestVoteResponse, error)
}

func NewNodeRaftClient 

func NewNodeRaftClient(cc *grpc.ClientConn) NodeRaftClient

type NodeRaftServer 

type NodeRaftServer interface {
	AppendEntries(context.Context, *AppendEntriesRequest) (*AppendEntriesResponse, error)
	RequestVote(context.Context, *RequestVoteRequest) (*RequestVoteResponse, error)
}

type NodeServer 

type NodeServer interface {
	Create(context.Context, *CreateInfo) (*CreateResponse, error)
	UpdateConfig(context.Context, *UpdateConfigRequest) (*UpdateConfigResponse, error)
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
	Leader(context.Context, *LeaderRequest) (*LeaderResponse, error)
}

type PeerInfo 

type PeerInfo struct {
	Addr string `protobuf:"bytes,1,opt,name=addr" json:"addr,omitempty"`
}

func (*PeerInfo) Descriptor 

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

func (*PeerInfo) GetAddr 

func (m *PeerInfo) GetAddr() string

func (*PeerInfo) ProtoMessage 

func (*PeerInfo) ProtoMessage()

func (*PeerInfo) Reset 

func (m *PeerInfo) Reset()

func (*PeerInfo) String 

func (m *PeerInfo) String() string

type RaftLog 

type RaftLog struct {
	Index uint64          `protobuf:"varint,1,opt,name=Index,json=index" json:"Index,omitempty"`
	Term  uint64          `protobuf:"varint,2,opt,name=Term,json=term" json:"Term,omitempty"`
	Type  RaftLog_LogType `protobuf:"varint,3,opt,name=Type,json=type,enum=intra.RaftLog_LogType" json:"Type,omitempty"`
	Data  []byte          `protobuf:"bytes,4,opt,name=Data,json=data,proto3" json:"Data,omitempty"`
}

func (*RaftLog) Descriptor 

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

func (*RaftLog) GetData 

func (m *RaftLog) GetData() []byte

func (*RaftLog) GetIndex 

func (m *RaftLog) GetIndex() uint64

func (*RaftLog) GetTerm 

func (m *RaftLog) GetTerm() uint64

func (*RaftLog) GetType 

func (m *RaftLog) GetType() RaftLog_LogType

func (*RaftLog) ProtoMessage 

func (*RaftLog) ProtoMessage()

func (*RaftLog) Reset 

func (m *RaftLog) Reset()

func (*RaftLog) String 

func (m *RaftLog) String() string

type RaftLog_LogType 

type RaftLog_LogType int32
const (
	RaftLog_LogCommand    RaftLog_LogType = 0
	RaftLog_LogNoop       RaftLog_LogType = 1
	RaftLog_LogAddPeer    RaftLog_LogType = 2
	RaftLog_LogRemovePeer RaftLog_LogType = 3
	RaftLog_LogBarrier    RaftLog_LogType = 4
)

func (RaftLog_LogType) EnumDescriptor 

func (RaftLog_LogType) EnumDescriptor() ([]byte, []int)

func (RaftLog_LogType) String 

func (x RaftLog_LogType) String() string

type RequestVoteRequest 

type RequestVoteRequest struct {
	BufferName   string `protobuf:"bytes,1,opt,name=BufferName,json=bufferName" json:"BufferName,omitempty"`
	Term         uint64 `protobuf:"varint,2,opt,name=Term,json=term" json:"Term,omitempty"`
	Candidate    []byte `protobuf:"bytes,3,opt,name=Candidate,json=candidate,proto3" json:"Candidate,omitempty"`
	LastLogIndex uint64 `protobuf:"varint,4,opt,name=LastLogIndex,json=lastLogIndex" json:"LastLogIndex,omitempty"`
	LastLogTerm  uint64 `protobuf:"varint,5,opt,name=LastLogTerm,json=lastLogTerm" json:"LastLogTerm,omitempty"`
}

func (*RequestVoteRequest) Descriptor 

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

func (*RequestVoteRequest) GetBufferName 

func (m *RequestVoteRequest) GetBufferName() string

func (*RequestVoteRequest) GetCandidate 

func (m *RequestVoteRequest) GetCandidate() []byte

func (*RequestVoteRequest) GetLastLogIndex 

func (m *RequestVoteRequest) GetLastLogIndex() uint64

func (*RequestVoteRequest) GetLastLogTerm 

func (m *RequestVoteRequest) GetLastLogTerm() uint64

func (*RequestVoteRequest) GetTerm 

func (m *RequestVoteRequest) GetTerm() uint64

func (*RequestVoteRequest) ProtoMessage 

func (*RequestVoteRequest) ProtoMessage()

func (*RequestVoteRequest) Reset 

func (m *RequestVoteRequest) Reset()

func (*RequestVoteRequest) String 

func (m *RequestVoteRequest) String() string

type RequestVoteResponse 

type RequestVoteResponse struct {
	Term    uint64 `protobuf:"varint,1,opt,name=Term,json=term" json:"Term,omitempty"`
	Peers   []byte `protobuf:"bytes,2,opt,name=Peers,json=peers,proto3" json:"Peers,omitempty"`
	Granted bool   `protobuf:"varint,3,opt,name=Granted,json=granted" json:"Granted,omitempty"`
}

func (*RequestVoteResponse) Descriptor 

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

func (*RequestVoteResponse) GetGranted 

func (m *RequestVoteResponse) GetGranted() bool

func (*RequestVoteResponse) GetPeers 

func (m *RequestVoteResponse) GetPeers() []byte

func (*RequestVoteResponse) GetTerm 

func (m *RequestVoteResponse) GetTerm() uint64

func (*RequestVoteResponse) ProtoMessage 

func (*RequestVoteResponse) ProtoMessage()

func (*RequestVoteResponse) Reset 

func (m *RequestVoteResponse) Reset()

func (*RequestVoteResponse) String 

func (m *RequestVoteResponse) String() string

type StatusBufferInfo 

type StatusBufferInfo struct {
	Name          string   `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	ExpectedNodes []string `protobuf:"bytes,2,rep,name=expectedNodes" json:"expectedNodes,omitempty"`
}

func (*StatusBufferInfo) Descriptor 

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

func (*StatusBufferInfo) GetExpectedNodes 

func (m *StatusBufferInfo) GetExpectedNodes() []string

func (*StatusBufferInfo) GetName 

func (m *StatusBufferInfo) GetName() string

func (*StatusBufferInfo) ProtoMessage 

func (*StatusBufferInfo) ProtoMessage()

func (*StatusBufferInfo) Reset 

func (m *StatusBufferInfo) Reset()

func (*StatusBufferInfo) String 

func (m *StatusBufferInfo) String() string

type StatusRequest 

type StatusRequest struct {
}

func (*StatusRequest) Descriptor 

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

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) Reset 

func (m *StatusRequest) Reset()

func (*StatusRequest) String 

func (m *StatusRequest) String() string

type StatusResponse 

type StatusResponse struct {
	ExternalAddr string              `protobuf:"bytes,1,opt,name=externalAddr" json:"externalAddr,omitempty"`
	Buffers      []*StatusBufferInfo `protobuf:"bytes,2,rep,name=buffers" json:"buffers,omitempty"`
}

func (*StatusResponse) Descriptor 

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

func (*StatusResponse) GetBuffers 

func (m *StatusResponse) GetBuffers() []*StatusBufferInfo

func (*StatusResponse) GetExternalAddr 

func (m *StatusResponse) GetExternalAddr() string

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) Reset 

func (m *StatusResponse) Reset()

func (*StatusResponse) String 

func (m *StatusResponse) String() string

type UpdateConfigRequest 

type UpdateConfigRequest struct {
	Name          string   `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	ExpectedNodes []string `protobuf:"bytes,2,rep,name=expectedNodes" json:"expectedNodes,omitempty"`
}

func (*UpdateConfigRequest) Descriptor 

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

func (*UpdateConfigRequest) GetExpectedNodes 

func (m *UpdateConfigRequest) GetExpectedNodes() []string

func (*UpdateConfigRequest) GetName 

func (m *UpdateConfigRequest) GetName() string

func (*UpdateConfigRequest) ProtoMessage 

func (*UpdateConfigRequest) ProtoMessage()

func (*UpdateConfigRequest) Reset 

func (m *UpdateConfigRequest) Reset()

func (*UpdateConfigRequest) String 

func (m *UpdateConfigRequest) String() string

type UpdateConfigResponse 

type UpdateConfigResponse struct {
}

func (*UpdateConfigResponse) Descriptor 

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

func (*UpdateConfigResponse) ProtoMessage 

func (*UpdateConfigResponse) ProtoMessage()

func (*UpdateConfigResponse) Reset 

func (m *UpdateConfigResponse) Reset()

func (*UpdateConfigResponse) String 

func (m *UpdateConfigResponse) String() string

type UpdateResponse 

type UpdateResponse struct {
	Dropped bool `protobuf:"varint,1,opt,name=dropped" json:"dropped,omitempty"`
}

func (*UpdateResponse) Descriptor 

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

func (*UpdateResponse) GetDropped 

func (m *UpdateResponse) GetDropped() bool

func (*UpdateResponse) ProtoMessage 

func (*UpdateResponse) ProtoMessage()

func (*UpdateResponse) Reset 

func (m *UpdateResponse) Reset()

func (*UpdateResponse) String 

func (m *UpdateResponse) String() string

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.