rpcpb

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(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(srv EdgeDevice_SyncServer) error