transportpb

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

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

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

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

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

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