transportpb

Documentation

Index

• func RegisterTransportServer(s *grpc.Server, srv TransportServer)
• type TransportClient
  • func NewTransportClient(cc *grpc.ClientConn) TransportClient
• type TransportServer
• type Transport_RaftMessageClient
• type Transport_RaftMessageServer
• type Transport_RaftSnapshotClient
• type Transport_RaftSnapshotServer

Functions

func RegisterTransportServer

func RegisterTransportServer(s *grpc.Server, srv TransportServer)

Types

type TransportClient

type TransportClient interface {
	RaftMessage(ctx context.Context, opts ...grpc.CallOption) (Transport_RaftMessageClient, error)
	RaftSnapshot(ctx context.Context, opts ...grpc.CallOption) (Transport_RaftSnapshotClient, error)
}

TransportClient is the client API for Transport service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTransportClient

func NewTransportClient(cc *grpc.ClientConn) TransportClient

type TransportServer

type TransportServer interface {
	RaftMessage(Transport_RaftMessageServer) error
	RaftSnapshot(Transport_RaftSnapshotServer) error
}

TransportServer is the server API for Transport service.

type Transport_RaftMessageClient

type Transport_RaftMessageClient interface {
	Send(*raftpb.MessageBatch) error
	Recv() (*raftpb.Response, error)
	grpc.ClientStream
}

type Transport_RaftMessageServer

type Transport_RaftMessageServer interface {
	Send(*raftpb.Response) error
	Recv() (*raftpb.MessageBatch, error)
	grpc.ServerStream
}

type Transport_RaftSnapshotClient

type Transport_RaftSnapshotClient interface {
	Send(*raftpb.SnapshotChunk) error
	Recv() (*raftpb.Response, error)
	grpc.ClientStream
}

type Transport_RaftSnapshotServer

type Transport_RaftSnapshotServer interface {
	Send(*raftpb.Response) error
	Recv() (*raftpb.SnapshotChunk, error)
	grpc.ServerStream
}