msgclient

package
v0.0.0-...-2119b44 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 17, 2024 License: MPL-2.0 Imports: 13 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	REGISTRAION_STATUS_name = map[int32]string{
		0: "REGISTERED",
		1: "NOT_REGISTERED",
	}
	REGISTRAION_STATUS_value = map[string]int32{
		"REGISTERED":     0,
		"NOT_REGISTERED": 1,
	}
)

Enum value maps for REGISTRAION_STATUS.

View Source 
var File_msgclient_msgClient_proto protoreflect.FileDescriptor
View Source 
var MsgClientService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ukama.msgClient.v1.MsgClientService",
	HandlerType: (*MsgClientServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterService",
			Handler:    _MsgClientService_RegisterService_Handler,
		},
		{
			MethodName: "StartMsgBusHandler",
			Handler:    _MsgClientService_StartMsgBusHandler_Handler,
		},
		{
			MethodName: "StopMsgBusHandler",
			Handler:    _MsgClientService_StopMsgBusHandler_Handler,
		},
		{
			MethodName: "UnregisterService",
			Handler:    _MsgClientService_UnregisterService_Handler,
		},
		{
			MethodName: "PublishMsg",
			Handler:    _MsgClientService_PublishMsg_Handler,
		},
		{
			MethodName: "CreateShovel",
			Handler:    _MsgClientService_CreateShovel_Handler,
		},
		{
			MethodName: "RemoveShovel",
			Handler:    _MsgClientService_RemoveShovel_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "msgclient/msgClient.proto",
}

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

Functions

func RegisterMsgClientServiceServer 

func RegisterMsgClientServiceServer(s grpc.ServiceRegistrar, srv MsgClientServiceServer)

Types

type CreateShovelRequest 

type CreateShovelRequest struct {
	SrcProtocol     string `protobuf:"bytes,1,opt,name=srcProtocol,proto3" json:"srcProtocol,omitempty"`
	DestProtocol    string `protobuf:"bytes,2,opt,name=destProtocol,proto3" json:"destProtocol,omitempty"`
	SrcExchange     string `protobuf:"bytes,3,opt,name=srcExchange,proto3" json:"srcExchange,omitempty"`
	DestExchange    string `protobuf:"bytes,4,opt,name=destExchange,proto3" json:"destExchange,omitempty"`
	SrcExchangeKey  string `protobuf:"bytes,5,opt,name=srcExchangeKey,proto3" json:"srcExchangeKey,omitempty"`
	DestExchangeKey string `protobuf:"bytes,6,opt,name=destExchangeKey,proto3" json:"destExchangeKey,omitempty"`
	SrcQueue        string `protobuf:"bytes,7,opt,name=srcQueue,proto3" json:"srcQueue,omitempty"`
	DestQueue       string `protobuf:"bytes,8,opt,name=destQueue,proto3" json:"destQueue,omitempty"`
	SrcUri          string `protobuf:"bytes,9,opt,name=srcUri,proto3" json:"srcUri,omitempty"`
	DestUri         string `protobuf:"bytes,10,opt,name=destUri,proto3" json:"destUri,omitempty"`
	Name            string `protobuf:"bytes,11,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateShovelRequest) Descriptor deprecated 

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

Deprecated: Use CreateShovelRequest.ProtoReflect.Descriptor instead.

func (*CreateShovelRequest) GetDestExchange 

func (x *CreateShovelRequest) GetDestExchange() string

func (*CreateShovelRequest) GetDestExchangeKey 

func (x *CreateShovelRequest) GetDestExchangeKey() string

func (*CreateShovelRequest) GetDestProtocol 

func (x *CreateShovelRequest) GetDestProtocol() string

func (*CreateShovelRequest) GetDestQueue 

func (x *CreateShovelRequest) GetDestQueue() string

func (*CreateShovelRequest) GetDestUri 

func (x *CreateShovelRequest) GetDestUri() string

func (*CreateShovelRequest) GetName 

func (x *CreateShovelRequest) GetName() string

func (*CreateShovelRequest) GetSrcExchange 

func (x *CreateShovelRequest) GetSrcExchange() string

func (*CreateShovelRequest) GetSrcExchangeKey 

func (x *CreateShovelRequest) GetSrcExchangeKey() string

func (*CreateShovelRequest) GetSrcProtocol 

func (x *CreateShovelRequest) GetSrcProtocol() string

func (*CreateShovelRequest) GetSrcQueue 

func (x *CreateShovelRequest) GetSrcQueue() string

func (*CreateShovelRequest) GetSrcUri 

func (x *CreateShovelRequest) GetSrcUri() string

func (*CreateShovelRequest) ProtoMessage 

func (*CreateShovelRequest) ProtoMessage()

func (*CreateShovelRequest) ProtoReflect 

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

func (*CreateShovelRequest) Reset 

func (x *CreateShovelRequest) Reset()

func (*CreateShovelRequest) String 

func (x *CreateShovelRequest) String() string

func (*CreateShovelRequest) Validate 

func (this *CreateShovelRequest) Validate() error

type CreateShovelResponse 

type CreateShovelResponse struct {
	// contains filtered or unexported fields
}

func (*CreateShovelResponse) Descriptor deprecated 

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

Deprecated: Use CreateShovelResponse.ProtoReflect.Descriptor instead.

func (*CreateShovelResponse) ProtoMessage 

func (*CreateShovelResponse) ProtoMessage()

func (*CreateShovelResponse) ProtoReflect 

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

func (*CreateShovelResponse) Reset 

func (x *CreateShovelResponse) Reset()

func (*CreateShovelResponse) String 

func (x *CreateShovelResponse) String() string

func (*CreateShovelResponse) Validate 

func (this *CreateShovelResponse) Validate() error

type MsgClientServiceClient 

type MsgClientServiceClient interface {
	// / Use this rpc to register system to MsgClient
	RegisterService(ctx context.Context, in *RegisterServiceReq, opts ...grpc.CallOption) (*RegisterServiceResp, error)
	// / Call this rpc to  StartMsgBus after registration
	StartMsgBusHandler(ctx context.Context, in *StartMsgBusHandlerReq, opts ...grpc.CallOption) (*StartMsgBusHandlerResp, error)
	// / Call this rpc to  StopMsgBus
	StopMsgBusHandler(ctx context.Context, in *StopMsgBusHandlerReq, opts ...grpc.CallOption) (*StopMsgBusHandlerResp, error)
	// / Unregister service from MsgClient
	UnregisterService(ctx context.Context, in *UnregisterServiceReq, opts ...grpc.CallOption) (*UnregisterServiceResp, error)
	// / Call this rpc to publisg events
	PublishMsg(ctx context.Context, in *PublishMsgRequest, opts ...grpc.CallOption) (*PublishMsgResponse, error)
	// / Create a shovel
	CreateShovel(ctx context.Context, in *CreateShovelRequest, opts ...grpc.CallOption) (*CreateShovelResponse, error)
	// / Remove shovel
	RemoveShovel(ctx context.Context, in *RemoveShovelRequest, opts ...grpc.CallOption) (*RemoveShovelResponse, error)
}

MsgClientServiceClient is the client API for MsgClientService 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 NewMsgClientServiceClient 

func NewMsgClientServiceClient(cc grpc.ClientConnInterface) MsgClientServiceClient

type MsgClientServiceServer 

type MsgClientServiceServer interface {
	// / Use this rpc to register system to MsgClient
	RegisterService(context.Context, *RegisterServiceReq) (*RegisterServiceResp, error)
	// / Call this rpc to  StartMsgBus after registration
	StartMsgBusHandler(context.Context, *StartMsgBusHandlerReq) (*StartMsgBusHandlerResp, error)
	// / Call this rpc to  StopMsgBus
	StopMsgBusHandler(context.Context, *StopMsgBusHandlerReq) (*StopMsgBusHandlerResp, error)
	// / Unregister service from MsgClient
	UnregisterService(context.Context, *UnregisterServiceReq) (*UnregisterServiceResp, error)
	// / Call this rpc to publisg events
	PublishMsg(context.Context, *PublishMsgRequest) (*PublishMsgResponse, error)
	// / Create a shovel
	CreateShovel(context.Context, *CreateShovelRequest) (*CreateShovelResponse, error)
	// / Remove shovel
	RemoveShovel(context.Context, *RemoveShovelRequest) (*RemoveShovelResponse, error)
	// contains filtered or unexported methods
}

MsgClientServiceServer is the server API for MsgClientService service. All implementations must embed UnimplementedMsgClientServiceServer for forward compatibility

type PublishMsgRequest 

type PublishMsgRequest struct {
	ServiceUuid string     `protobuf:"bytes,1,opt,name=serviceUuid,proto3" json:"serviceUuid,omitempty"` /// Uuid of service
	RoutingKey  string     `protobuf:"bytes,2,opt,name=routingKey,proto3" json:"routingKey,omitempty"`   /// Unique routing key
	Msg         *anypb.Any `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`                 /// Msg proto
	// contains filtered or unexported fields
}

func (*PublishMsgRequest) Descriptor deprecated 

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

Deprecated: Use PublishMsgRequest.ProtoReflect.Descriptor instead.

func (*PublishMsgRequest) GetMsg 

func (x *PublishMsgRequest) GetMsg() *anypb.Any

func (*PublishMsgRequest) GetRoutingKey 

func (x *PublishMsgRequest) GetRoutingKey() string

func (*PublishMsgRequest) GetServiceUuid 

func (x *PublishMsgRequest) GetServiceUuid() string

func (*PublishMsgRequest) ProtoMessage 

func (*PublishMsgRequest) ProtoMessage()

func (*PublishMsgRequest) ProtoReflect 

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

func (*PublishMsgRequest) Reset 

func (x *PublishMsgRequest) Reset()

func (*PublishMsgRequest) String 

func (x *PublishMsgRequest) String() string

func (*PublishMsgRequest) Validate 

func (this *PublishMsgRequest) Validate() error

type PublishMsgResponse 

type PublishMsgResponse struct {
	// contains filtered or unexported fields
}

func (*PublishMsgResponse) Descriptor deprecated 

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

Deprecated: Use PublishMsgResponse.ProtoReflect.Descriptor instead.

func (*PublishMsgResponse) ProtoMessage 

func (*PublishMsgResponse) ProtoMessage()

func (*PublishMsgResponse) ProtoReflect 

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

func (*PublishMsgResponse) Reset 

func (x *PublishMsgResponse) Reset()

func (*PublishMsgResponse) String 

func (x *PublishMsgResponse) String() string

func (*PublishMsgResponse) Validate 

func (this *PublishMsgResponse) Validate() error

type REGISTRAION_STATUS 

type REGISTRAION_STATUS int32

/ Registration status enums 

const (
	REGISTRAION_STATUS_REGISTERED     REGISTRAION_STATUS = 0 /// System registered status
	REGISTRAION_STATUS_NOT_REGISTERED REGISTRAION_STATUS = 1 /// System not registered status
)

func (REGISTRAION_STATUS) Descriptor 

func (REGISTRAION_STATUS) Descriptor() protoreflect.EnumDescriptor

func (REGISTRAION_STATUS) Enum 

func (x REGISTRAION_STATUS) Enum() *REGISTRAION_STATUS

func (REGISTRAION_STATUS) EnumDescriptor deprecated 

func (REGISTRAION_STATUS) EnumDescriptor() ([]byte, []int)

Deprecated: Use REGISTRAION_STATUS.Descriptor instead.

func (REGISTRAION_STATUS) Number 

func (x REGISTRAION_STATUS) Number() protoreflect.EnumNumber

func (REGISTRAION_STATUS) String 

func (x REGISTRAION_STATUS) String() string

func (REGISTRAION_STATUS) Type 

func (REGISTRAION_STATUS) Type() protoreflect.EnumType

type RegisterServiceReq 

type RegisterServiceReq struct {
	SystemName  string   `protobuf:"bytes,1,opt,name=systemName,proto3" json:"systemName,omitempty"`
	ServiceName string   `protobuf:"bytes,2,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
	InstanceId  string   `protobuf:"bytes,3,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	MsgBusURI   string   `protobuf:"bytes,4,opt,name=msgBusURI,proto3" json:"msgBusURI,omitempty"`
	ServiceURI  string   `protobuf:"bytes,5,opt,name=serviceURI,proto3" json:"serviceURI,omitempty"`
	ListQueue   string   `protobuf:"bytes,6,opt,name=listQueue,proto3" json:"listQueue,omitempty"`
	PublQueue   string   `protobuf:"bytes,7,opt,name=publQueue,proto3" json:"publQueue,omitempty"`
	Exchange    string   `protobuf:"bytes,8,opt,name=exchange,proto3" json:"exchange,omitempty"`
	GrpcTimeout uint32   `protobuf:"varint,9,opt,name=grpcTimeout,proto3" json:"grpcTimeout,omitempty"`
	Routes      []string `protobuf:"bytes,10,rep,name=routes,proto3" json:"routes,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterServiceReq) Descriptor deprecated 

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

Deprecated: Use RegisterServiceReq.ProtoReflect.Descriptor instead.

func (*RegisterServiceReq) GetExchange 

func (x *RegisterServiceReq) GetExchange() string

func (*RegisterServiceReq) GetGrpcTimeout 

func (x *RegisterServiceReq) GetGrpcTimeout() uint32

func (*RegisterServiceReq) GetInstanceId 

func (x *RegisterServiceReq) GetInstanceId() string

func (*RegisterServiceReq) GetListQueue 

func (x *RegisterServiceReq) GetListQueue() string

func (*RegisterServiceReq) GetMsgBusURI 

func (x *RegisterServiceReq) GetMsgBusURI() string

func (*RegisterServiceReq) GetPublQueue 

func (x *RegisterServiceReq) GetPublQueue() string

func (*RegisterServiceReq) GetRoutes 

func (x *RegisterServiceReq) GetRoutes() []string

func (*RegisterServiceReq) GetServiceName 

func (x *RegisterServiceReq) GetServiceName() string

func (*RegisterServiceReq) GetServiceURI 

func (x *RegisterServiceReq) GetServiceURI() string

func (*RegisterServiceReq) GetSystemName 

func (x *RegisterServiceReq) GetSystemName() string

func (*RegisterServiceReq) ProtoMessage 

func (*RegisterServiceReq) ProtoMessage()

func (*RegisterServiceReq) ProtoReflect 

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

func (*RegisterServiceReq) Reset 

func (x *RegisterServiceReq) Reset()

func (*RegisterServiceReq) String 

func (x *RegisterServiceReq) String() string

func (*RegisterServiceReq) Validate 

func (this *RegisterServiceReq) Validate() error

type RegisterServiceResp 

type RegisterServiceResp struct {
	State       REGISTRAION_STATUS `protobuf:"varint,1,opt,name=state,proto3,enum=ukama.msgClient.v1.REGISTRAION_STATUS" json:"state,omitempty"`
	ServiceUuid string             `protobuf:"bytes,2,opt,name=serviceUuid,proto3" json:"serviceUuid,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterServiceResp) Descriptor deprecated 

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

Deprecated: Use RegisterServiceResp.ProtoReflect.Descriptor instead.

func (*RegisterServiceResp) GetServiceUuid 

func (x *RegisterServiceResp) GetServiceUuid() string

func (*RegisterServiceResp) GetState 

func (x *RegisterServiceResp) GetState() REGISTRAION_STATUS

func (*RegisterServiceResp) ProtoMessage 

func (*RegisterServiceResp) ProtoMessage()

func (*RegisterServiceResp) ProtoReflect 

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

func (*RegisterServiceResp) Reset 

func (x *RegisterServiceResp) Reset()

func (*RegisterServiceResp) String 

func (x *RegisterServiceResp) String() string

func (*RegisterServiceResp) Validate 

func (this *RegisterServiceResp) Validate() error

type RemoveShovelRequest 

type RemoveShovelRequest struct {
	Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveShovelRequest) Descriptor deprecated 

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

Deprecated: Use RemoveShovelRequest.ProtoReflect.Descriptor instead.

func (*RemoveShovelRequest) GetName 

func (x *RemoveShovelRequest) GetName() string

func (*RemoveShovelRequest) ProtoMessage 

func (*RemoveShovelRequest) ProtoMessage()

func (*RemoveShovelRequest) ProtoReflect 

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

func (*RemoveShovelRequest) Reset 

func (x *RemoveShovelRequest) Reset()

func (*RemoveShovelRequest) String 

func (x *RemoveShovelRequest) String() string

func (*RemoveShovelRequest) Validate 

func (this *RemoveShovelRequest) Validate() error

type RemoveShovelResponse 

type RemoveShovelResponse struct {
	// contains filtered or unexported fields
}

func (*RemoveShovelResponse) Descriptor deprecated 

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

Deprecated: Use RemoveShovelResponse.ProtoReflect.Descriptor instead.

func (*RemoveShovelResponse) ProtoMessage 

func (*RemoveShovelResponse) ProtoMessage()

func (*RemoveShovelResponse) ProtoReflect 

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

func (*RemoveShovelResponse) Reset 

func (x *RemoveShovelResponse) Reset()

func (*RemoveShovelResponse) String 

func (x *RemoveShovelResponse) String() string

func (*RemoveShovelResponse) Validate 

func (this *RemoveShovelResponse) Validate() error

type StartMsgBusHandlerReq 

type StartMsgBusHandlerReq struct {
	ServiceUuid string `protobuf:"bytes,1,opt,name=serviceUuid,proto3" json:"serviceUuid,omitempty"` /// Uuid of service to start
	// contains filtered or unexported fields
}

func (*StartMsgBusHandlerReq) Descriptor deprecated 

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

Deprecated: Use StartMsgBusHandlerReq.ProtoReflect.Descriptor instead.

func (*StartMsgBusHandlerReq) GetServiceUuid 

func (x *StartMsgBusHandlerReq) GetServiceUuid() string

func (*StartMsgBusHandlerReq) ProtoMessage 

func (*StartMsgBusHandlerReq) ProtoMessage()

func (*StartMsgBusHandlerReq) ProtoReflect 

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

func (*StartMsgBusHandlerReq) Reset 

func (x *StartMsgBusHandlerReq) Reset()

func (*StartMsgBusHandlerReq) String 

func (x *StartMsgBusHandlerReq) String() string

func (*StartMsgBusHandlerReq) Validate 

func (this *StartMsgBusHandlerReq) Validate() error

type StartMsgBusHandlerResp 

type StartMsgBusHandlerResp struct {
	// contains filtered or unexported fields
}

func (*StartMsgBusHandlerResp) Descriptor deprecated 

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

Deprecated: Use StartMsgBusHandlerResp.ProtoReflect.Descriptor instead.

func (*StartMsgBusHandlerResp) ProtoMessage 

func (*StartMsgBusHandlerResp) ProtoMessage()

func (*StartMsgBusHandlerResp) ProtoReflect 

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

func (*StartMsgBusHandlerResp) Reset 

func (x *StartMsgBusHandlerResp) Reset()

func (*StartMsgBusHandlerResp) String 

func (x *StartMsgBusHandlerResp) String() string

func (*StartMsgBusHandlerResp) Validate 

func (this *StartMsgBusHandlerResp) Validate() error

type StopMsgBusHandlerReq 

type StopMsgBusHandlerReq struct {
	ServiceUuid string `protobuf:"bytes,1,opt,name=serviceUuid,proto3" json:"serviceUuid,omitempty"` /// Uuid of service to stop
	// contains filtered or unexported fields
}

func (*StopMsgBusHandlerReq) Descriptor deprecated 

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

Deprecated: Use StopMsgBusHandlerReq.ProtoReflect.Descriptor instead.

func (*StopMsgBusHandlerReq) GetServiceUuid 

func (x *StopMsgBusHandlerReq) GetServiceUuid() string

func (*StopMsgBusHandlerReq) ProtoMessage 

func (*StopMsgBusHandlerReq) ProtoMessage()

func (*StopMsgBusHandlerReq) ProtoReflect 

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

func (*StopMsgBusHandlerReq) Reset 

func (x *StopMsgBusHandlerReq) Reset()

func (*StopMsgBusHandlerReq) String 

func (x *StopMsgBusHandlerReq) String() string

func (*StopMsgBusHandlerReq) Validate 

func (this *StopMsgBusHandlerReq) Validate() error

type StopMsgBusHandlerResp 

type StopMsgBusHandlerResp struct {
	// contains filtered or unexported fields
}

func (*StopMsgBusHandlerResp) Descriptor deprecated 

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

Deprecated: Use StopMsgBusHandlerResp.ProtoReflect.Descriptor instead.

func (*StopMsgBusHandlerResp) ProtoMessage 

func (*StopMsgBusHandlerResp) ProtoMessage()

func (*StopMsgBusHandlerResp) ProtoReflect 

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

func (*StopMsgBusHandlerResp) Reset 

func (x *StopMsgBusHandlerResp) Reset()

func (*StopMsgBusHandlerResp) String 

func (x *StopMsgBusHandlerResp) String() string

func (*StopMsgBusHandlerResp) Validate 

func (this *StopMsgBusHandlerResp) Validate() error

type UnimplementedMsgClientServiceServer 

type UnimplementedMsgClientServiceServer struct {
}

UnimplementedMsgClientServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMsgClientServiceServer) CreateShovel 

func (UnimplementedMsgClientServiceServer) CreateShovel(context.Context, *CreateShovelRequest) (*CreateShovelResponse, error)

func (UnimplementedMsgClientServiceServer) PublishMsg 

func (UnimplementedMsgClientServiceServer) PublishMsg(context.Context, *PublishMsgRequest) (*PublishMsgResponse, error)

func (UnimplementedMsgClientServiceServer) RegisterService 

func (UnimplementedMsgClientServiceServer) RegisterService(context.Context, *RegisterServiceReq) (*RegisterServiceResp, error)

func (UnimplementedMsgClientServiceServer) RemoveShovel 

func (UnimplementedMsgClientServiceServer) RemoveShovel(context.Context, *RemoveShovelRequest) (*RemoveShovelResponse, error)

func (UnimplementedMsgClientServiceServer) StartMsgBusHandler 

func (UnimplementedMsgClientServiceServer) StartMsgBusHandler(context.Context, *StartMsgBusHandlerReq) (*StartMsgBusHandlerResp, error)

func (UnimplementedMsgClientServiceServer) StopMsgBusHandler 

func (UnimplementedMsgClientServiceServer) StopMsgBusHandler(context.Context, *StopMsgBusHandlerReq) (*StopMsgBusHandlerResp, error)

func (UnimplementedMsgClientServiceServer) UnregisterService 

func (UnimplementedMsgClientServiceServer) UnregisterService(context.Context, *UnregisterServiceReq) (*UnregisterServiceResp, error)

type UnregisterServiceReq 

type UnregisterServiceReq struct {
	ServiceUuid string `protobuf:"bytes,1,opt,name=serviceUuid,proto3" json:"serviceUuid,omitempty"` /// Uuid of service to unregister
	// contains filtered or unexported fields
}

func (*UnregisterServiceReq) Descriptor deprecated 

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

Deprecated: Use UnregisterServiceReq.ProtoReflect.Descriptor instead.

func (*UnregisterServiceReq) GetServiceUuid 

func (x *UnregisterServiceReq) GetServiceUuid() string

func (*UnregisterServiceReq) ProtoMessage 

func (*UnregisterServiceReq) ProtoMessage()

func (*UnregisterServiceReq) ProtoReflect 

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

func (*UnregisterServiceReq) Reset 

func (x *UnregisterServiceReq) Reset()

func (*UnregisterServiceReq) String 

func (x *UnregisterServiceReq) String() string

func (*UnregisterServiceReq) Validate 

func (this *UnregisterServiceReq) Validate() error

type UnregisterServiceResp 

type UnregisterServiceResp struct {
	// contains filtered or unexported fields
}

func (*UnregisterServiceResp) Descriptor deprecated 

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

Deprecated: Use UnregisterServiceResp.ProtoReflect.Descriptor instead.

func (*UnregisterServiceResp) ProtoMessage 

func (*UnregisterServiceResp) ProtoMessage()

func (*UnregisterServiceResp) ProtoReflect 

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

func (*UnregisterServiceResp) Reset 

func (x *UnregisterServiceResp) Reset()

func (*UnregisterServiceResp) String 

func (x *UnregisterServiceResp) String() string

func (*UnregisterServiceResp) Validate 

func (this *UnregisterServiceResp) Validate() error

type UnsafeMsgClientServiceServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.