transportpb

package
v2.1.7+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 7, 2019 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL