gRPCspec

Documentation

Index

• Variables
• func RegisterQueueServiceServer(s grpc.ServiceRegistrar, srv QueueServiceServer)
• type Frame
  • func (*Frame) Descriptor() ([]byte, []int)
  • func (x *Frame) GetClient() string
  • func (x *Frame) GetData() []byte
  • func (x *Frame) GetId() string
  • func (x *Frame) GetQos() string
  • func (*Frame) ProtoMessage()
  • func (x *Frame) ProtoReflect() protoreflect.Message
  • func (x *Frame) Reset()
  • func (x *Frame) String() string
• type QueueServer
  • func (s *QueueServer) NextFrame(ctx context.Context, in *Frame) (*Frame, error)
• type QueueServiceClient
  • func NewQueueServiceClient(cc grpc.ClientConnInterface) QueueServiceClient
• type QueueServiceServer
• type UnimplementedQueueServiceServer
  • func (UnimplementedQueueServiceServer) NextFrame(context.Context, *Frame) (*Frame, error)
• type UnsafeQueueServiceServer

Variables

var File_queueService_proto protoreflect.FileDescriptor

var QueueService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "QueueService",
	HandlerType: (*QueueServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "NextFrame",
			Handler:    _QueueService_NextFrame_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "queueService.proto",
}

QueueService_ServiceDesc is the grpc.ServiceDesc for QueueService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterQueueServiceServer

func RegisterQueueServiceServer(s grpc.ServiceRegistrar, srv QueueServiceServer)

Types

type Frame

type Frame struct {
	Client string `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
	Id     string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Qos    string `protobuf:"bytes,3,opt,name=qos,proto3" json:"qos,omitempty"`
	Data   []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"` // generic data byte array containing the expected input and output data of the AR Service
	// contains filtered or unexported fields
}

The request mand response frame structure.

func (*Frame) Descriptor

func (*Frame) Descriptor() ([]byte, []int)

Deprecated: Use Frame.ProtoReflect.Descriptor instead.

func (*Frame) GetClient

func (x *Frame) GetClient() string

func (*Frame) GetData

func (x *Frame) GetData() []byte

func (*Frame) GetId

func (x *Frame) GetId() string

func (*Frame) GetQos

func (x *Frame) GetQos() string

func (*Frame) ProtoMessage

func (*Frame) ProtoMessage()

func (*Frame) ProtoReflect

func (x *Frame) ProtoReflect() protoreflect.Message

func (*Frame) Reset

func (x *Frame) Reset()

func (*Frame) String

func (x *Frame) String() string

type QueueServer

type QueueServer struct {
	UnimplementedQueueServiceServer
	// contains filtered or unexported fields
}

func (*QueueServer) NextFrame

func (s *QueueServer) NextFrame(ctx context.Context, in *Frame) (*Frame, error)

type QueueServiceClient

type QueueServiceClient interface {
	// NextFrame send the next frame
	NextFrame(ctx context.Context, in *Frame, opts ...grpc.CallOption) (*Frame, error)
}

QueueServiceClient is the client API for QueueService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewQueueServiceClient

func NewQueueServiceClient(cc grpc.ClientConnInterface) QueueServiceClient

type QueueServiceServer

type QueueServiceServer interface {
	// NextFrame send the next frame
	NextFrame(context.Context, *Frame) (*Frame, error)
	// contains filtered or unexported methods
}

QueueServiceServer is the server API for QueueService service. All implementations must embed UnimplementedQueueServiceServer for forward compatibility

type UnimplementedQueueServiceServer

type UnimplementedQueueServiceServer struct {
}

UnimplementedQueueServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedQueueServiceServer) NextFrame

func (UnimplementedQueueServiceServer) NextFrame(context.Context, *Frame) (*Frame, error)

type UnsafeQueueServiceServer

type UnsafeQueueServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeQueueServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to QueueServiceServer will result in compilation errors.