Documentation ¶
Index ¶
- Variables
- func RegisterNotificationsServiceServer(s grpc.ServiceRegistrar, srv NotificationsServiceServer)
- type ListNotificationsRequest
- func (*ListNotificationsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListNotificationsRequest) GetEntityRef() *v1.GenericRef
- func (x *ListNotificationsRequest) GetExternalUserId() string
- func (x *ListNotificationsRequest) GetOffsetTime() *timestamppb.Timestamp
- func (x *ListNotificationsRequest) GetPageSize() int32
- func (x *ListNotificationsRequest) GetPageToken() string
- func (*ListNotificationsRequest) ProtoMessage()
- func (x *ListNotificationsRequest) ProtoReflect() protoreflect.Message
- func (x *ListNotificationsRequest) Reset()
- func (x *ListNotificationsRequest) String() string
- type ListNotificationsResponse
- func (*ListNotificationsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListNotificationsResponse) GetNextPageToken() string
- func (x *ListNotificationsResponse) GetNotifications() []*UserNotification
- func (*ListNotificationsResponse) ProtoMessage()
- func (x *ListNotificationsResponse) ProtoReflect() protoreflect.Message
- func (x *ListNotificationsResponse) Reset()
- func (x *ListNotificationsResponse) String() string
- type ListSubscriptionsRequest
- func (*ListSubscriptionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListSubscriptionsRequest) GetExternalUserId() string
- func (*ListSubscriptionsRequest) ProtoMessage()
- func (x *ListSubscriptionsRequest) ProtoReflect() protoreflect.Message
- func (x *ListSubscriptionsRequest) Reset()
- func (x *ListSubscriptionsRequest) String() string
- type ListSubscriptionsResponse
- func (*ListSubscriptionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListSubscriptionsResponse) GetSubscriptions() []*Subscription
- func (*ListSubscriptionsResponse) ProtoMessage()
- func (x *ListSubscriptionsResponse) ProtoReflect() protoreflect.Message
- func (x *ListSubscriptionsResponse) Reset()
- func (x *ListSubscriptionsResponse) String() string
- type Notification
- func (*Notification) Descriptor() ([]byte, []int)deprecated
- func (x *Notification) GetAuditTrailEntry() *v1.AuditTrailEntry
- func (x *Notification) GetComment() *v1.Comment
- func (x *Notification) GetCreateTime() *timestamppb.Timestamp
- func (m *Notification) GetNotification() isNotification_Notification
- func (*Notification) ProtoMessage()
- func (x *Notification) ProtoReflect() protoreflect.Message
- func (x *Notification) Reset()
- func (x *Notification) String() string
- type Notification_AuditTrailEntry
- type Notification_Comment
- type NotificationsServiceClient
- type NotificationsServiceServer
- type NotificationsService_ReceiveNotificationsClient
- type NotificationsService_ReceiveNotificationsServer
- type NotifySubscribersRequest
- func (*NotifySubscribersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NotifySubscribersRequest) GetEntityRef() *v1.GenericRef
- func (x *NotifySubscribersRequest) GetNotification() *Notification
- func (*NotifySubscribersRequest) ProtoMessage()
- func (x *NotifySubscribersRequest) ProtoReflect() protoreflect.Message
- func (x *NotifySubscribersRequest) Reset()
- func (x *NotifySubscribersRequest) String() string
- type NotifySubscribersResponse
- type NotifyUsersRequest
- func (*NotifyUsersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NotifyUsersRequest) GetExternalUserIds() []string
- func (x *NotifyUsersRequest) GetNotification() *Notification
- func (*NotifyUsersRequest) ProtoMessage()
- func (x *NotifyUsersRequest) ProtoReflect() protoreflect.Message
- func (x *NotifyUsersRequest) Reset()
- func (x *NotifyUsersRequest) String() string
- type NotifyUsersResponse
- type ReceiveNotificationsRequest
- type ReceiveNotificationsResponse
- func (*ReceiveNotificationsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReceiveNotificationsResponse) GetNotification() *UserNotification
- func (*ReceiveNotificationsResponse) ProtoMessage()
- func (x *ReceiveNotificationsResponse) ProtoReflect() protoreflect.Message
- func (x *ReceiveNotificationsResponse) Reset()
- func (x *ReceiveNotificationsResponse) String() string
- type SubscribeNotificationsRequest
- func (*SubscribeNotificationsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeNotificationsRequest) GetEntityRef() *v1.GenericRef
- func (x *SubscribeNotificationsRequest) GetExternalUserId() string
- func (*SubscribeNotificationsRequest) ProtoMessage()
- func (x *SubscribeNotificationsRequest) ProtoReflect() protoreflect.Message
- func (x *SubscribeNotificationsRequest) Reset()
- func (x *SubscribeNotificationsRequest) String() string
- type SubscribeNotificationsResponse
- func (*SubscribeNotificationsResponse) Descriptor() ([]byte, []int)deprecated
- func (*SubscribeNotificationsResponse) ProtoMessage()
- func (x *SubscribeNotificationsResponse) ProtoReflect() protoreflect.Message
- func (x *SubscribeNotificationsResponse) Reset()
- func (x *SubscribeNotificationsResponse) String() string
- type Subscription
- func (*Subscription) Descriptor() ([]byte, []int)deprecated
- func (x *Subscription) GetEntityRef() *v1.GenericRef
- func (x *Subscription) GetExternalUserId() string
- func (*Subscription) ProtoMessage()
- func (x *Subscription) ProtoReflect() protoreflect.Message
- func (x *Subscription) Reset()
- func (x *Subscription) String() string
- type UnSubscribeNotificationsRequest
- func (*UnSubscribeNotificationsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UnSubscribeNotificationsRequest) GetEntityRef() *v1.GenericRef
- func (x *UnSubscribeNotificationsRequest) GetExternalUserId() string
- func (*UnSubscribeNotificationsRequest) ProtoMessage()
- func (x *UnSubscribeNotificationsRequest) ProtoReflect() protoreflect.Message
- func (x *UnSubscribeNotificationsRequest) Reset()
- func (x *UnSubscribeNotificationsRequest) String() string
- type UnSubscribeNotificationsResponse
- func (*UnSubscribeNotificationsResponse) Descriptor() ([]byte, []int)deprecated
- func (*UnSubscribeNotificationsResponse) ProtoMessage()
- func (x *UnSubscribeNotificationsResponse) ProtoReflect() protoreflect.Message
- func (x *UnSubscribeNotificationsResponse) Reset()
- func (x *UnSubscribeNotificationsResponse) String() string
- type UnimplementedNotificationsServiceServer
- func (UnimplementedNotificationsServiceServer) ListNotifications(context.Context, *ListNotificationsRequest) (*ListNotificationsResponse, error)
- func (UnimplementedNotificationsServiceServer) ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)
- func (UnimplementedNotificationsServiceServer) NotifySubscribers(context.Context, *NotifySubscribersRequest) (*NotifySubscribersResponse, error)
- func (UnimplementedNotificationsServiceServer) NotifyUsers(context.Context, *NotifyUsersRequest) (*NotifyUsersResponse, error)
- func (UnimplementedNotificationsServiceServer) ReceiveNotifications(*ReceiveNotificationsRequest, NotificationsService_ReceiveNotificationsServer) error
- func (UnimplementedNotificationsServiceServer) SubscribeNotifications(context.Context, *SubscribeNotificationsRequest) (*SubscribeNotificationsResponse, error)
- func (UnimplementedNotificationsServiceServer) UnSubscribeNotifications(context.Context, *UnSubscribeNotificationsRequest) (*UnSubscribeNotificationsResponse, error)
- type UnsafeNotificationsServiceServer
- type UserNotification
- func (*UserNotification) Descriptor() ([]byte, []int)deprecated
- func (x *UserNotification) GetExternalUserId() string
- func (x *UserNotification) GetId() string
- func (x *UserNotification) GetMailSentTime() *timestamppb.Timestamp
- func (x *UserNotification) GetNotification() *Notification
- func (x *UserNotification) GetReason() string
- func (*UserNotification) ProtoMessage()
- func (x *UserNotification) ProtoReflect() protoreflect.Message
- func (x *UserNotification) Reset()
- func (x *UserNotification) String() string
Constants ¶
This section is empty.
Variables ¶
var File_strmprivacy_api_notifications_v1_notifications_v1_proto protoreflect.FileDescriptor
var NotificationsService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "strmprivacy.api.notifications.v1.NotificationsService", HandlerType: (*NotificationsServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "SubscribeNotifications", Handler: _NotificationsService_SubscribeNotifications_Handler, }, { MethodName: "UnSubscribeNotifications", Handler: _NotificationsService_UnSubscribeNotifications_Handler, }, { MethodName: "ListSubscriptions", Handler: _NotificationsService_ListSubscriptions_Handler, }, { MethodName: "NotifySubscribers", Handler: _NotificationsService_NotifySubscribers_Handler, }, { MethodName: "NotifyUsers", Handler: _NotificationsService_NotifyUsers_Handler, }, { MethodName: "ListNotifications", Handler: _NotificationsService_ListNotifications_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "ReceiveNotifications", Handler: _NotificationsService_ReceiveNotifications_Handler, ServerStreams: true, }, }, Metadata: "strmprivacy/api/notifications/v1/notifications_v1.proto", }
NotificationsService_ServiceDesc is the grpc.ServiceDesc for NotificationsService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterNotificationsServiceServer ¶
func RegisterNotificationsServiceServer(s grpc.ServiceRegistrar, srv NotificationsServiceServer)
Types ¶
type ListNotificationsRequest ¶
type ListNotificationsRequest struct { // The user for which to list notifications. ExternalUserId string `protobuf:"bytes,1,opt,name=external_user_id,json=externalUserId,proto3" json:"external_user_id,omitempty"` // The entity for which to filter the notifications. EntityRef *v1.GenericRef `protobuf:"bytes,2,opt,name=entity_ref,json=entityRef,proto3" json:"entity_ref,omitempty"` PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // Timestamp from which to list notifications OffsetTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=offset_time,json=offsetTime,proto3" json:"offset_time,omitempty"` // contains filtered or unexported fields }
func (*ListNotificationsRequest) Descriptor
deprecated
func (*ListNotificationsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListNotificationsRequest.ProtoReflect.Descriptor instead.
func (*ListNotificationsRequest) GetEntityRef ¶
func (x *ListNotificationsRequest) GetEntityRef() *v1.GenericRef
func (*ListNotificationsRequest) GetExternalUserId ¶
func (x *ListNotificationsRequest) GetExternalUserId() string
func (*ListNotificationsRequest) GetOffsetTime ¶ added in v3.5.0
func (x *ListNotificationsRequest) GetOffsetTime() *timestamppb.Timestamp
func (*ListNotificationsRequest) GetPageSize ¶
func (x *ListNotificationsRequest) GetPageSize() int32
func (*ListNotificationsRequest) GetPageToken ¶
func (x *ListNotificationsRequest) GetPageToken() string
func (*ListNotificationsRequest) ProtoMessage ¶
func (*ListNotificationsRequest) ProtoMessage()
func (*ListNotificationsRequest) ProtoReflect ¶
func (x *ListNotificationsRequest) ProtoReflect() protoreflect.Message
func (*ListNotificationsRequest) Reset ¶
func (x *ListNotificationsRequest) Reset()
func (*ListNotificationsRequest) String ¶
func (x *ListNotificationsRequest) String() string
type ListNotificationsResponse ¶
type ListNotificationsResponse struct { Notifications []*UserNotification `protobuf:"bytes,1,rep,name=notifications,proto3" json:"notifications,omitempty"` NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
func (*ListNotificationsResponse) Descriptor
deprecated
func (*ListNotificationsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListNotificationsResponse.ProtoReflect.Descriptor instead.
func (*ListNotificationsResponse) GetNextPageToken ¶
func (x *ListNotificationsResponse) GetNextPageToken() string
func (*ListNotificationsResponse) GetNotifications ¶
func (x *ListNotificationsResponse) GetNotifications() []*UserNotification
func (*ListNotificationsResponse) ProtoMessage ¶
func (*ListNotificationsResponse) ProtoMessage()
func (*ListNotificationsResponse) ProtoReflect ¶
func (x *ListNotificationsResponse) ProtoReflect() protoreflect.Message
func (*ListNotificationsResponse) Reset ¶
func (x *ListNotificationsResponse) Reset()
func (*ListNotificationsResponse) String ¶
func (x *ListNotificationsResponse) String() string
type ListSubscriptionsRequest ¶
type ListSubscriptionsRequest struct { // The user for which to list subscriptions. // ignored unless it's a system call ExternalUserId string `protobuf:"bytes,1,opt,name=external_user_id,json=externalUserId,proto3" json:"external_user_id,omitempty"` // contains filtered or unexported fields }
func (*ListSubscriptionsRequest) Descriptor
deprecated
func (*ListSubscriptionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListSubscriptionsRequest.ProtoReflect.Descriptor instead.
func (*ListSubscriptionsRequest) GetExternalUserId ¶
func (x *ListSubscriptionsRequest) GetExternalUserId() string
func (*ListSubscriptionsRequest) ProtoMessage ¶
func (*ListSubscriptionsRequest) ProtoMessage()
func (*ListSubscriptionsRequest) ProtoReflect ¶
func (x *ListSubscriptionsRequest) ProtoReflect() protoreflect.Message
func (*ListSubscriptionsRequest) Reset ¶
func (x *ListSubscriptionsRequest) Reset()
func (*ListSubscriptionsRequest) String ¶
func (x *ListSubscriptionsRequest) String() string
type ListSubscriptionsResponse ¶
type ListSubscriptionsResponse struct { Subscriptions []*Subscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"` // contains filtered or unexported fields }
func (*ListSubscriptionsResponse) Descriptor
deprecated
func (*ListSubscriptionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListSubscriptionsResponse.ProtoReflect.Descriptor instead.
func (*ListSubscriptionsResponse) GetSubscriptions ¶
func (x *ListSubscriptionsResponse) GetSubscriptions() []*Subscription
func (*ListSubscriptionsResponse) ProtoMessage ¶
func (*ListSubscriptionsResponse) ProtoMessage()
func (*ListSubscriptionsResponse) ProtoReflect ¶
func (x *ListSubscriptionsResponse) ProtoReflect() protoreflect.Message
func (*ListSubscriptionsResponse) Reset ¶
func (x *ListSubscriptionsResponse) Reset()
func (*ListSubscriptionsResponse) String ¶
func (x *ListSubscriptionsResponse) String() string
type Notification ¶
type Notification struct { CreateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // Types that are assignable to Notification: // // *Notification_Comment // *Notification_AuditTrailEntry Notification isNotification_Notification `protobuf_oneof:"notification"` // contains filtered or unexported fields }
func (*Notification) Descriptor
deprecated
func (*Notification) Descriptor() ([]byte, []int)
Deprecated: Use Notification.ProtoReflect.Descriptor instead.
func (*Notification) GetAuditTrailEntry ¶
func (x *Notification) GetAuditTrailEntry() *v1.AuditTrailEntry
func (*Notification) GetComment ¶
func (x *Notification) GetComment() *v1.Comment
func (*Notification) GetCreateTime ¶
func (x *Notification) GetCreateTime() *timestamppb.Timestamp
func (*Notification) GetNotification ¶
func (m *Notification) GetNotification() isNotification_Notification
func (*Notification) ProtoMessage ¶
func (*Notification) ProtoMessage()
func (*Notification) ProtoReflect ¶
func (x *Notification) ProtoReflect() protoreflect.Message
func (*Notification) Reset ¶
func (x *Notification) Reset()
func (*Notification) String ¶
func (x *Notification) String() string
type Notification_AuditTrailEntry ¶
type Notification_AuditTrailEntry struct {
AuditTrailEntry *v1.AuditTrailEntry `protobuf:"bytes,3,opt,name=audit_trail_entry,json=auditTrailEntry,proto3,oneof"`
}
type Notification_Comment ¶
type NotificationsServiceClient ¶
type NotificationsServiceClient interface { // Tell the notification service that the given user should receive notifications about the given entity. SubscribeNotifications(ctx context.Context, in *SubscribeNotificationsRequest, opts ...grpc.CallOption) (*SubscribeNotificationsResponse, error) // Tell the notification service that the given user should *not* receive notifications about the given entity. UnSubscribeNotifications(ctx context.Context, in *UnSubscribeNotificationsRequest, opts ...grpc.CallOption) (*UnSubscribeNotificationsResponse, error) // List the subscriptions of a certain user. ListSubscriptions(ctx context.Context, in *ListSubscriptionsRequest, opts ...grpc.CallOption) (*ListSubscriptionsResponse, error) // Called by systems (schema-registry for instance) that want to notify subscribed users about something. NotifySubscribers(ctx context.Context, in *NotifySubscribersRequest, opts ...grpc.CallOption) (*NotifySubscribersResponse, error) // Notify specific users directly, regardless of their subscriptions. NotifyUsers(ctx context.Context, in *NotifyUsersRequest, opts ...grpc.CallOption) (*NotifyUsersResponse, error) // Called by the user's browser to receive notifications. ReceiveNotifications(ctx context.Context, in *ReceiveNotificationsRequest, opts ...grpc.CallOption) (NotificationsService_ReceiveNotificationsClient, error) // List notifications for a user. ListNotifications(ctx context.Context, in *ListNotificationsRequest, opts ...grpc.CallOption) (*ListNotificationsResponse, error) }
NotificationsServiceClient is the client API for NotificationsService 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 NewNotificationsServiceClient ¶
func NewNotificationsServiceClient(cc grpc.ClientConnInterface) NotificationsServiceClient
type NotificationsServiceServer ¶
type NotificationsServiceServer interface { // Tell the notification service that the given user should receive notifications about the given entity. SubscribeNotifications(context.Context, *SubscribeNotificationsRequest) (*SubscribeNotificationsResponse, error) // Tell the notification service that the given user should *not* receive notifications about the given entity. UnSubscribeNotifications(context.Context, *UnSubscribeNotificationsRequest) (*UnSubscribeNotificationsResponse, error) // List the subscriptions of a certain user. ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error) // Called by systems (schema-registry for instance) that want to notify subscribed users about something. NotifySubscribers(context.Context, *NotifySubscribersRequest) (*NotifySubscribersResponse, error) // Notify specific users directly, regardless of their subscriptions. NotifyUsers(context.Context, *NotifyUsersRequest) (*NotifyUsersResponse, error) // Called by the user's browser to receive notifications. ReceiveNotifications(*ReceiveNotificationsRequest, NotificationsService_ReceiveNotificationsServer) error // List notifications for a user. ListNotifications(context.Context, *ListNotificationsRequest) (*ListNotificationsResponse, error) }
NotificationsServiceServer is the server API for NotificationsService service. All implementations should embed UnimplementedNotificationsServiceServer for forward compatibility
type NotificationsService_ReceiveNotificationsClient ¶
type NotificationsService_ReceiveNotificationsClient interface { Recv() (*ReceiveNotificationsResponse, error) grpc.ClientStream }
type NotificationsService_ReceiveNotificationsServer ¶
type NotificationsService_ReceiveNotificationsServer interface { Send(*ReceiveNotificationsResponse) error grpc.ServerStream }
type NotifySubscribersRequest ¶
type NotifySubscribersRequest struct { // The entity that the notification is about EntityRef *v1.GenericRef `protobuf:"bytes,1,opt,name=entity_ref,json=entityRef,proto3" json:"entity_ref,omitempty"` Notification *Notification `protobuf:"bytes,2,opt,name=notification,proto3" json:"notification,omitempty"` // contains filtered or unexported fields }
Users subscribed to notifications about the given entity will receive the given notification.
func (*NotifySubscribersRequest) Descriptor
deprecated
func (*NotifySubscribersRequest) Descriptor() ([]byte, []int)
Deprecated: Use NotifySubscribersRequest.ProtoReflect.Descriptor instead.
func (*NotifySubscribersRequest) GetEntityRef ¶
func (x *NotifySubscribersRequest) GetEntityRef() *v1.GenericRef
func (*NotifySubscribersRequest) GetNotification ¶
func (x *NotifySubscribersRequest) GetNotification() *Notification
func (*NotifySubscribersRequest) ProtoMessage ¶
func (*NotifySubscribersRequest) ProtoMessage()
func (*NotifySubscribersRequest) ProtoReflect ¶
func (x *NotifySubscribersRequest) ProtoReflect() protoreflect.Message
func (*NotifySubscribersRequest) Reset ¶
func (x *NotifySubscribersRequest) Reset()
func (*NotifySubscribersRequest) String ¶
func (x *NotifySubscribersRequest) String() string
type NotifySubscribersResponse ¶
type NotifySubscribersResponse struct {
// contains filtered or unexported fields
}
func (*NotifySubscribersResponse) Descriptor
deprecated
func (*NotifySubscribersResponse) Descriptor() ([]byte, []int)
Deprecated: Use NotifySubscribersResponse.ProtoReflect.Descriptor instead.
func (*NotifySubscribersResponse) ProtoMessage ¶
func (*NotifySubscribersResponse) ProtoMessage()
func (*NotifySubscribersResponse) ProtoReflect ¶
func (x *NotifySubscribersResponse) ProtoReflect() protoreflect.Message
func (*NotifySubscribersResponse) Reset ¶
func (x *NotifySubscribersResponse) Reset()
func (*NotifySubscribersResponse) String ¶
func (x *NotifySubscribersResponse) String() string
type NotifyUsersRequest ¶ added in v3.5.0
type NotifyUsersRequest struct { ExternalUserIds []string `protobuf:"bytes,1,rep,name=external_user_ids,json=externalUserIds,proto3" json:"external_user_ids,omitempty"` Notification *Notification `protobuf:"bytes,2,opt,name=notification,proto3" json:"notification,omitempty"` // contains filtered or unexported fields }
func (*NotifyUsersRequest) Descriptor
deprecated
added in
v3.5.0
func (*NotifyUsersRequest) Descriptor() ([]byte, []int)
Deprecated: Use NotifyUsersRequest.ProtoReflect.Descriptor instead.
func (*NotifyUsersRequest) GetExternalUserIds ¶ added in v3.5.0
func (x *NotifyUsersRequest) GetExternalUserIds() []string
func (*NotifyUsersRequest) GetNotification ¶ added in v3.5.0
func (x *NotifyUsersRequest) GetNotification() *Notification
func (*NotifyUsersRequest) ProtoMessage ¶ added in v3.5.0
func (*NotifyUsersRequest) ProtoMessage()
func (*NotifyUsersRequest) ProtoReflect ¶ added in v3.5.0
func (x *NotifyUsersRequest) ProtoReflect() protoreflect.Message
func (*NotifyUsersRequest) Reset ¶ added in v3.5.0
func (x *NotifyUsersRequest) Reset()
func (*NotifyUsersRequest) String ¶ added in v3.5.0
func (x *NotifyUsersRequest) String() string
type NotifyUsersResponse ¶ added in v3.5.0
type NotifyUsersResponse struct {
// contains filtered or unexported fields
}
func (*NotifyUsersResponse) Descriptor
deprecated
added in
v3.5.0
func (*NotifyUsersResponse) Descriptor() ([]byte, []int)
Deprecated: Use NotifyUsersResponse.ProtoReflect.Descriptor instead.
func (*NotifyUsersResponse) ProtoMessage ¶ added in v3.5.0
func (*NotifyUsersResponse) ProtoMessage()
func (*NotifyUsersResponse) ProtoReflect ¶ added in v3.5.0
func (x *NotifyUsersResponse) ProtoReflect() protoreflect.Message
func (*NotifyUsersResponse) Reset ¶ added in v3.5.0
func (x *NotifyUsersResponse) Reset()
func (*NotifyUsersResponse) String ¶ added in v3.5.0
func (x *NotifyUsersResponse) String() string
type ReceiveNotificationsRequest ¶
type ReceiveNotificationsRequest struct {
// contains filtered or unexported fields
}
The user's browser will subscribe to a stream to receive notifications. The user follows from the JWT.
func (*ReceiveNotificationsRequest) Descriptor
deprecated
func (*ReceiveNotificationsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReceiveNotificationsRequest.ProtoReflect.Descriptor instead.
func (*ReceiveNotificationsRequest) ProtoMessage ¶
func (*ReceiveNotificationsRequest) ProtoMessage()
func (*ReceiveNotificationsRequest) ProtoReflect ¶
func (x *ReceiveNotificationsRequest) ProtoReflect() protoreflect.Message
func (*ReceiveNotificationsRequest) Reset ¶
func (x *ReceiveNotificationsRequest) Reset()
func (*ReceiveNotificationsRequest) String ¶
func (x *ReceiveNotificationsRequest) String() string
type ReceiveNotificationsResponse ¶
type ReceiveNotificationsResponse struct { Notification *UserNotification `protobuf:"bytes,1,opt,name=notification,proto3" json:"notification,omitempty"` // contains filtered or unexported fields }
func (*ReceiveNotificationsResponse) Descriptor
deprecated
func (*ReceiveNotificationsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReceiveNotificationsResponse.ProtoReflect.Descriptor instead.
func (*ReceiveNotificationsResponse) GetNotification ¶
func (x *ReceiveNotificationsResponse) GetNotification() *UserNotification
func (*ReceiveNotificationsResponse) ProtoMessage ¶
func (*ReceiveNotificationsResponse) ProtoMessage()
func (*ReceiveNotificationsResponse) ProtoReflect ¶
func (x *ReceiveNotificationsResponse) ProtoReflect() protoreflect.Message
func (*ReceiveNotificationsResponse) Reset ¶
func (x *ReceiveNotificationsResponse) Reset()
func (*ReceiveNotificationsResponse) String ¶
func (x *ReceiveNotificationsResponse) String() string
type SubscribeNotificationsRequest ¶
type SubscribeNotificationsRequest struct { // The user that should be subscribed. ExternalUserId string `protobuf:"bytes,1,opt,name=external_user_id,json=externalUserId,proto3" json:"external_user_id,omitempty"` // The entity for which the user should be subscribed to notifications. EntityRef *v1.GenericRef `protobuf:"bytes,2,opt,name=entity_ref,json=entityRef,proto3" json:"entity_ref,omitempty"` // contains filtered or unexported fields }
func (*SubscribeNotificationsRequest) Descriptor
deprecated
func (*SubscribeNotificationsRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeNotificationsRequest.ProtoReflect.Descriptor instead.
func (*SubscribeNotificationsRequest) GetEntityRef ¶
func (x *SubscribeNotificationsRequest) GetEntityRef() *v1.GenericRef
func (*SubscribeNotificationsRequest) GetExternalUserId ¶
func (x *SubscribeNotificationsRequest) GetExternalUserId() string
func (*SubscribeNotificationsRequest) ProtoMessage ¶
func (*SubscribeNotificationsRequest) ProtoMessage()
func (*SubscribeNotificationsRequest) ProtoReflect ¶
func (x *SubscribeNotificationsRequest) ProtoReflect() protoreflect.Message
func (*SubscribeNotificationsRequest) Reset ¶
func (x *SubscribeNotificationsRequest) Reset()
func (*SubscribeNotificationsRequest) String ¶
func (x *SubscribeNotificationsRequest) String() string
type SubscribeNotificationsResponse ¶
type SubscribeNotificationsResponse struct {
// contains filtered or unexported fields
}
func (*SubscribeNotificationsResponse) Descriptor
deprecated
func (*SubscribeNotificationsResponse) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeNotificationsResponse.ProtoReflect.Descriptor instead.
func (*SubscribeNotificationsResponse) ProtoMessage ¶
func (*SubscribeNotificationsResponse) ProtoMessage()
func (*SubscribeNotificationsResponse) ProtoReflect ¶
func (x *SubscribeNotificationsResponse) ProtoReflect() protoreflect.Message
func (*SubscribeNotificationsResponse) Reset ¶
func (x *SubscribeNotificationsResponse) Reset()
func (*SubscribeNotificationsResponse) String ¶
func (x *SubscribeNotificationsResponse) String() string
type Subscription ¶
type Subscription struct { // The subscribed user. ExternalUserId string `protobuf:"bytes,1,opt,name=external_user_id,json=externalUserId,proto3" json:"external_user_id,omitempty"` // The entity for which to list notifications. EntityRef *v1.GenericRef `protobuf:"bytes,2,opt,name=entity_ref,json=entityRef,proto3" json:"entity_ref,omitempty"` // contains filtered or unexported fields }
func (*Subscription) Descriptor
deprecated
func (*Subscription) Descriptor() ([]byte, []int)
Deprecated: Use Subscription.ProtoReflect.Descriptor instead.
func (*Subscription) GetEntityRef ¶
func (x *Subscription) GetEntityRef() *v1.GenericRef
func (*Subscription) GetExternalUserId ¶
func (x *Subscription) GetExternalUserId() string
func (*Subscription) ProtoMessage ¶
func (*Subscription) ProtoMessage()
func (*Subscription) ProtoReflect ¶
func (x *Subscription) ProtoReflect() protoreflect.Message
func (*Subscription) Reset ¶
func (x *Subscription) Reset()
func (*Subscription) String ¶
func (x *Subscription) String() string
type UnSubscribeNotificationsRequest ¶
type UnSubscribeNotificationsRequest struct { // The user that should be unsubscribed. ExternalUserId string `protobuf:"bytes,1,opt,name=external_user_id,json=externalUserId,proto3" json:"external_user_id,omitempty"` // The entity for which the user should be unsubscribed from notifications. EntityRef *v1.GenericRef `protobuf:"bytes,2,opt,name=entity_ref,json=entityRef,proto3" json:"entity_ref,omitempty"` // contains filtered or unexported fields }
* Tell the notification server that
user X is interested in receiving notifications about item Y
func (*UnSubscribeNotificationsRequest) Descriptor
deprecated
func (*UnSubscribeNotificationsRequest) Descriptor() ([]byte, []int)
Deprecated: Use UnSubscribeNotificationsRequest.ProtoReflect.Descriptor instead.
func (*UnSubscribeNotificationsRequest) GetEntityRef ¶
func (x *UnSubscribeNotificationsRequest) GetEntityRef() *v1.GenericRef
func (*UnSubscribeNotificationsRequest) GetExternalUserId ¶
func (x *UnSubscribeNotificationsRequest) GetExternalUserId() string
func (*UnSubscribeNotificationsRequest) ProtoMessage ¶
func (*UnSubscribeNotificationsRequest) ProtoMessage()
func (*UnSubscribeNotificationsRequest) ProtoReflect ¶
func (x *UnSubscribeNotificationsRequest) ProtoReflect() protoreflect.Message
func (*UnSubscribeNotificationsRequest) Reset ¶
func (x *UnSubscribeNotificationsRequest) Reset()
func (*UnSubscribeNotificationsRequest) String ¶
func (x *UnSubscribeNotificationsRequest) String() string
type UnSubscribeNotificationsResponse ¶
type UnSubscribeNotificationsResponse struct {
// contains filtered or unexported fields
}
func (*UnSubscribeNotificationsResponse) Descriptor
deprecated
func (*UnSubscribeNotificationsResponse) Descriptor() ([]byte, []int)
Deprecated: Use UnSubscribeNotificationsResponse.ProtoReflect.Descriptor instead.
func (*UnSubscribeNotificationsResponse) ProtoMessage ¶
func (*UnSubscribeNotificationsResponse) ProtoMessage()
func (*UnSubscribeNotificationsResponse) ProtoReflect ¶
func (x *UnSubscribeNotificationsResponse) ProtoReflect() protoreflect.Message
func (*UnSubscribeNotificationsResponse) Reset ¶
func (x *UnSubscribeNotificationsResponse) Reset()
func (*UnSubscribeNotificationsResponse) String ¶
func (x *UnSubscribeNotificationsResponse) String() string
type UnimplementedNotificationsServiceServer ¶
type UnimplementedNotificationsServiceServer struct { }
UnimplementedNotificationsServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedNotificationsServiceServer) ListNotifications ¶
func (UnimplementedNotificationsServiceServer) ListNotifications(context.Context, *ListNotificationsRequest) (*ListNotificationsResponse, error)
func (UnimplementedNotificationsServiceServer) ListSubscriptions ¶
func (UnimplementedNotificationsServiceServer) ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)
func (UnimplementedNotificationsServiceServer) NotifySubscribers ¶
func (UnimplementedNotificationsServiceServer) NotifySubscribers(context.Context, *NotifySubscribersRequest) (*NotifySubscribersResponse, error)
func (UnimplementedNotificationsServiceServer) NotifyUsers ¶ added in v3.5.0
func (UnimplementedNotificationsServiceServer) NotifyUsers(context.Context, *NotifyUsersRequest) (*NotifyUsersResponse, error)
func (UnimplementedNotificationsServiceServer) ReceiveNotifications ¶
func (UnimplementedNotificationsServiceServer) ReceiveNotifications(*ReceiveNotificationsRequest, NotificationsService_ReceiveNotificationsServer) error
func (UnimplementedNotificationsServiceServer) SubscribeNotifications ¶
func (UnimplementedNotificationsServiceServer) SubscribeNotifications(context.Context, *SubscribeNotificationsRequest) (*SubscribeNotificationsResponse, error)
func (UnimplementedNotificationsServiceServer) UnSubscribeNotifications ¶
func (UnimplementedNotificationsServiceServer) UnSubscribeNotifications(context.Context, *UnSubscribeNotificationsRequest) (*UnSubscribeNotificationsResponse, error)
type UnsafeNotificationsServiceServer ¶
type UnsafeNotificationsServiceServer interface {
// contains filtered or unexported methods
}
UnsafeNotificationsServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NotificationsServiceServer will result in compilation errors.
type UserNotification ¶
type UserNotification struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Notification *Notification `protobuf:"bytes,2,opt,name=notification,proto3" json:"notification,omitempty"` // The reason a specific receiver of this notification received it. Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"` ExternalUserId string `protobuf:"bytes,4,opt,name=external_user_id,json=externalUserId,proto3" json:"external_user_id,omitempty"` // mail was sent at this moment. If null|0, mail was not sent. MailSentTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=mail_sent_time,json=mailSentTime,proto3" json:"mail_sent_time,omitempty"` // contains filtered or unexported fields }
The actual notification to be sent to an individual user.
func (*UserNotification) Descriptor
deprecated
func (*UserNotification) Descriptor() ([]byte, []int)
Deprecated: Use UserNotification.ProtoReflect.Descriptor instead.
func (*UserNotification) GetExternalUserId ¶
func (x *UserNotification) GetExternalUserId() string
func (*UserNotification) GetId ¶
func (x *UserNotification) GetId() string
func (*UserNotification) GetMailSentTime ¶
func (x *UserNotification) GetMailSentTime() *timestamppb.Timestamp
func (*UserNotification) GetNotification ¶
func (x *UserNotification) GetNotification() *Notification
func (*UserNotification) GetReason ¶
func (x *UserNotification) GetReason() string
func (*UserNotification) ProtoMessage ¶
func (*UserNotification) ProtoMessage()
func (*UserNotification) ProtoReflect ¶
func (x *UserNotification) ProtoReflect() protoreflect.Message
func (*UserNotification) Reset ¶
func (x *UserNotification) Reset()
func (*UserNotification) String ¶
func (x *UserNotification) String() string