v1

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Apr 20, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	EventType_name = map[int32]string{
		0: "EVENT_TYPE_UNSPECIFIED",
		1: "EVENT_TYPE_CREATED",
		2: "EVENT_TYPE_AVAILABLE",
		3: "EVENT_TYPE_UPDATED",
		4: "EVENT_TYPE_METADATA_UPDATED",
		5: "EVENT_TYPE_DELETED",
		6: "EVENT_TYPE_ALL",
	}
	EventType_value = map[string]int32{
		"EVENT_TYPE_UNSPECIFIED":      0,
		"EVENT_TYPE_CREATED":          1,
		"EVENT_TYPE_AVAILABLE":        2,
		"EVENT_TYPE_UPDATED":          3,
		"EVENT_TYPE_METADATA_UPDATED": 4,
		"EVENT_TYPE_DELETED":          5,
		"EVENT_TYPE_ALL":              6,
	}
)

Enum value maps for EventType.

View Source 
var (
	CreateEventStreamingGroupRequest_EventResources_name = map[int32]string{
		0: "EVENT_RESOURCES_UNSPECIFIED",
		1: "EVENT_RESOURCES_COLLECTION_RESOURCE",
		5: "EVENT_RESOURCES_ALL_RESOURCE",
	}
	CreateEventStreamingGroupRequest_EventResources_value = map[string]int32{
		"EVENT_RESOURCES_UNSPECIFIED":         0,
		"EVENT_RESOURCES_COLLECTION_RESOURCE": 1,
		"EVENT_RESOURCES_ALL_RESOURCE":        5,
	}
)

Enum value maps for CreateEventStreamingGroupRequest_EventResources.

View Source 
var (
	EventNotificationMessage_UpdateType_name = map[int32]string{
		0: "UPDATE_TYPE_UNSPECIFIED",
		1: "UPDATE_TYPE_CREATED",
		2: "UPDATE_TYPE_AVAILABLE",
		3: "UPDATE_TYPE_UPDATED",
		4: "UPDATE_TYPE_METADATA_UPDATED",
		5: "UPDATE_TYPE_DELETED",
	}
	EventNotificationMessage_UpdateType_value = map[string]int32{
		"UPDATE_TYPE_UNSPECIFIED":      0,
		"UPDATE_TYPE_CREATED":          1,
		"UPDATE_TYPE_AVAILABLE":        2,
		"UPDATE_TYPE_UPDATED":          3,
		"UPDATE_TYPE_METADATA_UPDATED": 4,
		"UPDATE_TYPE_DELETED":          5,
	}
)

Enum value maps for EventNotificationMessage_UpdateType.

View Source 
var (
	EventNotificationMessage_EventResources_name = map[int32]string{
		0: "EVENT_RESOURCES_UNSPECIFIED",
		1: "EVENT_RESOURCES_COLLECTION_RESOURCE",
		5: "EVENT_RESOURCES_ALL_RESOURCE",
	}
	EventNotificationMessage_EventResources_value = map[string]int32{
		"EVENT_RESOURCES_UNSPECIFIED":         0,
		"EVENT_RESOURCES_COLLECTION_RESOURCE": 1,
		"EVENT_RESOURCES_ALL_RESOURCE":        5,
	}
)

Enum value maps for EventNotificationMessage_EventResources.

View Source 
var EventNotificationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "aruna.api.notification.services.v1.EventNotificationService",
	HandlerType: (*EventNotificationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateEventStreamingGroup",
			Handler:    _EventNotificationService_CreateEventStreamingGroup_Handler,
		},
		{
			MethodName: "GetEventMessageBatch",
			Handler:    _EventNotificationService_GetEventMessageBatch_Handler,
		},
		{
			MethodName: "AcknowledgeMessageBatch",
			Handler:    _EventNotificationService_AcknowledgeMessageBatch_Handler,
		},
		{
			MethodName: "DeleteEventStreamingGroup",
			Handler:    _EventNotificationService_DeleteEventStreamingGroup_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetEventMessageBatchStream",
			Handler:       _EventNotificationService_GetEventMessageBatchStream_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "aruna/api/notification/services/v1/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_v1_notification_service_models_proto protoreflect.FileDescriptor
View Source 
var File_aruna_api_notification_services_v1_notification_service_proto protoreflect.FileDescriptor

Functions

func RegisterEventNotificationServiceServer added in v1.0.0 

func RegisterEventNotificationServiceServer(s grpc.ServiceRegistrar, srv EventNotificationServiceServer)

Types

type AcknowledgeMessageBatchRequest added in v1.0.0 

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

func (*AcknowledgeMessageBatchRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use AcknowledgeMessageBatchRequest.ProtoReflect.Descriptor instead.

func (*AcknowledgeMessageBatchRequest) GetReplies added in v1.0.0 

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

func (*AcknowledgeMessageBatchRequest) ProtoMessage added in v1.0.0 

func (*AcknowledgeMessageBatchRequest) ProtoMessage()

func (*AcknowledgeMessageBatchRequest) ProtoReflect added in v1.0.0 

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

func (*AcknowledgeMessageBatchRequest) Reset added in v1.0.0 

func (x *AcknowledgeMessageBatchRequest) Reset()

func (*AcknowledgeMessageBatchRequest) String added in v1.0.0 

func (x *AcknowledgeMessageBatchRequest) String() string

type AcknowledgeMessageBatchResponse added in v1.0.0 

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

func (*AcknowledgeMessageBatchResponse) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use AcknowledgeMessageBatchResponse.ProtoReflect.Descriptor instead.

func (*AcknowledgeMessageBatchResponse) ProtoMessage added in v1.0.0 

func (*AcknowledgeMessageBatchResponse) ProtoMessage()

func (*AcknowledgeMessageBatchResponse) ProtoReflect added in v1.0.0 

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

func (*AcknowledgeMessageBatchResponse) Reset added in v1.0.0 

func (x *AcknowledgeMessageBatchResponse) Reset()

func (*AcknowledgeMessageBatchResponse) String added in v1.0.0 

func (x *AcknowledgeMessageBatchResponse) String() string

type CreateEventStreamingGroupRequest 

type CreateEventStreamingGroupRequest struct {
	Resource           CreateEventStreamingGroupRequest_EventResources `` /* 158-byte string literal not displayed */
	ResourceId         string                                          `protobuf:"bytes,2,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	IncludeSubresource bool                                            `protobuf:"varint,3,opt,name=include_subresource,json=includeSubresource,proto3" json:"include_subresource,omitempty"`
	// Types that are assignable to StreamType:
	//	*CreateEventStreamingGroupRequest_StreamAll
	//	*CreateEventStreamingGroupRequest_StreamFromDate
	//	*CreateEventStreamingGroupRequest_StreamFromSequence
	StreamType    isCreateEventStreamingGroupRequest_StreamType `protobuf_oneof:"stream_type"`
	StreamGroupId string                                        `protobuf:"bytes,7,opt,name=stream_group_id,json=streamGroupId,proto3" json:"stream_group_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateEventStreamingGroupRequest) Descriptor deprecated 

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

Deprecated: Use CreateEventStreamingGroupRequest.ProtoReflect.Descriptor instead.

func (*CreateEventStreamingGroupRequest) GetHierarchy added in v1.0.0 

func (x *CreateEventStreamingGroupRequest) GetHierarchy() *EventStreamingGroupHierarchy

func (*CreateEventStreamingGroupRequest) GetIncludeSubresource 

func (x *CreateEventStreamingGroupRequest) GetIncludeSubresource() bool

func (*CreateEventStreamingGroupRequest) GetResource 

func (x *CreateEventStreamingGroupRequest) GetResource() v1.ResourceType

func (*CreateEventStreamingGroupRequest) GetResourceId 

func (x *CreateEventStreamingGroupRequest) GetResourceId() string

func (*CreateEventStreamingGroupRequest) GetStreamAll 

func (x *CreateEventStreamingGroupRequest) GetStreamAll() *StreamAll

func (*CreateEventStreamingGroupRequest) GetStreamFromDate 

func (x *CreateEventStreamingGroupRequest) GetStreamFromDate() *StreamFromDate

func (*CreateEventStreamingGroupRequest) GetStreamFromSequence 

func (x *CreateEventStreamingGroupRequest) GetStreamFromSequence() *StreamFromSequence

func (*CreateEventStreamingGroupRequest) GetStreamGroupId 

func (x *CreateEventStreamingGroupRequest) GetStreamGroupId() string

func (*CreateEventStreamingGroupRequest) GetStreamType 

func (m *CreateEventStreamingGroupRequest) GetStreamType() isCreateEventStreamingGroupRequest_StreamType

func (*CreateEventStreamingGroupRequest) ProtoMessage 

func (*CreateEventStreamingGroupRequest) ProtoMessage()

func (*CreateEventStreamingGroupRequest) ProtoReflect 

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

func (*CreateEventStreamingGroupRequest) Reset 

func (x *CreateEventStreamingGroupRequest) Reset()

func (*CreateEventStreamingGroupRequest) String 

func (x *CreateEventStreamingGroupRequest) String() string

type CreateEventStreamingGroupRequest_EventResources 

type CreateEventStreamingGroupRequest_EventResources int32
const (
	CreateEventStreamingGroupRequest_EVENT_RESOURCES_UNSPECIFIED         CreateEventStreamingGroupRequest_EventResources = 0
	CreateEventStreamingGroupRequest_EVENT_RESOURCES_COLLECTION_RESOURCE CreateEventStreamingGroupRequest_EventResources = 1
	CreateEventStreamingGroupRequest_EVENT_RESOURCES_ALL_RESOURCE        CreateEventStreamingGroupRequest_EventResources = 5
)

func (CreateEventStreamingGroupRequest_EventResources) Descriptor 

func (CreateEventStreamingGroupRequest_EventResources) Descriptor() protoreflect.EnumDescriptor

func (CreateEventStreamingGroupRequest_EventResources) Enum 

func (x CreateEventStreamingGroupRequest_EventResources) Enum() *CreateEventStreamingGroupRequest_EventResources

func (CreateEventStreamingGroupRequest_EventResources) EnumDescriptor deprecated 

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

Deprecated: Use CreateEventStreamingGroupRequest_EventResources.Descriptor instead.

func (CreateEventStreamingGroupRequest_EventResources) Number 

func (x CreateEventStreamingGroupRequest_EventResources) Number() protoreflect.EnumNumber

func (CreateEventStreamingGroupRequest_EventResources) String 

func (x CreateEventStreamingGroupRequest_EventResources) String() string

func (CreateEventStreamingGroupRequest_EventResources) Type 

func (CreateEventStreamingGroupRequest_EventResources) Type() protoreflect.EnumType

type CreateEventStreamingGroupRequest_StreamAll 

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

type CreateEventStreamingGroupRequest_StreamFromDate 

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

type CreateEventStreamingGroupRequest_StreamFromSequence 

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

type CreateEventStreamingGroupResponse 

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

func (*CreateEventStreamingGroupResponse) Descriptor deprecated 

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

Deprecated: Use CreateEventStreamingGroupResponse.ProtoReflect.Descriptor instead.

func (*CreateEventStreamingGroupResponse) GetStreamGroupId 

func (x *CreateEventStreamingGroupResponse) GetStreamGroupId() string

func (*CreateEventStreamingGroupResponse) ProtoMessage 

func (*CreateEventStreamingGroupResponse) ProtoMessage()

func (*CreateEventStreamingGroupResponse) ProtoReflect 

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

func (*CreateEventStreamingGroupResponse) Reset 

func (x *CreateEventStreamingGroupResponse) Reset()

func (*CreateEventStreamingGroupResponse) String 

func (x *CreateEventStreamingGroupResponse) String() string

type DeleteEventStreamingGroupRequest added in v0.5.0 

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

func (*DeleteEventStreamingGroupRequest) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use DeleteEventStreamingGroupRequest.ProtoReflect.Descriptor instead.

func (*DeleteEventStreamingGroupRequest) GetStreamGroupId added in v0.5.0 

func (x *DeleteEventStreamingGroupRequest) GetStreamGroupId() string

func (*DeleteEventStreamingGroupRequest) ProtoMessage added in v0.5.0 

func (*DeleteEventStreamingGroupRequest) ProtoMessage()

func (*DeleteEventStreamingGroupRequest) ProtoReflect added in v0.5.0 

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

func (*DeleteEventStreamingGroupRequest) Reset added in v0.5.0 

func (x *DeleteEventStreamingGroupRequest) Reset()

func (*DeleteEventStreamingGroupRequest) String added in v0.5.0 

func (x *DeleteEventStreamingGroupRequest) String() string

type DeleteEventStreamingGroupResponse added in v0.5.0 

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

func (*DeleteEventStreamingGroupResponse) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use DeleteEventStreamingGroupResponse.ProtoReflect.Descriptor instead.

func (*DeleteEventStreamingGroupResponse) ProtoMessage added in v0.5.0 

func (*DeleteEventStreamingGroupResponse) ProtoMessage()

func (*DeleteEventStreamingGroupResponse) ProtoReflect added in v0.5.0 

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

func (*DeleteEventStreamingGroupResponse) Reset added in v0.5.0 

func (x *DeleteEventStreamingGroupResponse) Reset()

func (*DeleteEventStreamingGroupResponse) String added in v0.5.0 

func (x *DeleteEventStreamingGroupResponse) String() string

type EventNotificationMessage 

type EventNotificationMessage struct {
	Resource    EventNotificationMessage_EventResources `` /* 150-byte string literal not displayed */
	ResourceId  string                                  `protobuf:"bytes,2,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	UpdatedType EventNotificationMessage_UpdateType     `` /* 171-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EventNotificationMessage) Descriptor deprecated 

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

Deprecated: Use EventNotificationMessage.ProtoReflect.Descriptor instead.

func (*EventNotificationMessage) GetReply added in v1.0.0 

func (x *EventNotificationMessage) GetReply() *Reply

func (*EventNotificationMessage) GetResource 

func (x *EventNotificationMessage) GetResource() v1.ResourceType

func (*EventNotificationMessage) GetResourceId 

func (x *EventNotificationMessage) GetResourceId() string

func (*EventNotificationMessage) GetUpdatedType 

func (x *EventNotificationMessage) GetUpdatedType() EventType

func (*EventNotificationMessage) ProtoMessage 

func (*EventNotificationMessage) ProtoMessage()

func (*EventNotificationMessage) ProtoReflect 

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

func (*EventNotificationMessage) Reset 

func (x *EventNotificationMessage) Reset()

func (*EventNotificationMessage) String 

func (x *EventNotificationMessage) String() string

type EventNotificationMessage_EventResources 

type EventNotificationMessage_EventResources int32
const (
	EventNotificationMessage_EVENT_RESOURCES_UNSPECIFIED         EventNotificationMessage_EventResources = 0
	EventNotificationMessage_EVENT_RESOURCES_COLLECTION_RESOURCE EventNotificationMessage_EventResources = 1
	EventNotificationMessage_EVENT_RESOURCES_ALL_RESOURCE        EventNotificationMessage_EventResources = 5
)

func (EventNotificationMessage_EventResources) Descriptor 

func (EventNotificationMessage_EventResources) Descriptor() protoreflect.EnumDescriptor

func (EventNotificationMessage_EventResources) Enum 

func (x EventNotificationMessage_EventResources) Enum() *EventNotificationMessage_EventResources

func (EventNotificationMessage_EventResources) EnumDescriptor deprecated 

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

Deprecated: Use EventNotificationMessage_EventResources.Descriptor instead.

func (EventNotificationMessage_EventResources) Number 

func (x EventNotificationMessage_EventResources) Number() protoreflect.EnumNumber

func (EventNotificationMessage_EventResources) String 

func (x EventNotificationMessage_EventResources) String() string

func (EventNotificationMessage_EventResources) Type 

func (EventNotificationMessage_EventResources) Type() protoreflect.EnumType

type EventNotificationMessage_UpdateType 

type EventNotificationMessage_UpdateType int32
const (
	EventNotificationMessage_UPDATE_TYPE_UNSPECIFIED      EventNotificationMessage_UpdateType = 0
	EventNotificationMessage_UPDATE_TYPE_CREATED          EventNotificationMessage_UpdateType = 1
	EventNotificationMessage_UPDATE_TYPE_AVAILABLE        EventNotificationMessage_UpdateType = 2
	EventNotificationMessage_UPDATE_TYPE_UPDATED          EventNotificationMessage_UpdateType = 3
	EventNotificationMessage_UPDATE_TYPE_METADATA_UPDATED EventNotificationMessage_UpdateType = 4
	EventNotificationMessage_UPDATE_TYPE_DELETED          EventNotificationMessage_UpdateType = 5
)

func (EventNotificationMessage_UpdateType) Descriptor 

func (EventNotificationMessage_UpdateType) Descriptor() protoreflect.EnumDescriptor

func (EventNotificationMessage_UpdateType) Enum 

func (x EventNotificationMessage_UpdateType) Enum() *EventNotificationMessage_UpdateType

func (EventNotificationMessage_UpdateType) EnumDescriptor deprecated 

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

Deprecated: Use EventNotificationMessage_UpdateType.Descriptor instead.

func (EventNotificationMessage_UpdateType) Number 

func (x EventNotificationMessage_UpdateType) Number() protoreflect.EnumNumber

func (EventNotificationMessage_UpdateType) String 

func (x EventNotificationMessage_UpdateType) String() string

func (EventNotificationMessage_UpdateType) Type 

func (EventNotificationMessage_UpdateType) Type() protoreflect.EnumType

type EventNotificationServiceClient added in v1.0.0 

type EventNotificationServiceClient interface {
	// CreateEventStreamingGroup
	//
	// Creates a new EventStreamingGroup
	CreateEventStreamingGroup(ctx context.Context, in *CreateEventStreamingGroupRequest, opts ...grpc.CallOption) (*CreateEventStreamingGroupResponse, error)
	// GetEventMessageBatch
	//
	// Reads a set of messages from a given stream group
	// 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
	GetEventMessageBatch(ctx context.Context, in *GetEventMessageBatchRequest, opts ...grpc.CallOption) (*GetEventMessageBatchResponse, error)
	// GetEventMessageBatch
	//
	// Reads a set of messages from a given stream group
	// 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
	GetEventMessageBatchStream(ctx context.Context, in *GetEventMessageBatchStreamRequest, opts ...grpc.CallOption) (EventNotificationService_GetEventMessageBatchStreamClient, error)
	// AcknowledgeMessageBatch
	//
	// 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
	//
	// Deletes a existing EventStreamingGroup by ID
	DeleteEventStreamingGroup(ctx context.Context, in *DeleteEventStreamingGroupRequest, opts ...grpc.CallOption) (*DeleteEventStreamingGroupResponse, 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 added in v1.0.0 

func NewEventNotificationServiceClient(cc grpc.ClientConnInterface) EventNotificationServiceClient

type EventNotificationServiceServer added in v1.0.0 

type EventNotificationServiceServer interface {
	// CreateEventStreamingGroup
	//
	// Creates a new EventStreamingGroup
	CreateEventStreamingGroup(context.Context, *CreateEventStreamingGroupRequest) (*CreateEventStreamingGroupResponse, error)
	// GetEventMessageBatch
	//
	// Reads a set of messages from a given stream group
	// 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
	GetEventMessageBatch(context.Context, *GetEventMessageBatchRequest) (*GetEventMessageBatchResponse, error)
	// GetEventMessageBatch
	//
	// Reads a set of messages from a given stream group
	// 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
	GetEventMessageBatchStream(*GetEventMessageBatchStreamRequest, EventNotificationService_GetEventMessageBatchStreamServer) error
	// AcknowledgeMessageBatch
	//
	// 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
	//
	// Deletes a existing EventStreamingGroup by ID
	DeleteEventStreamingGroup(context.Context, *DeleteEventStreamingGroupRequest) (*DeleteEventStreamingGroupResponse, error)
}

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

type EventNotificationService_GetEventMessageBatchStreamClient added in v1.0.0 

type EventNotificationService_GetEventMessageBatchStreamClient interface {
	Recv() (*GetEventMessageBatchStreamResponse, error)
	grpc.ClientStream
}

type EventNotificationService_GetEventMessageBatchStreamServer added in v1.0.0 

type EventNotificationService_GetEventMessageBatchStreamServer interface {
	Send(*GetEventMessageBatchStreamResponse) error
	grpc.ServerStream
}

type EventStreamingGroupHierarchy added in v1.0.0 

type EventStreamingGroupHierarchy struct {
	ProjectId     string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	CollectionId  string `protobuf:"bytes,2,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	ObjectId      string `protobuf:"bytes,3,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	ObjectGroupId string `protobuf:"bytes,4,opt,name=object_group_id,json=objectGroupId,proto3" json:"object_group_id,omitempty"`
	// contains filtered or unexported fields
}

func (*EventStreamingGroupHierarchy) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use EventStreamingGroupHierarchy.ProtoReflect.Descriptor instead.

func (*EventStreamingGroupHierarchy) GetCollectionId added in v1.0.0 

func (x *EventStreamingGroupHierarchy) GetCollectionId() string

func (*EventStreamingGroupHierarchy) GetObjectGroupId added in v1.0.0 

func (x *EventStreamingGroupHierarchy) GetObjectGroupId() string

func (*EventStreamingGroupHierarchy) GetObjectId added in v1.0.0 

func (x *EventStreamingGroupHierarchy) GetObjectId() string

func (*EventStreamingGroupHierarchy) GetProjectId added in v1.0.0 

func (x *EventStreamingGroupHierarchy) GetProjectId() string

func (*EventStreamingGroupHierarchy) ProtoMessage added in v1.0.0 

func (*EventStreamingGroupHierarchy) ProtoMessage()

func (*EventStreamingGroupHierarchy) ProtoReflect added in v1.0.0 

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

func (*EventStreamingGroupHierarchy) Reset added in v1.0.0 

func (x *EventStreamingGroupHierarchy) Reset()

func (*EventStreamingGroupHierarchy) String added in v1.0.0 

func (x *EventStreamingGroupHierarchy) String() string

type EventType added in v0.5.0 

type EventType int32
const (
	EventType_EVENT_TYPE_UNSPECIFIED      EventType = 0
	EventType_EVENT_TYPE_CREATED          EventType = 1
	EventType_EVENT_TYPE_AVAILABLE        EventType = 2
	EventType_EVENT_TYPE_UPDATED          EventType = 3
	EventType_EVENT_TYPE_METADATA_UPDATED EventType = 4
	EventType_EVENT_TYPE_DELETED          EventType = 5
	EventType_EVENT_TYPE_ALL              EventType = 6
)

func (EventType) Descriptor added in v0.5.0 

func (EventType) Descriptor() protoreflect.EnumDescriptor

func (EventType) Enum added in v0.5.0 

func (x EventType) Enum() *EventType

func (EventType) EnumDescriptor deprecated added in v0.5.0 

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

Deprecated: Use EventType.Descriptor instead.

func (EventType) Number added in v0.5.0 

func (x EventType) Number() protoreflect.EnumNumber

func (EventType) String added in v0.5.0 

func (x EventType) String() string

func (EventType) Type added in v0.5.0 

func (EventType) Type() protoreflect.EnumType

type GetEventMessageBatchRequest added in v1.0.0 

type GetEventMessageBatchRequest struct {
	StreamGroupId string `protobuf:"bytes,1,opt,name=stream_group_id,json=streamGroupId,proto3" json:"stream_group_id,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 added in v1.0.0 

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

Deprecated: Use GetEventMessageBatchRequest.ProtoReflect.Descriptor instead.

func (*GetEventMessageBatchRequest) GetBatchSize added in v1.0.0 

func (x *GetEventMessageBatchRequest) GetBatchSize() uint32

func (*GetEventMessageBatchRequest) GetStreamGroupId added in v1.0.0 

func (x *GetEventMessageBatchRequest) GetStreamGroupId() string

func (*GetEventMessageBatchRequest) ProtoMessage added in v1.0.0 

func (*GetEventMessageBatchRequest) ProtoMessage()

func (*GetEventMessageBatchRequest) ProtoReflect added in v1.0.0 

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

func (*GetEventMessageBatchRequest) Reset added in v1.0.0 

func (x *GetEventMessageBatchRequest) Reset()

func (*GetEventMessageBatchRequest) String added in v1.0.0 

func (x *GetEventMessageBatchRequest) String() string

type GetEventMessageBatchResponse added in v1.0.0 

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

func (*GetEventMessageBatchResponse) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use GetEventMessageBatchResponse.ProtoReflect.Descriptor instead.

func (*GetEventMessageBatchResponse) GetMessages added in v1.0.0 

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

func (*GetEventMessageBatchResponse) ProtoMessage added in v1.0.0 

func (*GetEventMessageBatchResponse) ProtoMessage()

func (*GetEventMessageBatchResponse) ProtoReflect added in v1.0.0 

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

func (*GetEventMessageBatchResponse) Reset added in v1.0.0 

func (x *GetEventMessageBatchResponse) Reset()

func (*GetEventMessageBatchResponse) String added in v1.0.0 

func (x *GetEventMessageBatchResponse) String() string

type GetEventMessageBatchStreamRequest added in v1.0.0 

type GetEventMessageBatchStreamRequest struct {
	StreamGroupId string `protobuf:"bytes,1,opt,name=stream_group_id,json=streamGroupId,proto3" json:"stream_group_id,omitempty"`
	BatchSize     uint32 `protobuf:"varint,2,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEventMessageBatchStreamRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use GetEventMessageBatchStreamRequest.ProtoReflect.Descriptor instead.

func (*GetEventMessageBatchStreamRequest) GetBatchSize added in v1.0.0 

func (x *GetEventMessageBatchStreamRequest) GetBatchSize() uint32

func (*GetEventMessageBatchStreamRequest) GetStreamGroupId added in v1.0.0 

func (x *GetEventMessageBatchStreamRequest) GetStreamGroupId() string

func (*GetEventMessageBatchStreamRequest) ProtoMessage added in v1.0.0 

func (*GetEventMessageBatchStreamRequest) ProtoMessage()

func (*GetEventMessageBatchStreamRequest) ProtoReflect added in v1.0.0 

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

func (*GetEventMessageBatchStreamRequest) Reset added in v1.0.0 

func (x *GetEventMessageBatchStreamRequest) Reset()

func (*GetEventMessageBatchStreamRequest) String added in v1.0.0 

func (x *GetEventMessageBatchStreamRequest) String() string

type GetEventMessageBatchStreamResponse added in v1.0.0 

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

func (*GetEventMessageBatchStreamResponse) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use GetEventMessageBatchStreamResponse.ProtoReflect.Descriptor instead.

func (*GetEventMessageBatchStreamResponse) GetMessages added in v1.0.0 

func (x *GetEventMessageBatchStreamResponse) GetMessages() []*EventNotificationMessage

func (*GetEventMessageBatchStreamResponse) ProtoMessage added in v1.0.0 

func (*GetEventMessageBatchStreamResponse) ProtoMessage()

func (*GetEventMessageBatchStreamResponse) ProtoReflect added in v1.0.0 

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

func (*GetEventMessageBatchStreamResponse) Reset added in v1.0.0 

func (x *GetEventMessageBatchStreamResponse) Reset()

func (*GetEventMessageBatchStreamResponse) String added in v1.0.0 

func (x *GetEventMessageBatchStreamResponse) String() string

type NotficationStreamAck 

type NotficationStreamAck struct {
	AckChunkId []string `protobuf:"bytes,1,rep,name=ack_chunk_id,json=ackChunkId,proto3" json:"ack_chunk_id,omitempty"`
	// contains filtered or unexported fields
}

func (*NotficationStreamAck) Descriptor deprecated 

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

Deprecated: Use NotficationStreamAck.ProtoReflect.Descriptor instead.

func (*NotficationStreamAck) GetAckChunkId 

func (x *NotficationStreamAck) GetAckChunkId() []string

func (*NotficationStreamAck) ProtoMessage 

func (*NotficationStreamAck) ProtoMessage()

func (*NotficationStreamAck) ProtoReflect 

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

func (*NotficationStreamAck) Reset 

func (x *NotficationStreamAck) Reset()

func (*NotficationStreamAck) String 

func (x *NotficationStreamAck) String() string

type NotificationStreamGroupRequest 

type NotificationStreamGroupRequest struct {

	// Types that are assignable to StreamAction:
	//	*NotificationStreamGroupRequest_Init
	//	*NotificationStreamGroupRequest_Ack
	StreamAction isNotificationStreamGroupRequest_StreamAction `protobuf_oneof:"stream_action"`
	Close        bool                                          `protobuf:"varint,3,opt,name=close,proto3" json:"close,omitempty"`
	// contains filtered or unexported fields
}

func (*NotificationStreamGroupRequest) Descriptor deprecated 

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

Deprecated: Use NotificationStreamGroupRequest.ProtoReflect.Descriptor instead.

func (*NotificationStreamGroupRequest) GetAck 

func (x *NotificationStreamGroupRequest) GetAck() *NotficationStreamAck

func (*NotificationStreamGroupRequest) GetClose 

func (x *NotificationStreamGroupRequest) GetClose() bool

func (*NotificationStreamGroupRequest) GetInit 

func (x *NotificationStreamGroupRequest) GetInit() *NotificationStreamInit

func (*NotificationStreamGroupRequest) GetStreamAction 

func (m *NotificationStreamGroupRequest) GetStreamAction() isNotificationStreamGroupRequest_StreamAction

func (*NotificationStreamGroupRequest) ProtoMessage 

func (*NotificationStreamGroupRequest) ProtoMessage()

func (*NotificationStreamGroupRequest) ProtoReflect 

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

func (*NotificationStreamGroupRequest) Reset 

func (x *NotificationStreamGroupRequest) Reset()

func (*NotificationStreamGroupRequest) String 

func (x *NotificationStreamGroupRequest) String() string

type NotificationStreamGroupRequest_Ack 

type NotificationStreamGroupRequest_Ack struct {
	Ack *NotficationStreamAck `protobuf:"bytes,2,opt,name=ack,proto3,oneof"`
}

type NotificationStreamGroupRequest_Init 

type NotificationStreamGroupRequest_Init struct {
	Init *NotificationStreamInit `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

type NotificationStreamGroupResponse 

type NotificationStreamGroupResponse struct {
	Notification []*NotificationStreamResponse `protobuf:"bytes,1,rep,name=notification,proto3" json:"notification,omitempty"`
	AckChunkId   string                        `protobuf:"bytes,2,opt,name=ack_chunk_id,json=ackChunkId,proto3" json:"ack_chunk_id,omitempty"`
	// contains filtered or unexported fields
}

func (*NotificationStreamGroupResponse) Descriptor deprecated 

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

Deprecated: Use NotificationStreamGroupResponse.ProtoReflect.Descriptor instead.

func (*NotificationStreamGroupResponse) GetAckChunkId 

func (x *NotificationStreamGroupResponse) GetAckChunkId() string

func (*NotificationStreamGroupResponse) GetNotification 

func (x *NotificationStreamGroupResponse) GetNotification() []*NotificationStreamResponse

func (*NotificationStreamGroupResponse) ProtoMessage 

func (*NotificationStreamGroupResponse) ProtoMessage()

func (*NotificationStreamGroupResponse) ProtoReflect 

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

func (*NotificationStreamGroupResponse) Reset 

func (x *NotificationStreamGroupResponse) Reset()

func (*NotificationStreamGroupResponse) String 

func (x *NotificationStreamGroupResponse) String() string

type NotificationStreamInit 

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

func (*NotificationStreamInit) Descriptor deprecated 

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

Deprecated: Use NotificationStreamInit.ProtoReflect.Descriptor instead.

func (*NotificationStreamInit) GetStreamGroupId 

func (x *NotificationStreamInit) GetStreamGroupId() string

func (*NotificationStreamInit) ProtoMessage 

func (*NotificationStreamInit) ProtoMessage()

func (*NotificationStreamInit) ProtoReflect 

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

func (*NotificationStreamInit) Reset 

func (x *NotificationStreamInit) Reset()

func (*NotificationStreamInit) String 

func (x *NotificationStreamInit) String() string

type NotificationStreamResponse 

type NotificationStreamResponse struct {
	Message   *EventNotificationMessage `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Sequence  uint64                    `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"`
	Timestamp *timestamppb.Timestamp    `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*NotificationStreamResponse) Descriptor deprecated 

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

Deprecated: Use NotificationStreamResponse.ProtoReflect.Descriptor instead.

func (*NotificationStreamResponse) GetMessage 

func (x *NotificationStreamResponse) GetMessage() *EventNotificationMessage

func (*NotificationStreamResponse) GetSequence 

func (x *NotificationStreamResponse) GetSequence() uint64

func (*NotificationStreamResponse) GetTimestamp 

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

func (*NotificationStreamResponse) ProtoMessage 

func (*NotificationStreamResponse) ProtoMessage()

func (*NotificationStreamResponse) ProtoReflect 

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

func (*NotificationStreamResponse) Reset 

func (x *NotificationStreamResponse) Reset()

func (*NotificationStreamResponse) String 

func (x *NotificationStreamResponse) String() string

type Reply added in v1.0.0 

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 added in v1.0.0 

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

Deprecated: Use Reply.ProtoReflect.Descriptor instead.

func (*Reply) GetHmac added in v1.0.0 

func (x *Reply) GetHmac() string

func (*Reply) GetReply added in v1.0.0 

func (x *Reply) GetReply() string

func (*Reply) GetSalt added in v1.0.0 

func (x *Reply) GetSalt() string

func (*Reply) ProtoMessage added in v1.0.0 

func (*Reply) ProtoMessage()

func (*Reply) ProtoReflect added in v1.0.0 

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

func (*Reply) Reset added in v1.0.0 

func (x *Reply) Reset()

func (*Reply) String added in v1.0.0 

func (x *Reply) 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 added in v1.0.0 

type UnimplementedEventNotificationServiceServer struct {
}

UnimplementedEventNotificationServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedEventNotificationServiceServer) AcknowledgeMessageBatch added in v1.0.0 

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

func (UnimplementedEventNotificationServiceServer) CreateEventStreamingGroup added in v1.0.0 

func (UnimplementedEventNotificationServiceServer) CreateEventStreamingGroup(context.Context, *CreateEventStreamingGroupRequest) (*CreateEventStreamingGroupResponse, error)

func (UnimplementedEventNotificationServiceServer) DeleteEventStreamingGroup added in v1.0.0 

func (UnimplementedEventNotificationServiceServer) DeleteEventStreamingGroup(context.Context, *DeleteEventStreamingGroupRequest) (*DeleteEventStreamingGroupResponse, error)

func (UnimplementedEventNotificationServiceServer) GetEventMessageBatch added in v1.0.0 

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

func (UnimplementedEventNotificationServiceServer) GetEventMessageBatchStream added in v1.0.0 

func (UnimplementedEventNotificationServiceServer) GetEventMessageBatchStream(*GetEventMessageBatchStreamRequest, EventNotificationService_GetEventMessageBatchStreamServer) error

type UnsafeEventNotificationServiceServer added in v1.0.0 

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.

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.