Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterNotifyServiceServer(s grpc.ServiceRegistrar, srv NotifyServiceServer)
- type AddRequest
- func (*AddRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddRequest) GetDetails() []byte
- func (x *AddRequest) GetNodeId() string
- func (x *AddRequest) GetServiceName() string
- func (x *AddRequest) GetSeverity() string
- func (x *AddRequest) GetStatus() uint32
- func (x *AddRequest) GetTime() uint32
- func (x *AddRequest) GetType() string
- func (*AddRequest) ProtoMessage()
- func (x *AddRequest) ProtoReflect() protoreflect.Message
- func (x *AddRequest) Reset()
- func (x *AddRequest) String() string
- func (this *AddRequest) Validate() error
- type AddResponse
- type DeleteResponse
- type GetRequest
- func (*GetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetRequest) GetNotificationId() string
- func (*GetRequest) ProtoMessage()
- func (x *GetRequest) ProtoReflect() protoreflect.Message
- func (x *GetRequest) Reset()
- func (x *GetRequest) String() string
- func (this *GetRequest) Validate() error
- type GetResponse
- func (*GetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetResponse) GetNotification() *Notification
- func (*GetResponse) ProtoMessage()
- func (x *GetResponse) ProtoReflect() protoreflect.Message
- func (x *GetResponse) Reset()
- func (x *GetResponse) String() string
- func (this *GetResponse) Validate() error
- type ListRequest
- func (*ListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListRequest) GetCount() uint32
- func (x *ListRequest) GetNodeId() string
- func (x *ListRequest) GetServiceName() string
- func (x *ListRequest) GetSort() bool
- func (x *ListRequest) GetType() string
- func (*ListRequest) ProtoMessage()
- func (x *ListRequest) ProtoReflect() protoreflect.Message
- func (x *ListRequest) Reset()
- func (x *ListRequest) String() string
- func (this *ListRequest) Validate() error
- type ListResponse
- func (*ListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListResponse) GetNotifications() []*Notification
- func (*ListResponse) ProtoMessage()
- func (x *ListResponse) ProtoReflect() protoreflect.Message
- func (x *ListResponse) Reset()
- func (x *ListResponse) String() string
- func (this *ListResponse) Validate() error
- type Notification
- func (*Notification) Descriptor() ([]byte, []int)deprecated
- func (x *Notification) GetCreatedAt() *timestamppb.Timestamp
- func (x *Notification) GetDetails() []byte
- func (x *Notification) GetId() string
- func (x *Notification) GetNodeId() string
- func (x *Notification) GetNodeType() string
- func (x *Notification) GetServiceName() string
- func (x *Notification) GetSeverity() string
- func (x *Notification) GetStatus() uint32
- func (x *Notification) GetTime() uint32
- func (x *Notification) GetType() string
- func (*Notification) ProtoMessage()
- func (x *Notification) ProtoReflect() protoreflect.Message
- func (x *Notification) Reset()
- func (x *Notification) String() string
- func (this *Notification) Validate() error
- type NotifyServiceClient
- type NotifyServiceServer
- type PurgeRequest
- func (*PurgeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PurgeRequest) GetNodeId() string
- func (x *PurgeRequest) GetServiceName() string
- func (x *PurgeRequest) GetType() string
- func (*PurgeRequest) ProtoMessage()
- func (x *PurgeRequest) ProtoReflect() protoreflect.Message
- func (x *PurgeRequest) Reset()
- func (x *PurgeRequest) String() string
- func (this *PurgeRequest) Validate() error
- type UnimplementedNotifyServiceServer
- func (UnimplementedNotifyServiceServer) Add(context.Context, *AddRequest) (*AddResponse, error)
- func (UnimplementedNotifyServiceServer) Delete(context.Context, *GetRequest) (*DeleteResponse, error)
- func (UnimplementedNotifyServiceServer) Get(context.Context, *GetRequest) (*GetResponse, error)
- func (UnimplementedNotifyServiceServer) List(context.Context, *ListRequest) (*ListResponse, error)
- func (UnimplementedNotifyServiceServer) Purge(context.Context, *PurgeRequest) (*ListResponse, error)
- type UnsafeNotifyServiceServer
Constants ¶
const ( NotifyService_Add_FullMethodName = "/ukama.notification.notify.v1.NotifyService/Add" NotifyService_Get_FullMethodName = "/ukama.notification.notify.v1.NotifyService/Get" NotifyService_List_FullMethodName = "/ukama.notification.notify.v1.NotifyService/List" NotifyService_Delete_FullMethodName = "/ukama.notification.notify.v1.NotifyService/Delete" NotifyService_Purge_FullMethodName = "/ukama.notification.notify.v1.NotifyService/Purge" )
Variables ¶
var File_notify_proto protoreflect.FileDescriptor
var NotifyService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "ukama.notification.notify.v1.NotifyService", HandlerType: (*NotifyServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Add", Handler: _NotifyService_Add_Handler, }, { MethodName: "Get", Handler: _NotifyService_Get_Handler, }, { MethodName: "List", Handler: _NotifyService_List_Handler, }, { MethodName: "Delete", Handler: _NotifyService_Delete_Handler, }, { MethodName: "Purge", Handler: _NotifyService_Purge_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "notify.proto", }
NotifyService_ServiceDesc is the grpc.ServiceDesc for NotifyService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterNotifyServiceServer ¶
func RegisterNotifyServiceServer(s grpc.ServiceRegistrar, srv NotifyServiceServer)
Types ¶
type AddRequest ¶
type AddRequest struct { NodeId string `protobuf:"bytes,1,opt,name=nodeId,json=node_id,proto3" json:"nodeId,omitempty"` Severity string `protobuf:"bytes,2,opt,name=severity,proto3" json:"severity,omitempty"` Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` ServiceName string `protobuf:"bytes,4,opt,name=serviceName,json=service_name,proto3" json:"serviceName,omitempty"` Status uint32 `protobuf:"varint,5,opt,name=status,proto3" json:"status,omitempty"` Time uint32 `protobuf:"varint,6,opt,name=time,proto3" json:"time,omitempty"` Details []byte `protobuf:"bytes,7,opt,name=details,proto3" json:"details,omitempty"` // contains filtered or unexported fields }
func (*AddRequest) Descriptor
deprecated
func (*AddRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddRequest.ProtoReflect.Descriptor instead.
func (*AddRequest) GetDetails ¶
func (x *AddRequest) GetDetails() []byte
func (*AddRequest) GetNodeId ¶
func (x *AddRequest) GetNodeId() string
func (*AddRequest) GetServiceName ¶
func (x *AddRequest) GetServiceName() string
func (*AddRequest) GetSeverity ¶
func (x *AddRequest) GetSeverity() string
func (*AddRequest) GetStatus ¶
func (x *AddRequest) GetStatus() uint32
func (*AddRequest) GetTime ¶
func (x *AddRequest) GetTime() uint32
func (*AddRequest) GetType ¶
func (x *AddRequest) GetType() string
func (*AddRequest) ProtoMessage ¶
func (*AddRequest) ProtoMessage()
func (*AddRequest) ProtoReflect ¶
func (x *AddRequest) ProtoReflect() protoreflect.Message
func (*AddRequest) Reset ¶
func (x *AddRequest) Reset()
func (*AddRequest) String ¶
func (x *AddRequest) String() string
func (*AddRequest) Validate ¶
func (this *AddRequest) Validate() error
type AddResponse ¶
type AddResponse struct {
// contains filtered or unexported fields
}
func (*AddResponse) Descriptor
deprecated
func (*AddResponse) Descriptor() ([]byte, []int)
Deprecated: Use AddResponse.ProtoReflect.Descriptor instead.
func (*AddResponse) ProtoMessage ¶
func (*AddResponse) ProtoMessage()
func (*AddResponse) ProtoReflect ¶
func (x *AddResponse) ProtoReflect() protoreflect.Message
func (*AddResponse) Reset ¶
func (x *AddResponse) Reset()
func (*AddResponse) String ¶
func (x *AddResponse) String() string
func (*AddResponse) Validate ¶
func (this *AddResponse) Validate() error
type DeleteResponse ¶
type DeleteResponse struct {
// contains filtered or unexported fields
}
func (*DeleteResponse) Descriptor
deprecated
func (*DeleteResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.
func (*DeleteResponse) ProtoMessage ¶
func (*DeleteResponse) ProtoMessage()
func (*DeleteResponse) ProtoReflect ¶
func (x *DeleteResponse) ProtoReflect() protoreflect.Message
func (*DeleteResponse) Reset ¶
func (x *DeleteResponse) Reset()
func (*DeleteResponse) String ¶
func (x *DeleteResponse) String() string
func (*DeleteResponse) Validate ¶
func (this *DeleteResponse) Validate() error
type GetRequest ¶
type GetRequest struct { NotificationId string `protobuf:"bytes,1,opt,name=notificationId,json=notification_id,proto3" json:"notificationId,omitempty"` // contains filtered or unexported fields }
func (*GetRequest) Descriptor
deprecated
func (*GetRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.
func (*GetRequest) GetNotificationId ¶
func (x *GetRequest) GetNotificationId() string
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) ProtoReflect ¶
func (x *GetRequest) ProtoReflect() protoreflect.Message
func (*GetRequest) Reset ¶
func (x *GetRequest) Reset()
func (*GetRequest) String ¶
func (x *GetRequest) String() string
func (*GetRequest) Validate ¶
func (this *GetRequest) Validate() error
type GetResponse ¶
type GetResponse struct { Notification *Notification `protobuf:"bytes,1,opt,name=notification,proto3" json:"notification,omitempty"` // contains filtered or unexported fields }
func (*GetResponse) Descriptor
deprecated
func (*GetResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.
func (*GetResponse) GetNotification ¶
func (x *GetResponse) GetNotification() *Notification
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) ProtoReflect ¶
func (x *GetResponse) ProtoReflect() protoreflect.Message
func (*GetResponse) Reset ¶
func (x *GetResponse) Reset()
func (*GetResponse) String ¶
func (x *GetResponse) String() string
func (*GetResponse) Validate ¶
func (this *GetResponse) Validate() error
type ListRequest ¶
type ListRequest struct { NodeId string `protobuf:"bytes,1,opt,name=nodeId,json=node_id,proto3" json:"nodeId,omitempty"` ServiceName string `protobuf:"bytes,2,opt,name=serviceName,json=service_name,proto3" json:"serviceName,omitempty"` Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` Count uint32 `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"` Sort bool `protobuf:"varint,5,opt,name=sort,proto3" json:"sort,omitempty"` // contains filtered or unexported fields }
func (*ListRequest) Descriptor
deprecated
func (*ListRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.
func (*ListRequest) GetCount ¶
func (x *ListRequest) GetCount() uint32
func (*ListRequest) GetNodeId ¶
func (x *ListRequest) GetNodeId() string
func (*ListRequest) GetServiceName ¶
func (x *ListRequest) GetServiceName() string
func (*ListRequest) GetSort ¶
func (x *ListRequest) GetSort() bool
func (*ListRequest) GetType ¶
func (x *ListRequest) GetType() string
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) ProtoReflect ¶
func (x *ListRequest) ProtoReflect() protoreflect.Message
func (*ListRequest) Reset ¶
func (x *ListRequest) Reset()
func (*ListRequest) String ¶
func (x *ListRequest) String() string
func (*ListRequest) Validate ¶
func (this *ListRequest) Validate() error
type ListResponse ¶
type ListResponse struct { Notifications []*Notification `protobuf:"bytes,1,rep,name=notifications,proto3" json:"notifications,omitempty"` // contains filtered or unexported fields }
func (*ListResponse) Descriptor
deprecated
func (*ListResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.
func (*ListResponse) GetNotifications ¶
func (x *ListResponse) GetNotifications() []*Notification
func (*ListResponse) ProtoMessage ¶
func (*ListResponse) ProtoMessage()
func (*ListResponse) ProtoReflect ¶
func (x *ListResponse) ProtoReflect() protoreflect.Message
func (*ListResponse) Reset ¶
func (x *ListResponse) Reset()
func (*ListResponse) String ¶
func (x *ListResponse) String() string
func (*ListResponse) Validate ¶
func (this *ListResponse) Validate() error
type Notification ¶
type Notification struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` NodeId string `protobuf:"bytes,2,opt,name=nodeId,json=node_id,proto3" json:"nodeId,omitempty"` NodeType string `protobuf:"bytes,3,opt,name=nodeType,json=node_type,proto3" json:"nodeType,omitempty"` Severity string `protobuf:"bytes,4,opt,name=severity,proto3" json:"severity,omitempty"` Type string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"` ServiceName string `protobuf:"bytes,6,opt,name=serviceName,json=service_name,proto3" json:"serviceName,omitempty"` Status uint32 `protobuf:"varint,7,opt,name=status,proto3" json:"status,omitempty"` Time uint32 `protobuf:"varint,8,opt,name=time,proto3" json:"time,omitempty"` Details []byte `protobuf:"bytes,9,opt,name=details,proto3" json:"details,omitempty"` CreatedAt *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=createdAt,json=created_at,proto3" json:"createdAt,omitempty"` // contains filtered or unexported fields }
func (*Notification) Descriptor
deprecated
func (*Notification) Descriptor() ([]byte, []int)
Deprecated: Use Notification.ProtoReflect.Descriptor instead.
func (*Notification) GetCreatedAt ¶
func (x *Notification) GetCreatedAt() *timestamppb.Timestamp
func (*Notification) GetDetails ¶
func (x *Notification) GetDetails() []byte
func (*Notification) GetId ¶
func (x *Notification) GetId() string
func (*Notification) GetNodeId ¶
func (x *Notification) GetNodeId() string
func (*Notification) GetNodeType ¶
func (x *Notification) GetNodeType() string
func (*Notification) GetServiceName ¶
func (x *Notification) GetServiceName() string
func (*Notification) GetSeverity ¶
func (x *Notification) GetSeverity() string
func (*Notification) GetStatus ¶
func (x *Notification) GetStatus() uint32
func (*Notification) GetTime ¶
func (x *Notification) GetTime() uint32
func (*Notification) GetType ¶
func (x *Notification) GetType() string
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
func (*Notification) Validate ¶
func (this *Notification) Validate() error
type NotifyServiceClient ¶
type NotifyServiceClient interface { Add(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*AddResponse, error) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) Delete(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*DeleteResponse, error) Purge(ctx context.Context, in *PurgeRequest, opts ...grpc.CallOption) (*ListResponse, error) }
NotifyServiceClient is the client API for NotifyService 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 NewNotifyServiceClient ¶
func NewNotifyServiceClient(cc grpc.ClientConnInterface) NotifyServiceClient
type NotifyServiceServer ¶
type NotifyServiceServer interface { Add(context.Context, *AddRequest) (*AddResponse, error) Get(context.Context, *GetRequest) (*GetResponse, error) List(context.Context, *ListRequest) (*ListResponse, error) Delete(context.Context, *GetRequest) (*DeleteResponse, error) Purge(context.Context, *PurgeRequest) (*ListResponse, error) // contains filtered or unexported methods }
NotifyServiceServer is the server API for NotifyService service. All implementations must embed UnimplementedNotifyServiceServer for forward compatibility
type PurgeRequest ¶
type PurgeRequest struct { NodeId string `protobuf:"bytes,1,opt,name=nodeId,json=node_id,proto3" json:"nodeId,omitempty"` ServiceName string `protobuf:"bytes,2,opt,name=serviceName,json=service_name,proto3" json:"serviceName,omitempty"` Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` // contains filtered or unexported fields }
func (*PurgeRequest) Descriptor
deprecated
func (*PurgeRequest) Descriptor() ([]byte, []int)
Deprecated: Use PurgeRequest.ProtoReflect.Descriptor instead.
func (*PurgeRequest) GetNodeId ¶
func (x *PurgeRequest) GetNodeId() string
func (*PurgeRequest) GetServiceName ¶
func (x *PurgeRequest) GetServiceName() string
func (*PurgeRequest) GetType ¶
func (x *PurgeRequest) GetType() string
func (*PurgeRequest) ProtoMessage ¶
func (*PurgeRequest) ProtoMessage()
func (*PurgeRequest) ProtoReflect ¶
func (x *PurgeRequest) ProtoReflect() protoreflect.Message
func (*PurgeRequest) Reset ¶
func (x *PurgeRequest) Reset()
func (*PurgeRequest) String ¶
func (x *PurgeRequest) String() string
func (*PurgeRequest) Validate ¶
func (this *PurgeRequest) Validate() error
type UnimplementedNotifyServiceServer ¶
type UnimplementedNotifyServiceServer struct { }
UnimplementedNotifyServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedNotifyServiceServer) Add ¶
func (UnimplementedNotifyServiceServer) Add(context.Context, *AddRequest) (*AddResponse, error)
func (UnimplementedNotifyServiceServer) Delete ¶
func (UnimplementedNotifyServiceServer) Delete(context.Context, *GetRequest) (*DeleteResponse, error)
func (UnimplementedNotifyServiceServer) Get ¶
func (UnimplementedNotifyServiceServer) Get(context.Context, *GetRequest) (*GetResponse, error)
func (UnimplementedNotifyServiceServer) List ¶
func (UnimplementedNotifyServiceServer) List(context.Context, *ListRequest) (*ListResponse, error)
func (UnimplementedNotifyServiceServer) Purge ¶
func (UnimplementedNotifyServiceServer) Purge(context.Context, *PurgeRequest) (*ListResponse, error)
type UnsafeNotifyServiceServer ¶
type UnsafeNotifyServiceServer interface {
// contains filtered or unexported methods
}
UnsafeNotifyServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NotifyServiceServer will result in compilation errors.