protobufs

package
v0.5.3 Latest Latest
Warning

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

 Go to latest Published: Jul 15, 2016 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Overview

Package protobufs is a generated protocol buffer package.

It is generated from these files: 

common.proto
communication.proto
nodelist.proto
config.proto

It has these top-level messages: 

EntryPb
VoteRequestPb
VoteResponsePb
AppendRequestPb
JoinRequestPb
AppendResponsePb
ProposalResponsePb
DiscoveryResponsePb
NodePb
NodeListPb
PurgeConfig
ConfigPb

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AppendRequestPb 

type AppendRequestPb struct {
	Term             *uint64    `protobuf:"varint,1,req,name=term" json:"term,omitempty"`
	LeaderId         *uint64    `protobuf:"fixed64,2,req,name=leaderId" json:"leaderId,omitempty"`
	PrevLogIndex     *uint64    `protobuf:"varint,3,req,name=prevLogIndex" json:"prevLogIndex,omitempty"`
	PrevLogTerm      *uint64    `protobuf:"varint,4,req,name=prevLogTerm" json:"prevLogTerm,omitempty"`
	LeaderCommit     *uint64    `protobuf:"varint,5,req,name=leaderCommit" json:"leaderCommit,omitempty"`
	Entries          []*EntryPb `protobuf:"bytes,6,rep,name=entries" json:"entries,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*AppendRequestPb) Descriptor 

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

func (*AppendRequestPb) GetEntries 

func (m *AppendRequestPb) GetEntries() []*EntryPb

func (*AppendRequestPb) GetLeaderCommit 

func (m *AppendRequestPb) GetLeaderCommit() uint64

func (*AppendRequestPb) GetLeaderId 

func (m *AppendRequestPb) GetLeaderId() uint64

func (*AppendRequestPb) GetPrevLogIndex 

func (m *AppendRequestPb) GetPrevLogIndex() uint64

func (*AppendRequestPb) GetPrevLogTerm 

func (m *AppendRequestPb) GetPrevLogTerm() uint64

func (*AppendRequestPb) GetTerm 

func (m *AppendRequestPb) GetTerm() uint64

func (*AppendRequestPb) ProtoMessage 

func (*AppendRequestPb) ProtoMessage()

func (*AppendRequestPb) Reset 

func (m *AppendRequestPb) Reset()

func (*AppendRequestPb) String 

func (m *AppendRequestPb) String() string

type AppendResponsePb 

type AppendResponsePb struct {
	Term             *uint64 `protobuf:"varint,1,req,name=term" json:"term,omitempty"`
	Success          *bool   `protobuf:"varint,2,req,name=success" json:"success,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*AppendResponsePb) Descriptor 

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

func (*AppendResponsePb) GetSuccess 

func (m *AppendResponsePb) GetSuccess() bool

func (*AppendResponsePb) GetTerm 

func (m *AppendResponsePb) GetTerm() uint64

func (*AppendResponsePb) ProtoMessage 

func (*AppendResponsePb) ProtoMessage()

func (*AppendResponsePb) Reset 

func (m *AppendResponsePb) Reset()

func (*AppendResponsePb) String 

func (m *AppendResponsePb) String() string

type ConfigPb added in v0.5.2 

type ConfigPb struct {
	Purge            *PurgeConfig `protobuf:"bytes,1,opt,name=purge" json:"purge,omitempty"`
	HeartbeatTimeout *int64       `protobuf:"varint,2,req,name=heartbeatTimeout" json:"heartbeatTimeout,omitempty"`
	ElectionTimeout  *int64       `protobuf:"varint,3,req,name=electionTimeout" json:"electionTimeout,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*ConfigPb) Descriptor added in v0.5.2 

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

func (*ConfigPb) GetElectionTimeout added in v0.5.2 

func (m *ConfigPb) GetElectionTimeout() int64

func (*ConfigPb) GetHeartbeatTimeout added in v0.5.2 

func (m *ConfigPb) GetHeartbeatTimeout() int64

func (*ConfigPb) GetPurge added in v0.5.2 

func (m *ConfigPb) GetPurge() *PurgeConfig

func (*ConfigPb) ProtoMessage added in v0.5.2 

func (*ConfigPb) ProtoMessage()

func (*ConfigPb) Reset added in v0.5.2 

func (m *ConfigPb) Reset()

func (*ConfigPb) String added in v0.5.2 

func (m *ConfigPb) String() string

type DiscoveryResponsePb 

type DiscoveryResponsePb struct {
	NodeId           *uint64 `protobuf:"fixed64,1,req,name=nodeId" json:"nodeId,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DiscoveryResponsePb) Descriptor 

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

func (*DiscoveryResponsePb) GetNodeId 

func (m *DiscoveryResponsePb) GetNodeId() uint64

func (*DiscoveryResponsePb) ProtoMessage 

func (*DiscoveryResponsePb) ProtoMessage()

func (*DiscoveryResponsePb) Reset 

func (m *DiscoveryResponsePb) Reset()

func (*DiscoveryResponsePb) String 

func (m *DiscoveryResponsePb) String() string

type EntryPb 

type EntryPb struct {
	Index            *uint64  `protobuf:"varint,1,req,name=index" json:"index,omitempty"`
	Type             *int32   `protobuf:"varint,2,req,name=type" json:"type,omitempty"`
	Term             *uint64  `protobuf:"varint,3,opt,name=term" json:"term,omitempty"`
	Timestamp        *int64   `protobuf:"varint,4,opt,name=timestamp" json:"timestamp,omitempty"`
	Tags             []string `protobuf:"bytes,5,rep,name=tags" json:"tags,omitempty"`
	Data             []byte   `protobuf:"bytes,6,opt,name=data" json:"data,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

A single Raft entry.

func (*EntryPb) Descriptor 

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

func (*EntryPb) GetData 

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

func (*EntryPb) GetIndex 

func (m *EntryPb) GetIndex() uint64

func (*EntryPb) GetTags 

func (m *EntryPb) GetTags() []string

func (*EntryPb) GetTerm 

func (m *EntryPb) GetTerm() uint64

func (*EntryPb) GetTimestamp 

func (m *EntryPb) GetTimestamp() int64

func (*EntryPb) GetType 

func (m *EntryPb) GetType() int32

func (*EntryPb) ProtoMessage 

func (*EntryPb) ProtoMessage()

func (*EntryPb) Reset 

func (m *EntryPb) Reset()

func (*EntryPb) String 

func (m *EntryPb) String() string

type JoinRequestPb 

type JoinRequestPb struct {
	ClusterId        *uint64    `protobuf:"fixed64,1,req,name=clusterId" json:"clusterId,omitempty"`
	Last             *bool      `protobuf:"varint,2,opt,name=last" json:"last,omitempty"`
	Entries          []*EntryPb `protobuf:"bytes,3,rep,name=entries" json:"entries,omitempty"`
	ConfigEntries    []*EntryPb `protobuf:"bytes,4,rep,name=configEntries" json:"configEntries,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*JoinRequestPb) Descriptor 

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

func (*JoinRequestPb) GetClusterId 

func (m *JoinRequestPb) GetClusterId() uint64

func (*JoinRequestPb) GetConfigEntries added in v0.5.2 

func (m *JoinRequestPb) GetConfigEntries() []*EntryPb

func (*JoinRequestPb) GetEntries 

func (m *JoinRequestPb) GetEntries() []*EntryPb

func (*JoinRequestPb) GetLast 

func (m *JoinRequestPb) GetLast() bool

func (*JoinRequestPb) ProtoMessage 

func (*JoinRequestPb) ProtoMessage()

func (*JoinRequestPb) Reset 

func (m *JoinRequestPb) Reset()

func (*JoinRequestPb) String 

func (m *JoinRequestPb) String() string

type NodeListPb 

type NodeListPb struct {
	Current          []*NodePb `protobuf:"bytes,1,rep,name=current" json:"current,omitempty"`
	Next             []*NodePb `protobuf:"bytes,2,rep,name=next" json:"next,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*NodeListPb) Descriptor 

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

func (*NodeListPb) GetCurrent 

func (m *NodeListPb) GetCurrent() []*NodePb

func (*NodeListPb) GetNext 

func (m *NodeListPb) GetNext() []*NodePb

func (*NodeListPb) ProtoMessage 

func (*NodeListPb) ProtoMessage()

func (*NodeListPb) Reset 

func (m *NodeListPb) Reset()

func (*NodeListPb) String 

func (m *NodeListPb) String() string

type NodePb 

type NodePb struct {
	NodeId           *uint64 `protobuf:"fixed64,1,req,name=nodeId" json:"nodeId,omitempty"`
	Address          *string `protobuf:"bytes,2,req,name=address" json:"address,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*NodePb) Descriptor 

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

func (*NodePb) GetAddress 

func (m *NodePb) GetAddress() string

func (*NodePb) GetNodeId 

func (m *NodePb) GetNodeId() uint64

func (*NodePb) ProtoMessage 

func (*NodePb) ProtoMessage()

func (*NodePb) Reset 

func (m *NodePb) Reset()

func (*NodePb) String 

func (m *NodePb) String() string

type ProposalResponsePb 

type ProposalResponsePb struct {
	NewIndex         *uint64 `protobuf:"varint,1,req,name=newIndex" json:"newIndex,omitempty"`
	Error            *string `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ProposalResponsePb) Descriptor 

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

func (*ProposalResponsePb) GetError 

func (m *ProposalResponsePb) GetError() string

func (*ProposalResponsePb) GetNewIndex 

func (m *ProposalResponsePb) GetNewIndex() uint64

func (*ProposalResponsePb) ProtoMessage 

func (*ProposalResponsePb) ProtoMessage()

func (*ProposalResponsePb) Reset 

func (m *ProposalResponsePb) Reset()

func (*ProposalResponsePb) String 

func (m *ProposalResponsePb) String() string

type PurgeConfig added in v0.5.2 

type PurgeConfig struct {
	MinDuration      *int64  `protobuf:"varint,1,req,name=minDuration" json:"minDuration,omitempty"`
	MinRecords       *uint32 `protobuf:"varint,2,req,name=minRecords" json:"minRecords,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*PurgeConfig) Descriptor added in v0.5.2 

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

func (*PurgeConfig) GetMinDuration added in v0.5.2 

func (m *PurgeConfig) GetMinDuration() int64

func (*PurgeConfig) GetMinRecords added in v0.5.2 

func (m *PurgeConfig) GetMinRecords() uint32

func (*PurgeConfig) ProtoMessage added in v0.5.2 

func (*PurgeConfig) ProtoMessage()

func (*PurgeConfig) Reset added in v0.5.2 

func (m *PurgeConfig) Reset()

func (*PurgeConfig) String added in v0.5.2 

func (m *PurgeConfig) String() string

type VoteRequestPb 

type VoteRequestPb struct {
	Term             *uint64 `protobuf:"varint,1,req,name=term" json:"term,omitempty"`
	CandidateId      *uint64 `protobuf:"fixed64,2,req,name=candidateId" json:"candidateId,omitempty"`
	LastLogIndex     *uint64 `protobuf:"varint,3,req,name=lastLogIndex" json:"lastLogIndex,omitempty"`
	LastLogTerm      *uint64 `protobuf:"varint,4,req,name=lastLogTerm" json:"lastLogTerm,omitempty"`
	ClusterId        *uint64 `protobuf:"fixed64,5,req,name=clusterId" json:"clusterId,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*VoteRequestPb) Descriptor 

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

func (*VoteRequestPb) GetCandidateId 

func (m *VoteRequestPb) GetCandidateId() uint64

func (*VoteRequestPb) GetClusterId 

func (m *VoteRequestPb) GetClusterId() uint64

func (*VoteRequestPb) GetLastLogIndex 

func (m *VoteRequestPb) GetLastLogIndex() uint64

func (*VoteRequestPb) GetLastLogTerm 

func (m *VoteRequestPb) GetLastLogTerm() uint64

func (*VoteRequestPb) GetTerm 

func (m *VoteRequestPb) GetTerm() uint64

func (*VoteRequestPb) ProtoMessage 

func (*VoteRequestPb) ProtoMessage()

func (*VoteRequestPb) Reset 

func (m *VoteRequestPb) Reset()

func (*VoteRequestPb) String 

func (m *VoteRequestPb) String() string

type VoteResponsePb 

type VoteResponsePb struct {
	NodeId           *uint64 `protobuf:"fixed64,1,req,name=nodeId" json:"nodeId,omitempty"`
	Term             *uint64 `protobuf:"varint,2,req,name=term" json:"term,omitempty"`
	VoteGranted      *bool   `protobuf:"varint,3,req,name=voteGranted" json:"voteGranted,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*VoteResponsePb) Descriptor 

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

func (*VoteResponsePb) GetNodeId 

func (m *VoteResponsePb) GetNodeId() uint64

func (*VoteResponsePb) GetTerm 

func (m *VoteResponsePb) GetTerm() uint64

func (*VoteResponsePb) GetVoteGranted 

func (m *VoteResponsePb) GetVoteGranted() bool

func (*VoteResponsePb) ProtoMessage 

func (*VoteResponsePb) ProtoMessage()

func (*VoteResponsePb) Reset 

func (m *VoteResponsePb) Reset()

func (*VoteResponsePb) String 

func (m *VoteResponsePb) 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.