api

Documentation

Index

• Constants
• Variables
• func RegisterExchangeServiceServer(s grpc.ServiceRegistrar, srv ExchangeServiceServer)
• type ConnectCommand
  • func (*ConnectCommand) Descriptor() ([]byte, []int)
  • func (x *ConnectCommand) GetId() uint64
  • func (x *ConnectCommand) GetNameSpace() string
  • func (x *ConnectCommand) GetServiceName() string
  • func (*ConnectCommand) ProtoMessage()
  • func (x *ConnectCommand) ProtoReflect() protoreflect.Message
  • func (x *ConnectCommand) Reset()
  • func (x *ConnectCommand) String() string
• type ExchangeServiceClient
  • func NewExchangeServiceClient(cc grpc.ClientConnInterface) ExchangeServiceClient
• type ExchangeServiceServer
• type ExchangeService_RegisterServiceClient
• type ExchangeService_RegisterServiceServer
• type RegisterRequest
  • func (*RegisterRequest) Descriptor() ([]byte, []int)
  • func (x *RegisterRequest) GetNameSpace() string
  • func (x *RegisterRequest) GetServiceName() []string
  • func (*RegisterRequest) ProtoMessage()
  • func (x *RegisterRequest) ProtoReflect() protoreflect.Message
  • func (x *RegisterRequest) Reset()
  • func (x *RegisterRequest) String() string
• type UnimplementedExchangeServiceServer
  • func (UnimplementedExchangeServiceServer) RegisterService(*RegisterRequest, grpc.ServerStreamingServer[ConnectCommand]) error
• type UnsafeExchangeServiceServer

Constants

const (
	ExchangeService_RegisterService_FullMethodName = "/api.ExchangeService/RegisterService"
)

Variables

var ExchangeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.ExchangeService",
	HandlerType: (*ExchangeServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "RegisterService",
			Handler:       _ExchangeService_RegisterService_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "exchange.proto",
}

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

var File_exchange_proto protoreflect.FileDescriptor

Functions

func RegisterExchangeServiceServer

func RegisterExchangeServiceServer(s grpc.ServiceRegistrar, srv ExchangeServiceServer)

Types

type ConnectCommand

type ConnectCommand struct {
	NameSpace   string `protobuf:"bytes,1,opt,name=name_space,json=nameSpace,proto3" json:"name_space,omitempty"`
	ServiceName string `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	Id          uint64 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectCommand) Descriptor

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

Deprecated: Use ConnectCommand.ProtoReflect.Descriptor instead.

func (*ConnectCommand) GetId

func (x *ConnectCommand) GetId() uint64

func (*ConnectCommand) GetNameSpace

func (x *ConnectCommand) GetNameSpace() string

func (*ConnectCommand) GetServiceName

func (x *ConnectCommand) GetServiceName() string

func (*ConnectCommand) ProtoMessage

func (*ConnectCommand) ProtoMessage()

func (*ConnectCommand) ProtoReflect

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

func (*ConnectCommand) Reset

func (x *ConnectCommand) Reset()

func (*ConnectCommand) String

func (x *ConnectCommand) String() string

type ExchangeServiceClient

type ExchangeServiceClient interface {
	RegisterService(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ConnectCommand], error)
}

ExchangeServiceClient is the client API for ExchangeService 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 NewExchangeServiceClient

func NewExchangeServiceClient(cc grpc.ClientConnInterface) ExchangeServiceClient

type ExchangeServiceServer

type ExchangeServiceServer interface {
	RegisterService(*RegisterRequest, grpc.ServerStreamingServer[ConnectCommand]) error
	// contains filtered or unexported methods
}

ExchangeServiceServer is the server API for ExchangeService service. All implementations must embed UnimplementedExchangeServiceServer for forward compatibility.

type ExchangeService_RegisterServiceClient

type ExchangeService_RegisterServiceClient = grpc.ServerStreamingClient[ConnectCommand]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ExchangeService_RegisterServiceServer

type ExchangeService_RegisterServiceServer = grpc.ServerStreamingServer[ConnectCommand]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type RegisterRequest

type RegisterRequest struct {
	NameSpace   string   `protobuf:"bytes,1,opt,name=name_space,json=nameSpace,proto3" json:"name_space,omitempty"`
	ServiceName []string `protobuf:"bytes,2,rep,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterRequest) Descriptor

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

Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.

func (*RegisterRequest) GetNameSpace

func (x *RegisterRequest) GetNameSpace() string

func (*RegisterRequest) GetServiceName

func (x *RegisterRequest) GetServiceName() []string

func (*RegisterRequest) ProtoMessage

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) ProtoReflect

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

func (*RegisterRequest) Reset

func (x *RegisterRequest) Reset()

func (*RegisterRequest) String

func (x *RegisterRequest) String() string

type UnimplementedExchangeServiceServer

type UnimplementedExchangeServiceServer struct{}

UnimplementedExchangeServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedExchangeServiceServer) RegisterService

func (UnimplementedExchangeServiceServer) RegisterService(*RegisterRequest, grpc.ServerStreamingServer[ConnectCommand]) error

type UnsafeExchangeServiceServer

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

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