transportpb

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(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
}