proto

Documentation

Overview

Package proto is a generated protocol buffer package.

It is generated from these files:

raftrpc.proto

It has these top-level messages:

Nothing

Index

• Variables
• func RegisterRaftServer(s *grpc.Server, srv RaftServer)
• type Nothing
  • func (m *Nothing) Marshal() (data []byte, err error)
  • func (m *Nothing) MarshalTo(data []byte) (int, error)
  • func (*Nothing) ProtoMessage()
  • func (m *Nothing) Reset()
  • func (m *Nothing) Size() (n int)
  • func (m *Nothing) String() string
  • func (m *Nothing) Unmarshal(data []byte) error
• type RaftClient
  • func NewRaftClient(cc *grpc.ClientConn) RaftClient
• type RaftServer

Variables

var (
	ErrInvalidLengthRaftrpc = fmt.Errorf("proto: negative length found during unmarshaling")
)

Functions

func RegisterRaftServer

func RegisterRaftServer(s *grpc.Server, srv RaftServer)

Types

type Nothing

type Nothing struct {
}

func (*Nothing) Marshal

func (m *Nothing) Marshal() (data []byte, err error)

func (*Nothing) MarshalTo

func (m *Nothing) MarshalTo(data []byte) (int, error)

func (*Nothing) ProtoMessage

func (*Nothing) ProtoMessage()

func (*Nothing) Reset

func (m *Nothing) Reset()

func (*Nothing) Size

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

func (*Nothing) String

func (m *Nothing) String() string

func (*Nothing) Unmarshal

func (m *Nothing) Unmarshal(data []byte) error

type RaftClient

type RaftClient interface {
	Step(ctx context.Context, in *raftpb.Message, opts ...grpc.CallOption) (*Nothing, error)
}

func NewRaftClient

func NewRaftClient(cc *grpc.ClientConn) RaftClient

type RaftServer

type RaftServer interface {
	Step(context.Context, *raftpb.Message) (*Nothing, error)
}