v2

package
v2.0.0-beta.12 Latest Latest
Warning

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

 Go to latest Published: Mar 15, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

Package v2 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	EventNotificationService_CreateStreamConsumer_FullMethodName    = "/aruna.api.notification.services.v2.EventNotificationService/CreateStreamConsumer"
	EventNotificationService_GetEventMessageBatch_FullMethodName    = "/aruna.api.notification.services.v2.EventNotificationService/GetEventMessageBatch"
	EventNotificationService_GetEventMessageStream_FullMethodName   = "/aruna.api.notification.services.v2.EventNotificationService/GetEventMessageStream"
	EventNotificationService_AcknowledgeMessageBatch_FullMethodName = "/aruna.api.notification.services.v2.EventNotificationService/AcknowledgeMessageBatch"
	EventNotificationService_DeleteStreamConsumer_FullMethodName    = "/aruna.api.notification.services.v2.EventNotificationService/DeleteStreamConsumer"
)

Variables

View Source 
var (
	EventVariant_name = map[int32]string{
		0: "EVENT_VARIANT_UNSPECIFIED",
		1: "EVENT_VARIANT_CREATED",
		2: "EVENT_VARIANT_AVAILABLE",
		3: "EVENT_VARIANT_UPDATED",
		4: "EVENT_VARIANT_DELETED",
		5: "EVENT_VARIANT_SNAPSHOTTED",
	}
	EventVariant_value = map[string]int32{
		"EVENT_VARIANT_UNSPECIFIED": 0,
		"EVENT_VARIANT_CREATED":     1,
		"EVENT_VARIANT_AVAILABLE":   2,
		"EVENT_VARIANT_UPDATED":     3,
		"EVENT_VARIANT_DELETED":     4,
		"EVENT_VARIANT_SNAPSHOTTED": 5,
	}
)

Enum value maps for EventVariant.

View Source 
var EventNotificationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "aruna.api.notification.services.v2.EventNotificationService",
	HandlerType: (*EventNotificationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateStreamConsumer",
			Handler:    _EventNotificationService_CreateStreamConsumer_Handler,
		},
		{
			MethodName: "GetEventMessageBatch",
			Handler:    _EventNotificationService_GetEventMessageBatch_Handler,
		},
		{
			MethodName: "AcknowledgeMessageBatch",
			Handler:    _EventNotificationService_AcknowledgeMessageBatch_Handler,
		},
		{
			MethodName: "DeleteStreamConsumer",
			Handler:    _EventNotificationService_DeleteStreamConsumer_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetEventMessageStream",
			Handler:       _EventNotificationService_GetEventMessageStream_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "aruna/api/notification/services/v2/notification_service.proto",
}

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

View Source 
var File_aruna_api_notification_services_v2_notification_service_proto protoreflect.FileDescriptor

Functions

func RegisterEventNotificationServiceHandler 

func RegisterEventNotificationServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterEventNotificationServiceHandler registers the http handlers for service EventNotificationService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterEventNotificationServiceHandlerClient 

func RegisterEventNotificationServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client EventNotificationServiceClient) error

RegisterEventNotificationServiceHandlerClient registers the http handlers for service EventNotificationService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "EventNotificationServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "EventNotificationServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "EventNotificationServiceClient" to call the correct interceptors.

func RegisterEventNotificationServiceHandlerFromEndpoint 

func RegisterEventNotificationServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterEventNotificationServiceHandlerFromEndpoint is same as RegisterEventNotificationServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterEventNotificationServiceHandlerServer 

func RegisterEventNotificationServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server EventNotificationServiceServer) error

RegisterEventNotificationServiceHandlerServer registers the http handlers for service EventNotificationService to "mux". UnaryRPC :call EventNotificationServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterEventNotificationServiceHandlerFromEndpoint instead.

func RegisterEventNotificationServiceServer 

func RegisterEventNotificationServiceServer(s grpc.ServiceRegistrar, srv EventNotificationServiceServer)

Types

type AcknowledgeMessageBatchRequest 

type AcknowledgeMessageBatchRequest struct {
	Replies []*Reply `protobuf:"bytes,1,rep,name=replies,proto3" json:"replies,omitempty"`
	// contains filtered or unexported fields
}

func (*AcknowledgeMessageBatchRequest) Descriptor deprecated 

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

Deprecated: Use AcknowledgeMessageBatchRequest.ProtoReflect.Descriptor instead.

func (*AcknowledgeMessageBatchRequest) GetReplies 

func (x *AcknowledgeMessageBatchRequest) GetReplies() []*Reply

func (*AcknowledgeMessageBatchRequest) ProtoMessage 

func (*AcknowledgeMessageBatchRequest) ProtoMessage()

func (*AcknowledgeMessageBatchRequest) ProtoReflect 

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

func (*AcknowledgeMessageBatchRequest) Reset 

func (x *AcknowledgeMessageBatchRequest) Reset()

func (*AcknowledgeMessageBatchRequest) String 

func (x *AcknowledgeMessageBatchRequest) String() string

type AcknowledgeMessageBatchResponse 

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

func (*AcknowledgeMessageBatchResponse) Descriptor deprecated 

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

Deprecated: Use AcknowledgeMessageBatchResponse.ProtoReflect.Descriptor instead.

func (*AcknowledgeMessageBatchResponse) ProtoMessage 

func (*AcknowledgeMessageBatchResponse) ProtoMessage()

func (*AcknowledgeMessageBatchResponse) ProtoReflect 

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

func (*AcknowledgeMessageBatchResponse) Reset 

func (x *AcknowledgeMessageBatchResponse) Reset()

func (*AcknowledgeMessageBatchResponse) String 

func (x *AcknowledgeMessageBatchResponse) String() string

type AnnouncementEvent 

type AnnouncementEvent struct {

	// Types that are assignable to EventVariant:
	//
	//	*AnnouncementEvent_NewDataProxyId
	//	*AnnouncementEvent_RemoveDataProxyId
	//	*AnnouncementEvent_UpdateDataProxyId
	//	*AnnouncementEvent_NewPubkey
	//	*AnnouncementEvent_RemovePubkey
	//	*AnnouncementEvent_Downtime
	//	*AnnouncementEvent_Version
	EventVariant isAnnouncementEvent_EventVariant `protobuf_oneof:"event_variant"`
	Reply        *Reply                           `protobuf:"bytes,8,opt,name=reply,proto3" json:"reply,omitempty"`
	// contains filtered or unexported fields
}

func (*AnnouncementEvent) Descriptor deprecated 

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

Deprecated: Use AnnouncementEvent.ProtoReflect.Descriptor instead.

func (*AnnouncementEvent) GetDowntime 

func (x *AnnouncementEvent) GetDowntime() *ScheduledDowntime

func (*AnnouncementEvent) GetEventVariant 

func (m *AnnouncementEvent) GetEventVariant() isAnnouncementEvent_EventVariant

func (*AnnouncementEvent) GetNewDataProxyId 

func (x *AnnouncementEvent) GetNewDataProxyId() string

func (*AnnouncementEvent) GetNewPubkey 

func (x *AnnouncementEvent) GetNewPubkey() int32

func (*AnnouncementEvent) GetRemoveDataProxyId 

func (x *AnnouncementEvent) GetRemoveDataProxyId() string

func (*AnnouncementEvent) GetRemovePubkey 

func (x *AnnouncementEvent) GetRemovePubkey() int32

func (*AnnouncementEvent) GetReply 

func (x *AnnouncementEvent) GetReply() *Reply

func (*AnnouncementEvent) GetUpdateDataProxyId 

func (x *AnnouncementEvent) GetUpdateDataProxyId() string

func (*AnnouncementEvent) GetVersion 

func (x *AnnouncementEvent) GetVersion() *NewVersion

func (*AnnouncementEvent) ProtoMessage 

func (*AnnouncementEvent) ProtoMessage()

func (*AnnouncementEvent) ProtoReflect 

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

func (*AnnouncementEvent) Reset 

func (x *AnnouncementEvent) Reset()

func (*AnnouncementEvent) String 

func (x *AnnouncementEvent) String() string

type AnnouncementEvent_Downtime 

type AnnouncementEvent_Downtime struct {
	Downtime *ScheduledDowntime `protobuf:"bytes,6,opt,name=downtime,proto3,oneof"`
}

type AnnouncementEvent_NewDataProxyId 

type AnnouncementEvent_NewDataProxyId struct {
	NewDataProxyId string `protobuf:"bytes,1,opt,name=new_data_proxy_id,json=newDataProxyId,proto3,oneof"`
}

type AnnouncementEvent_NewPubkey 

type AnnouncementEvent_NewPubkey struct {
	NewPubkey int32 `protobuf:"varint,4,opt,name=new_pubkey,json=newPubkey,proto3,oneof"`
}

type AnnouncementEvent_RemoveDataProxyId 

type AnnouncementEvent_RemoveDataProxyId struct {
	RemoveDataProxyId string `protobuf:"bytes,2,opt,name=remove_data_proxy_id,json=removeDataProxyId,proto3,oneof"`
}

type AnnouncementEvent_RemovePubkey 

type AnnouncementEvent_RemovePubkey struct {
	RemovePubkey int32 `protobuf:"varint,5,opt,name=remove_pubkey,json=removePubkey,proto3,oneof"`
}

type AnnouncementEvent_UpdateDataProxyId 

type AnnouncementEvent_UpdateDataProxyId struct {
	UpdateDataProxyId string `protobuf:"bytes,3,opt,name=update_data_proxy_id,json=updateDataProxyId,proto3,oneof"`
}

type AnnouncementEvent_Version 

type AnnouncementEvent_Version struct {
	Version *NewVersion `protobuf:"bytes,7,opt,name=version,proto3,oneof"`
}

type CreateStreamConsumerRequest 

type CreateStreamConsumerRequest struct {

	// Types that are assignable to Target:
	//
	//	*CreateStreamConsumerRequest_Resource
	//	*CreateStreamConsumerRequest_User
	//	*CreateStreamConsumerRequest_Announcements
	//	*CreateStreamConsumerRequest_All
	Target              isCreateStreamConsumerRequest_Target `protobuf_oneof:"target"`
	IncludeSubresources bool                                 `protobuf:"varint,5,opt,name=include_subresources,json=includeSubresources,proto3" json:"include_subresources,omitempty"`
	// Types that are assignable to StreamType:
	//
	//	*CreateStreamConsumerRequest_StreamAll
	//	*CreateStreamConsumerRequest_StreamFromDate
	//	*CreateStreamConsumerRequest_StreamFromSequence
	StreamType isCreateStreamConsumerRequest_StreamType `protobuf_oneof:"stream_type"`
	// contains filtered or unexported fields
}

func (*CreateStreamConsumerRequest) Descriptor deprecated 

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

Deprecated: Use CreateStreamConsumerRequest.ProtoReflect.Descriptor instead.

func (*CreateStreamConsumerRequest) GetAll 

func (x *CreateStreamConsumerRequest) GetAll() bool

func (*CreateStreamConsumerRequest) GetAnnouncements 

func (x *CreateStreamConsumerRequest) GetAnnouncements() bool

func (*CreateStreamConsumerRequest) GetIncludeSubresources 

func (x *CreateStreamConsumerRequest) GetIncludeSubresources() bool

func (*CreateStreamConsumerRequest) GetResource 

func (x *CreateStreamConsumerRequest) GetResource() *ResourceTarget

func (*CreateStreamConsumerRequest) GetStreamAll 

func (x *CreateStreamConsumerRequest) GetStreamAll() *StreamAll

func (*CreateStreamConsumerRequest) GetStreamFromDate 

func (x *CreateStreamConsumerRequest) GetStreamFromDate() *StreamFromDate

func (*CreateStreamConsumerRequest) GetStreamFromSequence 

func (x *CreateStreamConsumerRequest) GetStreamFromSequence() *StreamFromSequence

func (*CreateStreamConsumerRequest) GetStreamType 

func (m *CreateStreamConsumerRequest) GetStreamType() isCreateStreamConsumerRequest_StreamType

func (*CreateStreamConsumerRequest) GetTarget 

func (m *CreateStreamConsumerRequest) GetTarget() isCreateStreamConsumerRequest_Target

func (*CreateStreamConsumerRequest) GetUser 

func (x *CreateStreamConsumerRequest) GetUser() string

func (*CreateStreamConsumerRequest) ProtoMessage 

func (*CreateStreamConsumerRequest) ProtoMessage()

func (*CreateStreamConsumerRequest) ProtoReflect 

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

func (*CreateStreamConsumerRequest) Reset 

func (x *CreateStreamConsumerRequest) Reset()

func (*CreateStreamConsumerRequest) String 

func (x *CreateStreamConsumerRequest) String() string

type CreateStreamConsumerRequest_All 

type CreateStreamConsumerRequest_All struct {
	All bool `protobuf:"varint,4,opt,name=all,proto3,oneof"`
}

type CreateStreamConsumerRequest_Announcements 

type CreateStreamConsumerRequest_Announcements struct {
	Announcements bool `protobuf:"varint,3,opt,name=announcements,proto3,oneof"`
}

type CreateStreamConsumerRequest_Resource 

type CreateStreamConsumerRequest_Resource struct {
	Resource *ResourceTarget `protobuf:"bytes,1,opt,name=resource,proto3,oneof"`
}

type CreateStreamConsumerRequest_StreamAll 

type CreateStreamConsumerRequest_StreamAll struct {
	StreamAll *StreamAll `protobuf:"bytes,6,opt,name=stream_all,json=streamAll,proto3,oneof"`
}

type CreateStreamConsumerRequest_StreamFromDate 

type CreateStreamConsumerRequest_StreamFromDate struct {
	StreamFromDate *StreamFromDate `protobuf:"bytes,7,opt,name=stream_from_date,json=streamFromDate,proto3,oneof"`
}

type CreateStreamConsumerRequest_StreamFromSequence 

type CreateStreamConsumerRequest_StreamFromSequence struct {
	StreamFromSequence *StreamFromSequence `protobuf:"bytes,8,opt,name=stream_from_sequence,json=streamFromSequence,proto3,oneof"`
}

type CreateStreamConsumerRequest_User 

type CreateStreamConsumerRequest_User struct {
	User string `protobuf:"bytes,2,opt,name=user,proto3,oneof"`
}

type CreateStreamConsumerResponse 

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

func (*CreateStreamConsumerResponse) Descriptor deprecated 

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

Deprecated: Use CreateStreamConsumerResponse.ProtoReflect.Descriptor instead.

func (*CreateStreamConsumerResponse) GetStreamConsumer 

func (x *CreateStreamConsumerResponse) GetStreamConsumer() string

func (*CreateStreamConsumerResponse) ProtoMessage 

func (*CreateStreamConsumerResponse) ProtoMessage()

func (*CreateStreamConsumerResponse) ProtoReflect 

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

func (*CreateStreamConsumerResponse) Reset 

func (x *CreateStreamConsumerResponse) Reset()

func (*CreateStreamConsumerResponse) String 

func (x *CreateStreamConsumerResponse) String() string

type DeleteStreamConsumerRequest 

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

func (*DeleteStreamConsumerRequest) Descriptor deprecated 

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

Deprecated: Use DeleteStreamConsumerRequest.ProtoReflect.Descriptor instead.

func (*DeleteStreamConsumerRequest) GetStreamConsumer 

func (x *DeleteStreamConsumerRequest) GetStreamConsumer() string

func (*DeleteStreamConsumerRequest) ProtoMessage 

func (*DeleteStreamConsumerRequest) ProtoMessage()

func (*DeleteStreamConsumerRequest) ProtoReflect 

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

func (*DeleteStreamConsumerRequest) Reset 

func (x *DeleteStreamConsumerRequest) Reset()

func (*DeleteStreamConsumerRequest) String 

func (x *DeleteStreamConsumerRequest) String() string

type DeleteStreamConsumerResponse 

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

func (*DeleteStreamConsumerResponse) Descriptor deprecated 

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

Deprecated: Use DeleteStreamConsumerResponse.ProtoReflect.Descriptor instead.

func (*DeleteStreamConsumerResponse) ProtoMessage 

func (*DeleteStreamConsumerResponse) ProtoMessage()

func (*DeleteStreamConsumerResponse) ProtoReflect 

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

func (*DeleteStreamConsumerResponse) Reset 

func (x *DeleteStreamConsumerResponse) Reset()

func (*DeleteStreamConsumerResponse) String 

func (x *DeleteStreamConsumerResponse) String() string

type EventMessage 

type EventMessage struct {

	// Types that are assignable to MessageVariant:
	//
	//	*EventMessage_ResourceEvent
	//	*EventMessage_UserEvent
	//	*EventMessage_AnnouncementEvent
	MessageVariant isEventMessage_MessageVariant `protobuf_oneof:"message_variant"`
	// contains filtered or unexported fields
}

func (*EventMessage) Descriptor deprecated 

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

Deprecated: Use EventMessage.ProtoReflect.Descriptor instead.

func (*EventMessage) GetAnnouncementEvent 

func (x *EventMessage) GetAnnouncementEvent() *AnnouncementEvent

func (*EventMessage) GetMessageVariant 

func (m *EventMessage) GetMessageVariant() isEventMessage_MessageVariant

func (*EventMessage) GetResourceEvent 

func (x *EventMessage) GetResourceEvent() *ResourceEvent

func (*EventMessage) GetUserEvent 

func (x *EventMessage) GetUserEvent() *UserEvent

func (*EventMessage) ProtoMessage 

func (*EventMessage) ProtoMessage()

func (*EventMessage) ProtoReflect 

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

func (*EventMessage) Reset 

func (x *EventMessage) Reset()

func (*EventMessage) String 

func (x *EventMessage) String() string

type EventMessage_AnnouncementEvent 

type EventMessage_AnnouncementEvent struct {
	AnnouncementEvent *AnnouncementEvent `protobuf:"bytes,3,opt,name=announcement_event,json=announcementEvent,proto3,oneof"`
}

type EventMessage_ResourceEvent 

type EventMessage_ResourceEvent struct {
	ResourceEvent *ResourceEvent `protobuf:"bytes,1,opt,name=resource_event,json=resourceEvent,proto3,oneof"`
}

type EventMessage_UserEvent 

type EventMessage_UserEvent struct {
	UserEvent *UserEvent `protobuf:"bytes,2,opt,name=user_event,json=userEvent,proto3,oneof"`
}

type EventNotificationServiceClient 

type EventNotificationServiceClient interface {
	// CreateStreamConsumer
	//
	// Status: BETA
	//
	// Creates a new event stream consumer.
	CreateStreamConsumer(ctx context.Context, in *CreateStreamConsumerRequest, opts ...grpc.CallOption) (*CreateStreamConsumerResponse, error)
	// GetEventMessageBatch
	//
	// Status: BETA
	//
	// Reads a set of messages from a given stream group
	// Each message contains a separate acknowledgement message thatis protected by a salt and an hmac for verification.
	// The message can be send directly through the AcknowledgeMessageBatch call to acknowledge the message.
	GetEventMessageBatch(ctx context.Context, in *GetEventMessageBatchRequest, opts ...grpc.CallOption) (*GetEventMessageBatchResponse, error)
	// GetEventMessageBatch
	//
	// Status: BETA
	//
	// Opens a stream which pushes each received notification individual and just-in-time.
	// Each message contains a separate acknowledgement message that is protected by a salt and an hmac for verification.
	// The message can be send directly through the AcknowledgeMessageBatch call to acknowledge the message.
	GetEventMessageStream(ctx context.Context, in *GetEventMessageStreamRequest, opts ...grpc.CallOption) (EventNotificationService_GetEventMessageStreamClient, error)
	// AcknowledgeMessageBatch
	//
	// Status: BETA
	//
	// List of messages to acknowledge
	// Each reply is protected by a salt and and hmac that verifies the message
	AcknowledgeMessageBatch(ctx context.Context, in *AcknowledgeMessageBatchRequest, opts ...grpc.CallOption) (*AcknowledgeMessageBatchResponse, error)
	// DeleteEventStreamingGroup
	//
	// Status: BETA
	//
	// Deletes an existing event stream consumer by ID.
	DeleteStreamConsumer(ctx context.Context, in *DeleteStreamConsumerRequest, opts ...grpc.CallOption) (*DeleteStreamConsumerResponse, error)
}

EventNotificationServiceClient is the client API for EventNotificationService 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 NewEventNotificationServiceClient 

func NewEventNotificationServiceClient(cc grpc.ClientConnInterface) EventNotificationServiceClient

type EventNotificationServiceServer 

type EventNotificationServiceServer interface {
	// CreateStreamConsumer
	//
	// Status: BETA
	//
	// Creates a new event stream consumer.
	CreateStreamConsumer(context.Context, *CreateStreamConsumerRequest) (*CreateStreamConsumerResponse, error)
	// GetEventMessageBatch
	//
	// Status: BETA
	//
	// Reads a set of messages from a given stream group
	// Each message contains a separate acknowledgement message thatis protected by a salt and an hmac for verification.
	// The message can be send directly through the AcknowledgeMessageBatch call to acknowledge the message.
	GetEventMessageBatch(context.Context, *GetEventMessageBatchRequest) (*GetEventMessageBatchResponse, error)
	// GetEventMessageBatch
	//
	// Status: BETA
	//
	// Opens a stream which pushes each received notification individual and just-in-time.
	// Each message contains a separate acknowledgement message that is protected by a salt and an hmac for verification.
	// The message can be send directly through the AcknowledgeMessageBatch call to acknowledge the message.
	GetEventMessageStream(*GetEventMessageStreamRequest, EventNotificationService_GetEventMessageStreamServer) error
	// AcknowledgeMessageBatch
	//
	// Status: BETA
	//
	// List of messages to acknowledge
	// Each reply is protected by a salt and and hmac that verifies the message
	AcknowledgeMessageBatch(context.Context, *AcknowledgeMessageBatchRequest) (*AcknowledgeMessageBatchResponse, error)
	// DeleteEventStreamingGroup
	//
	// Status: BETA
	//
	// Deletes an existing event stream consumer by ID.
	DeleteStreamConsumer(context.Context, *DeleteStreamConsumerRequest) (*DeleteStreamConsumerResponse, error)
}

EventNotificationServiceServer is the server API for EventNotificationService service. All implementations should embed UnimplementedEventNotificationServiceServer for forward compatibility

type EventNotificationService_GetEventMessageStreamClient 

type EventNotificationService_GetEventMessageStreamClient interface {
	Recv() (*GetEventMessageStreamResponse, error)
	grpc.ClientStream
}

type EventNotificationService_GetEventMessageStreamServer 

type EventNotificationService_GetEventMessageStreamServer interface {
	Send(*GetEventMessageStreamResponse) error
	grpc.ServerStream
}

type EventVariant 

type EventVariant int32
const (
	EventVariant_EVENT_VARIANT_UNSPECIFIED EventVariant = 0
	EventVariant_EVENT_VARIANT_CREATED     EventVariant = 1
	EventVariant_EVENT_VARIANT_AVAILABLE   EventVariant = 2
	EventVariant_EVENT_VARIANT_UPDATED     EventVariant = 3
	EventVariant_EVENT_VARIANT_DELETED     EventVariant = 4
	EventVariant_EVENT_VARIANT_SNAPSHOTTED EventVariant = 5
)

func (EventVariant) Descriptor 

func (EventVariant) Descriptor() protoreflect.EnumDescriptor

func (EventVariant) Enum 

func (x EventVariant) Enum() *EventVariant

func (EventVariant) EnumDescriptor deprecated 

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

Deprecated: Use EventVariant.Descriptor instead.

func (EventVariant) Number 

func (x EventVariant) Number() protoreflect.EnumNumber

func (EventVariant) String 

func (x EventVariant) String() string

func (EventVariant) Type 

func (EventVariant) Type() protoreflect.EnumType

type GetEventMessageBatchRequest 

type GetEventMessageBatchRequest struct {
	StreamConsumer string `protobuf:"bytes,1,opt,name=stream_consumer,json=streamConsumer,proto3" json:"stream_consumer,omitempty"`
	BatchSize      uint32 `protobuf:"varint,2,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEventMessageBatchRequest) Descriptor deprecated 

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

Deprecated: Use GetEventMessageBatchRequest.ProtoReflect.Descriptor instead.

func (*GetEventMessageBatchRequest) GetBatchSize 

func (x *GetEventMessageBatchRequest) GetBatchSize() uint32

func (*GetEventMessageBatchRequest) GetStreamConsumer 

func (x *GetEventMessageBatchRequest) GetStreamConsumer() string

func (*GetEventMessageBatchRequest) ProtoMessage 

func (*GetEventMessageBatchRequest) ProtoMessage()

func (*GetEventMessageBatchRequest) ProtoReflect 

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

func (*GetEventMessageBatchRequest) Reset 

func (x *GetEventMessageBatchRequest) Reset()

func (*GetEventMessageBatchRequest) String 

func (x *GetEventMessageBatchRequest) String() string

type GetEventMessageBatchResponse 

type GetEventMessageBatchResponse struct {
	Messages []*EventMessage `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEventMessageBatchResponse) Descriptor deprecated 

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

Deprecated: Use GetEventMessageBatchResponse.ProtoReflect.Descriptor instead.

func (*GetEventMessageBatchResponse) GetMessages 

func (x *GetEventMessageBatchResponse) GetMessages() []*EventMessage

func (*GetEventMessageBatchResponse) ProtoMessage 

func (*GetEventMessageBatchResponse) ProtoMessage()

func (*GetEventMessageBatchResponse) ProtoReflect 

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

func (*GetEventMessageBatchResponse) Reset 

func (x *GetEventMessageBatchResponse) Reset()

func (*GetEventMessageBatchResponse) String 

func (x *GetEventMessageBatchResponse) String() string

type GetEventMessageStreamRequest 

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

func (*GetEventMessageStreamRequest) Descriptor deprecated 

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

Deprecated: Use GetEventMessageStreamRequest.ProtoReflect.Descriptor instead.

func (*GetEventMessageStreamRequest) GetStreamConsumer 

func (x *GetEventMessageStreamRequest) GetStreamConsumer() string

func (*GetEventMessageStreamRequest) ProtoMessage 

func (*GetEventMessageStreamRequest) ProtoMessage()

func (*GetEventMessageStreamRequest) ProtoReflect 

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

func (*GetEventMessageStreamRequest) Reset 

func (x *GetEventMessageStreamRequest) Reset()

func (*GetEventMessageStreamRequest) String 

func (x *GetEventMessageStreamRequest) String() string

type GetEventMessageStreamResponse 

type GetEventMessageStreamResponse struct {
	Message *EventMessage `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEventMessageStreamResponse) Descriptor deprecated 

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

Deprecated: Use GetEventMessageStreamResponse.ProtoReflect.Descriptor instead.

func (*GetEventMessageStreamResponse) GetMessage 

func (x *GetEventMessageStreamResponse) GetMessage() *EventMessage

func (*GetEventMessageStreamResponse) ProtoMessage 

func (*GetEventMessageStreamResponse) ProtoMessage()

func (*GetEventMessageStreamResponse) ProtoReflect 

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

func (*GetEventMessageStreamResponse) Reset 

func (x *GetEventMessageStreamResponse) Reset()

func (*GetEventMessageStreamResponse) String 

func (x *GetEventMessageStreamResponse) String() string

type NewPubkey 

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

func (*NewPubkey) Descriptor deprecated 

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

Deprecated: Use NewPubkey.ProtoReflect.Descriptor instead.

func (*NewPubkey) GetPubkey 

func (x *NewPubkey) GetPubkey() string

func (*NewPubkey) ProtoMessage 

func (*NewPubkey) ProtoMessage()

func (*NewPubkey) ProtoReflect 

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

func (*NewPubkey) Reset 

func (x *NewPubkey) Reset()

func (*NewPubkey) String 

func (x *NewPubkey) String() string

type NewVersion 

type NewVersion struct {
	Location   string `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	Component  string `protobuf:"bytes,2,opt,name=component,proto3" json:"component,omitempty"`
	NewVersion string `protobuf:"bytes,3,opt,name=new_version,json=newVersion,proto3" json:"new_version,omitempty"`
	// contains filtered or unexported fields
}

func (*NewVersion) Descriptor deprecated 

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

Deprecated: Use NewVersion.ProtoReflect.Descriptor instead.

func (*NewVersion) GetComponent 

func (x *NewVersion) GetComponent() string

func (*NewVersion) GetLocation 

func (x *NewVersion) GetLocation() string

func (*NewVersion) GetNewVersion 

func (x *NewVersion) GetNewVersion() string

func (*NewVersion) ProtoMessage 

func (*NewVersion) ProtoMessage()

func (*NewVersion) ProtoReflect 

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

func (*NewVersion) Reset 

func (x *NewVersion) Reset()

func (*NewVersion) String 

func (x *NewVersion) String() string

type Reply 

type Reply struct {
	Reply string `protobuf:"bytes,1,opt,name=reply,proto3" json:"reply,omitempty"`
	Salt  string `protobuf:"bytes,2,opt,name=salt,proto3" json:"salt,omitempty"`
	Hmac  string `protobuf:"bytes,3,opt,name=hmac,proto3" json:"hmac,omitempty"`
	// contains filtered or unexported fields
}

func (*Reply) Descriptor deprecated 

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

Deprecated: Use Reply.ProtoReflect.Descriptor instead.

func (*Reply) GetHmac 

func (x *Reply) GetHmac() string

func (*Reply) GetReply 

func (x *Reply) GetReply() string

func (*Reply) GetSalt 

func (x *Reply) GetSalt() string

func (*Reply) ProtoMessage 

func (*Reply) ProtoMessage()

func (*Reply) ProtoReflect 

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

func (*Reply) Reset 

func (x *Reply) Reset()

func (*Reply) String 

func (x *Reply) String() string

type Resource 

type Resource struct {
	ResourceId           string             `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	PersistentResourceId bool               `protobuf:"varint,2,opt,name=persistent_resource_id,json=persistentResourceId,proto3" json:"persistent_resource_id,omitempty"`
	Checksum             string             `protobuf:"bytes,3,opt,name=checksum,proto3" json:"checksum,omitempty"`
	ResourceVariant      v2.ResourceVariant `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Resource) Descriptor deprecated 

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

Deprecated: Use Resource.ProtoReflect.Descriptor instead.

func (*Resource) GetChecksum 

func (x *Resource) GetChecksum() string

func (*Resource) GetPersistentResourceId 

func (x *Resource) GetPersistentResourceId() bool

func (*Resource) GetResourceId 

func (x *Resource) GetResourceId() string

func (*Resource) GetResourceVariant 

func (x *Resource) GetResourceVariant() v2.ResourceVariant

func (*Resource) ProtoMessage 

func (*Resource) ProtoMessage()

func (*Resource) ProtoReflect 

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

func (*Resource) Reset 

func (x *Resource) Reset()

func (*Resource) String 

func (x *Resource) String() string

type ResourceEvent 

type ResourceEvent struct {
	Resource     *Resource    `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	EventVariant EventVariant `` /* 151-byte string literal not displayed */
	Reply        *Reply       `protobuf:"bytes,3,opt,name=reply,proto3" json:"reply,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceEvent) Descriptor deprecated 

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

Deprecated: Use ResourceEvent.ProtoReflect.Descriptor instead.

func (*ResourceEvent) GetEventVariant 

func (x *ResourceEvent) GetEventVariant() EventVariant

func (*ResourceEvent) GetReply 

func (x *ResourceEvent) GetReply() *Reply

func (*ResourceEvent) GetResource 

func (x *ResourceEvent) GetResource() *Resource

func (*ResourceEvent) ProtoMessage 

func (*ResourceEvent) ProtoMessage()

func (*ResourceEvent) ProtoReflect 

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

func (*ResourceEvent) Reset 

func (x *ResourceEvent) Reset()

func (*ResourceEvent) String 

func (x *ResourceEvent) String() string

type ResourceTarget 

type ResourceTarget struct {
	ResourceId      string             `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	ResourceVariant v2.ResourceVariant `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ResourceTarget) Descriptor deprecated 

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

Deprecated: Use ResourceTarget.ProtoReflect.Descriptor instead.

func (*ResourceTarget) GetResourceId 

func (x *ResourceTarget) GetResourceId() string

func (*ResourceTarget) GetResourceVariant 

func (x *ResourceTarget) GetResourceVariant() v2.ResourceVariant

func (*ResourceTarget) ProtoMessage 

func (*ResourceTarget) ProtoMessage()

func (*ResourceTarget) ProtoReflect 

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

func (*ResourceTarget) Reset 

func (x *ResourceTarget) Reset()

func (*ResourceTarget) String 

func (x *ResourceTarget) String() string

type ScheduledDowntime 

type ScheduledDowntime struct {
	Location  string                 `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	Component string                 `protobuf:"bytes,2,opt,name=component,proto3" json:"component,omitempty"`
	From      *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"`
	To        *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=to,proto3" json:"to,omitempty"`
	// contains filtered or unexported fields
}

func (*ScheduledDowntime) Descriptor deprecated 

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

Deprecated: Use ScheduledDowntime.ProtoReflect.Descriptor instead.

func (*ScheduledDowntime) GetComponent 

func (x *ScheduledDowntime) GetComponent() string

func (*ScheduledDowntime) GetFrom 

func (x *ScheduledDowntime) GetFrom() *timestamppb.Timestamp

func (*ScheduledDowntime) GetLocation 

func (x *ScheduledDowntime) GetLocation() string

func (*ScheduledDowntime) GetTo 

func (x *ScheduledDowntime) GetTo() *timestamppb.Timestamp

func (*ScheduledDowntime) ProtoMessage 

func (*ScheduledDowntime) ProtoMessage()

func (*ScheduledDowntime) ProtoReflect 

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

func (*ScheduledDowntime) Reset 

func (x *ScheduledDowntime) Reset()

func (*ScheduledDowntime) String 

func (x *ScheduledDowntime) String() string

type StreamAll 

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

func (*StreamAll) Descriptor deprecated 

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

Deprecated: Use StreamAll.ProtoReflect.Descriptor instead.

func (*StreamAll) ProtoMessage 

func (*StreamAll) ProtoMessage()

func (*StreamAll) ProtoReflect 

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

func (*StreamAll) Reset 

func (x *StreamAll) Reset()

func (*StreamAll) String 

func (x *StreamAll) String() string

type StreamFromDate 

type StreamFromDate struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFromDate) Descriptor deprecated 

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

Deprecated: Use StreamFromDate.ProtoReflect.Descriptor instead.

func (*StreamFromDate) GetTimestamp 

func (x *StreamFromDate) GetTimestamp() *timestamppb.Timestamp

func (*StreamFromDate) ProtoMessage 

func (*StreamFromDate) ProtoMessage()

func (*StreamFromDate) ProtoReflect 

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

func (*StreamFromDate) Reset 

func (x *StreamFromDate) Reset()

func (*StreamFromDate) String 

func (x *StreamFromDate) String() string

type StreamFromSequence 

type StreamFromSequence struct {
	Sequence uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFromSequence) Descriptor deprecated 

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

Deprecated: Use StreamFromSequence.ProtoReflect.Descriptor instead.

func (*StreamFromSequence) GetSequence 

func (x *StreamFromSequence) GetSequence() uint64

func (*StreamFromSequence) ProtoMessage 

func (*StreamFromSequence) ProtoMessage()

func (*StreamFromSequence) ProtoReflect 

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

func (*StreamFromSequence) Reset 

func (x *StreamFromSequence) Reset()

func (*StreamFromSequence) String 

func (x *StreamFromSequence) String() string

type UnimplementedEventNotificationServiceServer 

type UnimplementedEventNotificationServiceServer struct {
}

UnimplementedEventNotificationServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedEventNotificationServiceServer) AcknowledgeMessageBatch 

func (UnimplementedEventNotificationServiceServer) AcknowledgeMessageBatch(context.Context, *AcknowledgeMessageBatchRequest) (*AcknowledgeMessageBatchResponse, error)

func (UnimplementedEventNotificationServiceServer) CreateStreamConsumer 

func (UnimplementedEventNotificationServiceServer) CreateStreamConsumer(context.Context, *CreateStreamConsumerRequest) (*CreateStreamConsumerResponse, error)

func (UnimplementedEventNotificationServiceServer) DeleteStreamConsumer 

func (UnimplementedEventNotificationServiceServer) DeleteStreamConsumer(context.Context, *DeleteStreamConsumerRequest) (*DeleteStreamConsumerResponse, error)

func (UnimplementedEventNotificationServiceServer) GetEventMessageBatch 

func (UnimplementedEventNotificationServiceServer) GetEventMessageBatch(context.Context, *GetEventMessageBatchRequest) (*GetEventMessageBatchResponse, error)

func (UnimplementedEventNotificationServiceServer) GetEventMessageStream 

func (UnimplementedEventNotificationServiceServer) GetEventMessageStream(*GetEventMessageStreamRequest, EventNotificationService_GetEventMessageStreamServer) error

type UnsafeEventNotificationServiceServer 

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

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

type UserEvent 

type UserEvent struct {
	UserId       string       `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	EventVariant EventVariant `` /* 151-byte string literal not displayed */
	Checksum     string       `protobuf:"bytes,3,opt,name=checksum,proto3" json:"checksum,omitempty"`
	Reply        *Reply       `protobuf:"bytes,4,opt,name=reply,proto3" json:"reply,omitempty"`
	// contains filtered or unexported fields
}

func (*UserEvent) Descriptor deprecated 

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

Deprecated: Use UserEvent.ProtoReflect.Descriptor instead.

func (*UserEvent) GetChecksum 

func (x *UserEvent) GetChecksum() string

func (*UserEvent) GetEventVariant 

func (x *UserEvent) GetEventVariant() EventVariant

func (*UserEvent) GetReply 

func (x *UserEvent) GetReply() *Reply

func (*UserEvent) GetUserId 

func (x *UserEvent) GetUserId() string

func (*UserEvent) ProtoMessage 

func (*UserEvent) ProtoMessage()

func (*UserEvent) ProtoReflect 

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

func (*UserEvent) Reset 

func (x *UserEvent) Reset()

func (*UserEvent) String 

func (x *UserEvent) 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.