v1

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Feb 15, 2022 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

Package v1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	CreateEventStreamingGroupRequest_EventResources_name = map[int32]string{
		0: "EVENT_RESOURCES_UNSPECIFIED",
		1: "EVENT_RESOURCES_PROJECT_RESOURCE",
		2: "EVENT_RESOURCES_DATASET_RESOURCE",
		3: "EVENT_RESOURCES_DATASET_VERSION_RESOURCE",
		4: "EVENT_RESOURCES_OBJECT_GROUP_RESOURCE",
		5: "EVENT_RESOURCES_ALL_RESOURCE",
	}
	CreateEventStreamingGroupRequest_EventResources_value = map[string]int32{
		"EVENT_RESOURCES_UNSPECIFIED":              0,
		"EVENT_RESOURCES_PROJECT_RESOURCE":         1,
		"EVENT_RESOURCES_DATASET_RESOURCE":         2,
		"EVENT_RESOURCES_DATASET_VERSION_RESOURCE": 3,
		"EVENT_RESOURCES_OBJECT_GROUP_RESOURCE":    4,
		"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 File_sciobjsdb_api_notification_services_v1_notification_service_models_proto protoreflect.FileDescriptor
View Source 
var File_sciobjsdb_api_notification_services_v1_notification_service_proto protoreflect.FileDescriptor
View Source 
var UpdateNotificationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "sciobjsdb.api.notification.services.v1.UpdateNotificationService",
	HandlerType: (*UpdateNotificationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateEventStreamingGroup",
			Handler:    _UpdateNotificationService_CreateEventStreamingGroup_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "NotificationStreamGroup",
			Handler:       _UpdateNotificationService_NotificationStreamGroup_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "sciobjsdb/api/notification/services/v1/notification_service.proto",
}

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

Functions

func RegisterUpdateNotificationServiceHandler 

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

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

func RegisterUpdateNotificationServiceHandlerClient 

func RegisterUpdateNotificationServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client UpdateNotificationServiceClient) error

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

func RegisterUpdateNotificationServiceHandlerFromEndpoint 

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

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

func RegisterUpdateNotificationServiceHandlerServer 

func RegisterUpdateNotificationServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server UpdateNotificationServiceServer) error

RegisterUpdateNotificationServiceHandlerServer registers the http handlers for service UpdateNotificationService to "mux". UnaryRPC :call UpdateNotificationServiceServer 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 RegisterUpdateNotificationServiceHandlerFromEndpoint instead.

func RegisterUpdateNotificationServiceServer 

func RegisterUpdateNotificationServiceServer(s grpc.ServiceRegistrar, srv UpdateNotificationServiceServer)

Types

type CreateEventStreamingGroupRequest 

type CreateEventStreamingGroupRequest struct {
	Resource           CreateEventStreamingGroupRequest_EventResources `` /* 162-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) GetIncludeSubresource 

func (x *CreateEventStreamingGroupRequest) GetIncludeSubresource() bool

func (*CreateEventStreamingGroupRequest) GetResource 

func (x *CreateEventStreamingGroupRequest) GetResource() CreateEventStreamingGroupRequest_EventResources

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_PROJECT_RESOURCE         CreateEventStreamingGroupRequest_EventResources = 1
	CreateEventStreamingGroupRequest_EVENT_RESOURCES_DATASET_RESOURCE         CreateEventStreamingGroupRequest_EventResources = 2
	CreateEventStreamingGroupRequest_EVENT_RESOURCES_DATASET_VERSION_RESOURCE CreateEventStreamingGroupRequest_EventResources = 3
	CreateEventStreamingGroupRequest_EVENT_RESOURCES_OBJECT_GROUP_RESOURCE    CreateEventStreamingGroupRequest_EventResources = 4
	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 EventNotificationMessage 

type EventNotificationMessage struct {
	Resource    v1.Resource                         `protobuf:"varint,1,opt,name=resource,proto3,enum=sciobjsdb.api.storage.models.v1.Resource" json:"resource,omitempty"`
	ResourceId  string                              `protobuf:"bytes,2,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	UpdatedType EventNotificationMessage_UpdateType `` /* 175-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) GetResource 

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

func (*EventNotificationMessage) GetResourceId 

func (x *EventNotificationMessage) GetResourceId() string

func (*EventNotificationMessage) GetUpdatedType 

func (x *EventNotificationMessage) GetUpdatedType() EventNotificationMessage_UpdateType

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_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 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 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 UnimplementedUpdateNotificationServiceServer 

type UnimplementedUpdateNotificationServiceServer struct {
}

UnimplementedUpdateNotificationServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedUpdateNotificationServiceServer) CreateEventStreamingGroup 

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

func (UnimplementedUpdateNotificationServiceServer) NotificationStreamGroup 

func (UnimplementedUpdateNotificationServiceServer) NotificationStreamGroup(UpdateNotificationService_NotificationStreamGroupServer) error

type UnsafeUpdateNotificationServiceServer 

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

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

type UpdateNotificationServiceClient 

type UpdateNotificationServiceClient interface {
	CreateEventStreamingGroup(ctx context.Context, in *CreateEventStreamingGroupRequest, opts ...grpc.CallOption) (*CreateEventStreamingGroupResponse, error)
	NotificationStreamGroup(ctx context.Context, opts ...grpc.CallOption) (UpdateNotificationService_NotificationStreamGroupClient, error)
}

UpdateNotificationServiceClient is the client API for UpdateNotificationService 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 NewUpdateNotificationServiceClient 

func NewUpdateNotificationServiceClient(cc grpc.ClientConnInterface) UpdateNotificationServiceClient

type UpdateNotificationServiceServer 

type UpdateNotificationServiceServer interface {
	CreateEventStreamingGroup(context.Context, *CreateEventStreamingGroupRequest) (*CreateEventStreamingGroupResponse, error)
	NotificationStreamGroup(UpdateNotificationService_NotificationStreamGroupServer) error
}

UpdateNotificationServiceServer is the server API for UpdateNotificationService service. All implementations should embed UnimplementedUpdateNotificationServiceServer for forward compatibility

type UpdateNotificationService_NotificationStreamGroupClient 

type UpdateNotificationService_NotificationStreamGroupClient interface {
	Send(*NotificationStreamGroupRequest) error
	Recv() (*NotificationStreamGroupResponse, error)
	grpc.ClientStream
}

type UpdateNotificationService_NotificationStreamGroupServer 

type UpdateNotificationService_NotificationStreamGroupServer interface {
	Send(*NotificationStreamGroupResponse) error
	Recv() (*NotificationStreamGroupRequest, error)
	grpc.ServerStream
}

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.