grpc_v1

Documentation

Index

• Variables
• func RegisterRouterServiceServer(s grpc.ServiceRegistrar, srv RouterServiceServer)
• type RouterServiceClient
  • func NewRouterServiceClient(cc grpc.ClientConnInterface) RouterServiceClient
• type RouterServiceServer
• type RouterService_StreamClient
• type RouterService_StreamServer
• type StreamRequest
  • func (*StreamRequest) Descriptor() ([]byte, []int)
  • func (x *StreamRequest) GetClosed() bool
  • func (x *StreamRequest) GetPayload() []byte
  • func (*StreamRequest) ProtoMessage()
  • func (x *StreamRequest) ProtoReflect() protoreflect.Message
  • func (x *StreamRequest) Reset()
  • func (x *StreamRequest) String() string
• type StreamResponse
  • func (*StreamResponse) Descriptor() ([]byte, []int)
  • func (x *StreamResponse) GetClosed() bool
  • func (x *StreamResponse) GetPayload() []byte
  • func (*StreamResponse) ProtoMessage()
  • func (x *StreamResponse) ProtoReflect() protoreflect.Message
  • func (x *StreamResponse) Reset()
  • func (x *StreamResponse) String() string
• type UnimplementedRouterServiceServer
  • func (UnimplementedRouterServiceServer) Stream(RouterService_StreamServer) error
• type UnsafeRouterServiceServer

Variables

var File_router_proto protoreflect.FileDescriptor

var RouterService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flightctl.v1.RouterService",
	HandlerType: (*RouterServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Stream",
			Handler:       _RouterService_Stream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "router.proto",
}

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

Functions

func RegisterRouterServiceServer

func RegisterRouterServiceServer(s grpc.ServiceRegistrar, srv RouterServiceServer)

Types

type RouterServiceClient

type RouterServiceClient interface {
	// Stream connects caller to another caller of the same stream
	// in the call context we expect:
	// - the stream ID
	Stream(ctx context.Context, opts ...grpc.CallOption) (RouterService_StreamClient, error)
}

RouterServiceClient is the client API for RouterService 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 NewRouterServiceClient

func NewRouterServiceClient(cc grpc.ClientConnInterface) RouterServiceClient

type RouterServiceServer

type RouterServiceServer interface {
	// Stream connects caller to another caller of the same stream
	// in the call context we expect:
	// - the stream ID
	Stream(RouterService_StreamServer) error
	// contains filtered or unexported methods
}

RouterServiceServer is the server API for RouterService service. All implementations must embed UnimplementedRouterServiceServer for forward compatibility

type RouterService_StreamClient

type RouterService_StreamClient interface {
	Send(*StreamRequest) error
	Recv() (*StreamResponse, error)
	grpc.ClientStream
}

type RouterService_StreamServer

type RouterService_StreamServer interface {
	Send(*StreamResponse) error
	Recv() (*StreamRequest, error)
	grpc.ServerStream
}

type StreamRequest

type StreamRequest struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Closed  bool   `protobuf:"varint,2,opt,name=closed,proto3" json:"closed,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamRequest) Descriptor

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

Deprecated: Use StreamRequest.ProtoReflect.Descriptor instead.

func (*StreamRequest) GetClosed

func (x *StreamRequest) GetClosed() bool

func (*StreamRequest) GetPayload

func (x *StreamRequest) GetPayload() []byte

func (*StreamRequest) ProtoMessage

func (*StreamRequest) ProtoMessage()

func (*StreamRequest) ProtoReflect

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

func (*StreamRequest) Reset

func (x *StreamRequest) Reset()

func (*StreamRequest) String

func (x *StreamRequest) String() string

type StreamResponse

type StreamResponse struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Closed  bool   `protobuf:"varint,2,opt,name=closed,proto3" json:"closed,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamResponse) Descriptor

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

Deprecated: Use StreamResponse.ProtoReflect.Descriptor instead.

func (*StreamResponse) GetClosed

func (x *StreamResponse) GetClosed() bool

func (*StreamResponse) GetPayload

func (x *StreamResponse) GetPayload() []byte

func (*StreamResponse) ProtoMessage

func (*StreamResponse) ProtoMessage()

func (*StreamResponse) ProtoReflect

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

func (*StreamResponse) Reset

func (x *StreamResponse) Reset()

func (*StreamResponse) String

func (x *StreamResponse) String() string

type UnimplementedRouterServiceServer

type UnimplementedRouterServiceServer struct {
}

UnimplementedRouterServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedRouterServiceServer) Stream

func (UnimplementedRouterServiceServer) Stream(RouterService_StreamServer) error

type UnsafeRouterServiceServer

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

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