messages

package
v1.1.1 Latest Latest
Warning

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

 Go to latest Published: Oct 24, 2024 License: AGPL-3.0 Imports: 8 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	MessageDispatchService_ValidateAccessToken_FullMethodName             = "/MessageDispatchService/ValidateAccessToken"
	MessageDispatchService_GetAccessToken_FullMethodName                  = "/MessageDispatchService/GetAccessToken"
	MessageDispatchService_SendActions_FullMethodName                     = "/MessageDispatchService/SendActions"
	MessageDispatchService_SendClusterGatewayResource_FullMethodName      = "/MessageDispatchService/SendClusterGatewayResource"
	MessageDispatchService_ReceiveError_FullMethodName                    = "/MessageDispatchService/ReceiveError"
	MessageDispatchService_ReceiveConsoleResourceUpdate_FullMethodName    = "/MessageDispatchService/ReceiveConsoleResourceUpdate"
	MessageDispatchService_ReceiveIotConsoleResourceUpdate_FullMethodName = "/MessageDispatchService/ReceiveIotConsoleResourceUpdate"
	MessageDispatchService_ReceiveInfraResourceUpdate_FullMethodName      = "/MessageDispatchService/ReceiveInfraResourceUpdate"
	MessageDispatchService_ReceiveContainerRegistryUpdate_FullMethodName  = "/MessageDispatchService/ReceiveContainerRegistryUpdate"
	MessageDispatchService_Ping_FullMethodName                            = "/MessageDispatchService/Ping"
)

Variables

View Source 
var File_messages_proto protoreflect.FileDescriptor
View Source 
var MessageDispatchService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "MessageDispatchService",
	HandlerType: (*MessageDispatchServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ValidateAccessToken",
			Handler:    _MessageDispatchService_ValidateAccessToken_Handler,
		},
		{
			MethodName: "GetAccessToken",
			Handler:    _MessageDispatchService_GetAccessToken_Handler,
		},
		{
			MethodName: "SendClusterGatewayResource",
			Handler:    _MessageDispatchService_SendClusterGatewayResource_Handler,
		},
		{
			MethodName: "ReceiveError",
			Handler:    _MessageDispatchService_ReceiveError_Handler,
		},
		{
			MethodName: "ReceiveConsoleResourceUpdate",
			Handler:    _MessageDispatchService_ReceiveConsoleResourceUpdate_Handler,
		},
		{
			MethodName: "ReceiveIotConsoleResourceUpdate",
			Handler:    _MessageDispatchService_ReceiveIotConsoleResourceUpdate_Handler,
		},
		{
			MethodName: "ReceiveInfraResourceUpdate",
			Handler:    _MessageDispatchService_ReceiveInfraResourceUpdate_Handler,
		},
		{
			MethodName: "ReceiveContainerRegistryUpdate",
			Handler:    _MessageDispatchService_ReceiveContainerRegistryUpdate_Handler,
		},
		{
			MethodName: "Ping",
			Handler:    _MessageDispatchService_Ping_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SendActions",
			Handler:       _MessageDispatchService_SendActions_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "messages.proto",
}

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

Functions

func RegisterMessageDispatchServiceServer 

func RegisterMessageDispatchServiceServer(s grpc.ServiceRegistrar, srv MessageDispatchServiceServer)

Types

type Action 

type Action struct {
	ProtocolVersion string `protobuf:"bytes,1,opt,name=protocolVersion,proto3" json:"protocolVersion,omitempty"`
	Message         []byte `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Action) Descriptor deprecated 

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

Deprecated: Use Action.ProtoReflect.Descriptor instead.

func (*Action) GetMessage 

func (x *Action) GetMessage() []byte

func (*Action) GetProtocolVersion added in v1.1.0 

func (x *Action) GetProtocolVersion() string

func (*Action) ProtoMessage 

func (*Action) ProtoMessage()

func (*Action) ProtoReflect 

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

func (*Action) Reset 

func (x *Action) Reset()

func (*Action) String 

func (x *Action) String() string

type Empty 

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

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type ErrorData 

type ErrorData struct {
	ProtocolVersion string `protobuf:"bytes,1,opt,name=protocolVersion,proto3" json:"protocolVersion,omitempty"`
	Message         []byte `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Gvk             string `protobuf:"bytes,3,opt,name=gvk,proto3" json:"gvk,omitempty"`
	Namespace       string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name            string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*ErrorData) Descriptor deprecated 

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

Deprecated: Use ErrorData.ProtoReflect.Descriptor instead.

func (*ErrorData) GetGvk added in v1.1.0 

func (x *ErrorData) GetGvk() string

func (*ErrorData) GetMessage 

func (x *ErrorData) GetMessage() []byte

func (*ErrorData) GetName added in v1.1.0 

func (x *ErrorData) GetName() string

func (*ErrorData) GetNamespace added in v1.1.0 

func (x *ErrorData) GetNamespace() string

func (*ErrorData) GetProtocolVersion added in v1.1.0 

func (x *ErrorData) GetProtocolVersion() string

func (*ErrorData) ProtoMessage 

func (*ErrorData) ProtoMessage()

func (*ErrorData) ProtoReflect 

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

func (*ErrorData) Reset 

func (x *ErrorData) Reset()

func (*ErrorData) String 

func (x *ErrorData) String() string

type GatewayResource added in v1.1.1 

type GatewayResource struct {
	Gateway []byte `protobuf:"bytes,1,opt,name=gateway,proto3" json:"gateway,omitempty"`
	// contains filtered or unexported fields
}

func (*GatewayResource) Descriptor deprecated added in v1.1.1 

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

Deprecated: Use GatewayResource.ProtoReflect.Descriptor instead.

func (*GatewayResource) GetGateway added in v1.1.1 

func (x *GatewayResource) GetGateway() []byte

func (*GatewayResource) ProtoMessage added in v1.1.1 

func (*GatewayResource) ProtoMessage()

func (*GatewayResource) ProtoReflect added in v1.1.1 

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

func (*GatewayResource) Reset added in v1.1.1 

func (x *GatewayResource) Reset()

func (*GatewayResource) String added in v1.1.1 

func (x *GatewayResource) String() string

type GetAccessTokenIn added in v1.0.3 

type GetAccessTokenIn struct {
	ProtocolVersion string `protobuf:"bytes,1,opt,name=protocolVersion,proto3" json:"protocolVersion,omitempty"`
	ClusterToken    string `protobuf:"bytes,2,opt,name=clusterToken,proto3" json:"clusterToken,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAccessTokenIn) Descriptor deprecated added in v1.0.3 

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

Deprecated: Use GetAccessTokenIn.ProtoReflect.Descriptor instead.

func (*GetAccessTokenIn) GetClusterToken added in v1.0.3 

func (x *GetAccessTokenIn) GetClusterToken() string

func (*GetAccessTokenIn) GetProtocolVersion added in v1.1.0 

func (x *GetAccessTokenIn) GetProtocolVersion() string

func (*GetAccessTokenIn) ProtoMessage added in v1.0.3 

func (*GetAccessTokenIn) ProtoMessage()

func (*GetAccessTokenIn) ProtoReflect added in v1.0.3 

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

func (*GetAccessTokenIn) Reset added in v1.0.3 

func (x *GetAccessTokenIn) Reset()

func (*GetAccessTokenIn) String added in v1.0.3 

func (x *GetAccessTokenIn) String() string

type GetAccessTokenOut added in v1.0.3 

type GetAccessTokenOut struct {
	ProtocolVersion string `protobuf:"bytes,1,opt,name=protocolVersion,proto3" json:"protocolVersion,omitempty"`
	AccountName     string `protobuf:"bytes,2,opt,name=accountName,proto3" json:"accountName,omitempty"`
	ClusterName     string `protobuf:"bytes,3,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	AccessToken     string `protobuf:"bytes,4,opt,name=accessToken,proto3" json:"accessToken,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAccessTokenOut) Descriptor deprecated added in v1.0.3 

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

Deprecated: Use GetAccessTokenOut.ProtoReflect.Descriptor instead.

func (*GetAccessTokenOut) GetAccessToken added in v1.0.3 

func (x *GetAccessTokenOut) GetAccessToken() string

func (*GetAccessTokenOut) GetAccountName added in v1.1.0 

func (x *GetAccessTokenOut) GetAccountName() string

func (*GetAccessTokenOut) GetClusterName added in v1.1.0 

func (x *GetAccessTokenOut) GetClusterName() string

func (*GetAccessTokenOut) GetProtocolVersion added in v1.1.0 

func (x *GetAccessTokenOut) GetProtocolVersion() string

func (*GetAccessTokenOut) ProtoMessage added in v1.0.3 

func (*GetAccessTokenOut) ProtoMessage()

func (*GetAccessTokenOut) ProtoReflect added in v1.0.3 

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

func (*GetAccessTokenOut) Reset added in v1.0.3 

func (x *GetAccessTokenOut) Reset()

func (*GetAccessTokenOut) String added in v1.0.3 

func (x *GetAccessTokenOut) String() string

type MessageDispatchServiceClient 

type MessageDispatchServiceClient interface {
	ValidateAccessToken(ctx context.Context, in *ValidateAccessTokenIn, opts ...grpc.CallOption) (*ValidateAccessTokenOut, error)
	GetAccessToken(ctx context.Context, in *GetAccessTokenIn, opts ...grpc.CallOption) (*GetAccessTokenOut, error)
	SendActions(ctx context.Context, in *Empty, opts ...grpc.CallOption) (MessageDispatchService_SendActionsClient, error)
	SendClusterGatewayResource(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GatewayResource, error)
	ReceiveError(ctx context.Context, in *ErrorData, opts ...grpc.CallOption) (*Empty, error)
	ReceiveConsoleResourceUpdate(ctx context.Context, in *ResourceUpdate, opts ...grpc.CallOption) (*Empty, error)
	ReceiveIotConsoleResourceUpdate(ctx context.Context, in *ResourceUpdate, opts ...grpc.CallOption) (*Empty, error)
	ReceiveInfraResourceUpdate(ctx context.Context, in *ResourceUpdate, opts ...grpc.CallOption) (*Empty, error)
	ReceiveContainerRegistryUpdate(ctx context.Context, in *ResourceUpdate, opts ...grpc.CallOption) (*Empty, error)
	Ping(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PingOutput, error)
}

MessageDispatchServiceClient is the client API for MessageDispatchService 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 NewMessageDispatchServiceClient 

func NewMessageDispatchServiceClient(cc grpc.ClientConnInterface) MessageDispatchServiceClient

type MessageDispatchServiceServer 

type MessageDispatchServiceServer interface {
	ValidateAccessToken(context.Context, *ValidateAccessTokenIn) (*ValidateAccessTokenOut, error)
	GetAccessToken(context.Context, *GetAccessTokenIn) (*GetAccessTokenOut, error)
	SendActions(*Empty, MessageDispatchService_SendActionsServer) error
	SendClusterGatewayResource(context.Context, *Empty) (*GatewayResource, error)
	ReceiveError(context.Context, *ErrorData) (*Empty, error)
	ReceiveConsoleResourceUpdate(context.Context, *ResourceUpdate) (*Empty, error)
	ReceiveIotConsoleResourceUpdate(context.Context, *ResourceUpdate) (*Empty, error)
	ReceiveInfraResourceUpdate(context.Context, *ResourceUpdate) (*Empty, error)
	ReceiveContainerRegistryUpdate(context.Context, *ResourceUpdate) (*Empty, error)
	Ping(context.Context, *Empty) (*PingOutput, error)
	// contains filtered or unexported methods
}

MessageDispatchServiceServer is the server API for MessageDispatchService service. All implementations must embed UnimplementedMessageDispatchServiceServer for forward compatibility

type MessageDispatchService_SendActionsClient 

type MessageDispatchService_SendActionsClient interface {
	Recv() (*Action, error)
	grpc.ClientStream
}

type MessageDispatchService_SendActionsServer 

type MessageDispatchService_SendActionsServer interface {
	Send(*Action) error
	grpc.ServerStream
}

type PingOutput 

type PingOutput struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*PingOutput) Descriptor deprecated 

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

Deprecated: Use PingOutput.ProtoReflect.Descriptor instead.

func (*PingOutput) GetOk 

func (x *PingOutput) GetOk() bool

func (*PingOutput) ProtoMessage 

func (*PingOutput) ProtoMessage()

func (*PingOutput) ProtoReflect 

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

func (*PingOutput) Reset 

func (x *PingOutput) Reset()

func (*PingOutput) String 

func (x *PingOutput) String() string

type ResourceUpdate 

type ResourceUpdate struct {
	ProtocolVersion string `protobuf:"bytes,1,opt,name=protocolVersion,proto3" json:"protocolVersion,omitempty"`
	Message         []byte `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Gvk             string `protobuf:"bytes,3,opt,name=gvk,proto3" json:"gvk,omitempty"`
	Namespace       string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name            string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceUpdate) Descriptor deprecated 

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

Deprecated: Use ResourceUpdate.ProtoReflect.Descriptor instead.

func (*ResourceUpdate) GetGvk added in v1.1.0 

func (x *ResourceUpdate) GetGvk() string

func (*ResourceUpdate) GetMessage 

func (x *ResourceUpdate) GetMessage() []byte

func (*ResourceUpdate) GetName added in v1.1.0 

func (x *ResourceUpdate) GetName() string

func (*ResourceUpdate) GetNamespace added in v1.1.0 

func (x *ResourceUpdate) GetNamespace() string

func (*ResourceUpdate) GetProtocolVersion added in v1.1.0 

func (x *ResourceUpdate) GetProtocolVersion() string

func (*ResourceUpdate) ProtoMessage 

func (*ResourceUpdate) ProtoMessage()

func (*ResourceUpdate) ProtoReflect 

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

func (*ResourceUpdate) Reset 

func (x *ResourceUpdate) Reset()

func (*ResourceUpdate) String 

func (x *ResourceUpdate) String() string

type UnimplementedMessageDispatchServiceServer 

type UnimplementedMessageDispatchServiceServer struct {
}

UnimplementedMessageDispatchServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMessageDispatchServiceServer) GetAccessToken 

func (UnimplementedMessageDispatchServiceServer) GetAccessToken(context.Context, *GetAccessTokenIn) (*GetAccessTokenOut, error)

func (UnimplementedMessageDispatchServiceServer) Ping 

func (UnimplementedMessageDispatchServiceServer) Ping(context.Context, *Empty) (*PingOutput, error)

func (UnimplementedMessageDispatchServiceServer) ReceiveConsoleResourceUpdate 

func (UnimplementedMessageDispatchServiceServer) ReceiveConsoleResourceUpdate(context.Context, *ResourceUpdate) (*Empty, error)

func (UnimplementedMessageDispatchServiceServer) ReceiveContainerRegistryUpdate 

func (UnimplementedMessageDispatchServiceServer) ReceiveContainerRegistryUpdate(context.Context, *ResourceUpdate) (*Empty, error)

func (UnimplementedMessageDispatchServiceServer) ReceiveError 

func (UnimplementedMessageDispatchServiceServer) ReceiveError(context.Context, *ErrorData) (*Empty, error)

func (UnimplementedMessageDispatchServiceServer) ReceiveInfraResourceUpdate 

func (UnimplementedMessageDispatchServiceServer) ReceiveInfraResourceUpdate(context.Context, *ResourceUpdate) (*Empty, error)

func (UnimplementedMessageDispatchServiceServer) ReceiveIotConsoleResourceUpdate added in v1.1.0 

func (UnimplementedMessageDispatchServiceServer) ReceiveIotConsoleResourceUpdate(context.Context, *ResourceUpdate) (*Empty, error)

func (UnimplementedMessageDispatchServiceServer) SendActions 

func (UnimplementedMessageDispatchServiceServer) SendActions(*Empty, MessageDispatchService_SendActionsServer) error

func (UnimplementedMessageDispatchServiceServer) SendClusterGatewayResource added in v1.1.1 

func (UnimplementedMessageDispatchServiceServer) SendClusterGatewayResource(context.Context, *Empty) (*GatewayResource, error)

func (UnimplementedMessageDispatchServiceServer) ValidateAccessToken 

func (UnimplementedMessageDispatchServiceServer) ValidateAccessToken(context.Context, *ValidateAccessTokenIn) (*ValidateAccessTokenOut, error)

type UnsafeMessageDispatchServiceServer 

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

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

type ValidateAccessTokenIn 

type ValidateAccessTokenIn struct {
	ProtocolVersion string `protobuf:"bytes,1,opt,name=protocolVersion,proto3" json:"protocolVersion,omitempty"` // string accessToken = 2;
	// contains filtered or unexported fields
}

func (*ValidateAccessTokenIn) Descriptor deprecated 

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

Deprecated: Use ValidateAccessTokenIn.ProtoReflect.Descriptor instead.

func (*ValidateAccessTokenIn) GetProtocolVersion added in v1.1.0 

func (x *ValidateAccessTokenIn) GetProtocolVersion() string

func (*ValidateAccessTokenIn) ProtoMessage 

func (*ValidateAccessTokenIn) ProtoMessage()

func (*ValidateAccessTokenIn) ProtoReflect 

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

func (*ValidateAccessTokenIn) Reset 

func (x *ValidateAccessTokenIn) Reset()

func (*ValidateAccessTokenIn) String 

func (x *ValidateAccessTokenIn) String() string

type ValidateAccessTokenOut 

type ValidateAccessTokenOut struct {
	ProtocolVersion string `protobuf:"bytes,1,opt,name=protocolVersion,proto3" json:"protocolVersion,omitempty"`
	AccountName     string `protobuf:"bytes,2,opt,name=accountName,proto3" json:"accountName,omitempty"`
	ClusterName     string `protobuf:"bytes,3,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	Valid           bool   `protobuf:"varint,4,opt,name=valid,proto3" json:"valid,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateAccessTokenOut) Descriptor deprecated 

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

Deprecated: Use ValidateAccessTokenOut.ProtoReflect.Descriptor instead.

func (*ValidateAccessTokenOut) GetAccountName added in v1.1.0 

func (x *ValidateAccessTokenOut) GetAccountName() string

func (*ValidateAccessTokenOut) GetClusterName added in v1.1.0 

func (x *ValidateAccessTokenOut) GetClusterName() string

func (*ValidateAccessTokenOut) GetProtocolVersion added in v1.1.0 

func (x *ValidateAccessTokenOut) GetProtocolVersion() string

func (*ValidateAccessTokenOut) GetValid 

func (x *ValidateAccessTokenOut) GetValid() bool

func (*ValidateAccessTokenOut) ProtoMessage 

func (*ValidateAccessTokenOut) ProtoMessage()

func (*ValidateAccessTokenOut) ProtoReflect 

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

func (*ValidateAccessTokenOut) Reset 

func (x *ValidateAccessTokenOut) Reset()

func (*ValidateAccessTokenOut) String 

func (x *ValidateAccessTokenOut) String() string

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.