transportpb

Documentation

Overview

Package transportpb is a generated protocol buffer package.

It is generated from these files:

transport.proto

It has these top-level messages:

RaftMsg

Index

• Variables
• func RegisterRaftServiceServer(s *grpc.Server, srv RaftServiceServer)
• type RaftMsg
  • func (*RaftMsg) Descriptor() ([]byte, []int)
  • func (m *RaftMsg) GetEpoch() config.TestEpoch
  • func (m *RaftMsg) GetMsgs() []raftpb.Message
  • func (m *RaftMsg) Marshal() (dAtA []byte, err error)
  • func (m *RaftMsg) MarshalTo(dAtA []byte) (int, error)
  • func (*RaftMsg) ProtoMessage()
  • func (m *RaftMsg) Reset()
  • func (m *RaftMsg) Size() (n int)
  • func (m *RaftMsg) String() string
  • func (m *RaftMsg) Unmarshal(dAtA []byte) error
• type RaftServiceClient
  • func NewRaftServiceClient(cc *grpc.ClientConn) RaftServiceClient
• type RaftServiceServer
• type RaftService_RaftMessageClient
• type RaftService_RaftMessageServer

Variables

var (
	ErrInvalidLengthTransport = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTransport   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterRaftServiceServer

func RegisterRaftServiceServer(s *grpc.Server, srv RaftServiceServer)

Types

type RaftMsg

type RaftMsg struct {
	// Epoch indicates the test epoch that this message was sent from. Raft
	// state is reset when an epoch increment is detected and Raft messages
	// from previous epochs are discarded.
	Epoch config.TestEpoch `protobuf:"bytes,1,opt,name=epoch" json:"epoch"`
	// Msgs is a group of wrapped Raft message.
	Msgs []raftpb.Message `protobuf:"bytes,2,rep,name=msgs" json:"msgs"`
}

func (*RaftMsg) Descriptor

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

func (*RaftMsg) GetEpoch

func (m *RaftMsg) GetEpoch() config.TestEpoch

func (*RaftMsg) GetMsgs

func (m *RaftMsg) GetMsgs() []raftpb.Message

func (*RaftMsg) Marshal

func (m *RaftMsg) Marshal() (dAtA []byte, err error)

func (*RaftMsg) MarshalTo

func (m *RaftMsg) MarshalTo(dAtA []byte) (int, error)

func (*RaftMsg) ProtoMessage

func (*RaftMsg) ProtoMessage()

func (*RaftMsg) Reset

func (m *RaftMsg) Reset()

func (*RaftMsg) Size

func (m *RaftMsg) Size() (n int)

func (*RaftMsg) String

func (m *RaftMsg) String() string

func (*RaftMsg) Unmarshal

func (m *RaftMsg) Unmarshal(dAtA []byte) error

type RaftServiceClient

type RaftServiceClient interface {
	RaftMessage(ctx context.Context, opts ...grpc.CallOption) (RaftService_RaftMessageClient, error)
}

func NewRaftServiceClient

func NewRaftServiceClient(cc *grpc.ClientConn) RaftServiceClient

type RaftServiceServer

type RaftServiceServer interface {
	RaftMessage(RaftService_RaftMessageServer) error
}

type RaftService_RaftMessageClient

type RaftService_RaftMessageClient interface {
	Send(*RaftMsg) error
	Recv() (*RaftMsg, error)
	grpc.ClientStream
}

type RaftService_RaftMessageServer

type RaftService_RaftMessageServer interface {
	Send(*RaftMsg) error
	Recv() (*RaftMsg, error)
	grpc.ServerStream
}