rpcpb

Documentation

Index

• func RegisterEdgeDeviceServer(s *grpc.Server, srv EdgeDeviceServer)
• type EdgeDeviceClient
  • func NewEdgeDeviceClient(cc *grpc.ClientConn) EdgeDeviceClient
• type EdgeDeviceServer
• type EdgeDevice_SyncClient
• type EdgeDevice_SyncServer
• type UnimplementedEdgeDeviceServer
  • func (*UnimplementedEdgeDeviceServer) Sync(srv EdgeDevice_SyncServer) error

Functions

func RegisterEdgeDeviceServer

func RegisterEdgeDeviceServer(s *grpc.Server, srv EdgeDeviceServer)

Types

type EdgeDeviceClient

type EdgeDeviceClient interface {
	Sync(ctx context.Context, opts ...grpc.CallOption) (EdgeDevice_SyncClient, error)
}

EdgeDeviceClient is the client API for EdgeDevice service.

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

func NewEdgeDeviceClient

func NewEdgeDeviceClient(cc *grpc.ClientConn) EdgeDeviceClient

type EdgeDeviceServer

type EdgeDeviceServer interface {
	Sync(EdgeDevice_SyncServer) error
}

EdgeDeviceServer is the server API for EdgeDevice service.

type EdgeDevice_SyncClient

type EdgeDevice_SyncClient interface {
	Send(*aranyagopb.Msg) error
	Recv() (*aranyagopb.Cmd, error)
	grpc.ClientStream
}

type EdgeDevice_SyncServer

type EdgeDevice_SyncServer interface {
	Send(*aranyagopb.Cmd) error
	Recv() (*aranyagopb.Msg, error)
	grpc.ServerStream
}

type UnimplementedEdgeDeviceServer

type UnimplementedEdgeDeviceServer struct {
}

UnimplementedEdgeDeviceServer can be embedded to have forward compatible implementations.

func (*UnimplementedEdgeDeviceServer) Sync

func (*UnimplementedEdgeDeviceServer) Sync(srv EdgeDevice_SyncServer) error