notificationv1

package
v1.29.14 Latest Latest
Warning

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

 Go to latest Published: Nov 16, 2024 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Overview

Package notificationv1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package notificationv1 is a generated GoMock package.

Index

Constants

View Source 
const (
	NotificationService_Send_FullMethodName           = "/notification.v1.NotificationService/Send"
	NotificationService_Release_FullMethodName        = "/notification.v1.NotificationService/Release"
	NotificationService_Receive_FullMethodName        = "/notification.v1.NotificationService/Receive"
	NotificationService_Search_FullMethodName         = "/notification.v1.NotificationService/Search"
	NotificationService_Status_FullMethodName         = "/notification.v1.NotificationService/Status"
	NotificationService_StatusUpdate_FullMethodName   = "/notification.v1.NotificationService/StatusUpdate"
	NotificationService_TemplateSearch_FullMethodName = "/notification.v1.NotificationService/TemplateSearch"
	NotificationService_TemplateSave_FullMethodName   = "/notification.v1.NotificationService/TemplateSave"
)

Variables

View Source 
var (
	PRIORITY_name = map[int32]string{
		0: "HIGH",
		1: "LOW",
		2: "VERY_LOW",
	}
	PRIORITY_value = map[string]int32{
		"HIGH":     0,
		"LOW":      1,
		"VERY_LOW": 2,
	}
)

Enum value maps for PRIORITY.

View Source 
var File_notification_v1_notification_proto protoreflect.FileDescriptor
View Source 
var NotificationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "notification.v1.NotificationService",
	HandlerType: (*NotificationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Send",
			Handler:    _NotificationService_Send_Handler,
		},
		{
			MethodName: "Release",
			Handler:    _NotificationService_Release_Handler,
		},
		{
			MethodName: "Receive",
			Handler:    _NotificationService_Receive_Handler,
		},
		{
			MethodName: "Status",
			Handler:    _NotificationService_Status_Handler,
		},
		{
			MethodName: "StatusUpdate",
			Handler:    _NotificationService_StatusUpdate_Handler,
		},
		{
			MethodName: "TemplateSave",
			Handler:    _NotificationService_TemplateSave_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Search",
			Handler:       _NotificationService_Search_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "TemplateSearch",
			Handler:       _NotificationService_TemplateSearch_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "notification/v1/notification.proto",
}

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

Functions

func CreateProxyHandler added in v1.28.4 

func CreateProxyHandler(ctx context.Context, proxyOptions common.ProxyOptions) (*http.ServeMux, error)

func RegisterNotificationServiceHandler added in v1.28.0 

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

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

func RegisterNotificationServiceHandlerClient added in v1.28.0 

func RegisterNotificationServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client NotificationServiceClient) error

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

func RegisterNotificationServiceHandlerFromEndpoint added in v1.28.0 

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

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

func RegisterNotificationServiceHandlerServer added in v1.28.0 

func RegisterNotificationServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server NotificationServiceServer) error

RegisterNotificationServiceHandlerServer registers the http handlers for service NotificationService to "mux". UnaryRPC :call NotificationServiceServer 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 RegisterNotificationServiceHandlerFromEndpoint instead. GRPC interceptors will not work for this type of registration. To use interceptors, you must use the "runtime.WithMiddlewares" option in the "runtime.NewServeMux" call.

func RegisterNotificationServiceServer 

func RegisterNotificationServiceServer(s grpc.ServiceRegistrar, srv NotificationServiceServer)

func ToContext 

func ToContext(ctx context.Context, client *NotificationClient) context.Context

Types

type Language added in v1.9.0 

type Language struct {
	Id    string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Code  string            `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
	Name  string            `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Extra map[string]string `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Language) Descriptor deprecated added in v1.9.0 

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

Deprecated: Use Language.ProtoReflect.Descriptor instead.

func (*Language) GetCode added in v1.9.0 

func (x *Language) GetCode() string

func (*Language) GetExtra added in v1.9.0 

func (x *Language) GetExtra() map[string]string

func (*Language) GetId added in v1.9.0 

func (x *Language) GetId() string

func (*Language) GetName added in v1.9.0 

func (x *Language) GetName() string

func (*Language) ProtoMessage added in v1.9.0 

func (*Language) ProtoMessage()

func (*Language) ProtoReflect added in v1.9.0 

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

func (*Language) Reset added in v1.9.0 

func (x *Language) Reset()

func (*Language) String added in v1.9.0 

func (x *Language) String() string

type MockNotificationServiceClient 

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

MockNotificationServiceClient is a mock of NotificationServiceClient interface.

func NewMockNotificationServiceClient 

func NewMockNotificationServiceClient(ctrl *gomock.Controller) *MockNotificationServiceClient

NewMockNotificationServiceClient creates a new mock instance.

func (*MockNotificationServiceClient) EXPECT 

func (m *MockNotificationServiceClient) EXPECT() *MockNotificationServiceClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockNotificationServiceClient) Receive 

func (m *MockNotificationServiceClient) Receive(ctx context.Context, in *ReceiveRequest, opts ...grpc.CallOption) (*ReceiveResponse, error)

Receive mocks base method.

func (*MockNotificationServiceClient) Release 

func (m *MockNotificationServiceClient) Release(ctx context.Context, in *ReleaseRequest, opts ...grpc.CallOption) (*ReleaseResponse, error)

Release mocks base method.

func (*MockNotificationServiceClient) Search 

func (m *MockNotificationServiceClient) Search(ctx context.Context, in *v1.SearchRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[SearchResponse], error)

Search mocks base method.

func (*MockNotificationServiceClient) Send 

func (m *MockNotificationServiceClient) Send(ctx context.Context, in *SendRequest, opts ...grpc.CallOption) (*SendResponse, error)

Send mocks base method.

func (*MockNotificationServiceClient) Status 

func (m *MockNotificationServiceClient) Status(ctx context.Context, in *v1.StatusRequest, opts ...grpc.CallOption) (*v1.StatusResponse, error)

Status mocks base method.

func (*MockNotificationServiceClient) StatusUpdate 

func (m *MockNotificationServiceClient) StatusUpdate(ctx context.Context, in *v1.StatusUpdateRequest, opts ...grpc.CallOption) (*v1.StatusUpdateResponse, error)

StatusUpdate mocks base method.

func (*MockNotificationServiceClient) TemplateSave added in v1.9.0 

func (m *MockNotificationServiceClient) TemplateSave(ctx context.Context, in *TemplateSaveRequest, opts ...grpc.CallOption) (*TemplateSaveResponse, error)

TemplateSave mocks base method.

func (*MockNotificationServiceClient) TemplateSearch added in v1.9.0 

func (m *MockNotificationServiceClient) TemplateSearch(ctx context.Context, in *TemplateSearchRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[TemplateSearchResponse], error)

TemplateSearch mocks base method.

type MockNotificationServiceClientMockRecorder 

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

MockNotificationServiceClientMockRecorder is the mock recorder for MockNotificationServiceClient.

func (*MockNotificationServiceClientMockRecorder) Receive 

func (mr *MockNotificationServiceClientMockRecorder) Receive(ctx, in any, opts ...any) *gomock.Call

Receive indicates an expected call of Receive.

func (*MockNotificationServiceClientMockRecorder) Release 

func (mr *MockNotificationServiceClientMockRecorder) Release(ctx, in any, opts ...any) *gomock.Call

Release indicates an expected call of Release.

func (*MockNotificationServiceClientMockRecorder) Search 

func (mr *MockNotificationServiceClientMockRecorder) Search(ctx, in any, opts ...any) *gomock.Call

Search indicates an expected call of Search.

func (*MockNotificationServiceClientMockRecorder) Send 

func (mr *MockNotificationServiceClientMockRecorder) Send(ctx, in any, opts ...any) *gomock.Call

Send indicates an expected call of Send.

func (*MockNotificationServiceClientMockRecorder) Status 

func (mr *MockNotificationServiceClientMockRecorder) Status(ctx, in any, opts ...any) *gomock.Call

Status indicates an expected call of Status.

func (*MockNotificationServiceClientMockRecorder) StatusUpdate 

func (mr *MockNotificationServiceClientMockRecorder) StatusUpdate(ctx, in any, opts ...any) *gomock.Call

StatusUpdate indicates an expected call of StatusUpdate.

func (*MockNotificationServiceClientMockRecorder) TemplateSave added in v1.9.0 

func (mr *MockNotificationServiceClientMockRecorder) TemplateSave(ctx, in any, opts ...any) *gomock.Call

TemplateSave indicates an expected call of TemplateSave.

func (*MockNotificationServiceClientMockRecorder) TemplateSearch added in v1.9.0 

func (mr *MockNotificationServiceClientMockRecorder) TemplateSearch(ctx, in any, opts ...any) *gomock.Call

TemplateSearch indicates an expected call of TemplateSearch.

type MockNotificationServiceServer 

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

MockNotificationServiceServer is a mock of NotificationServiceServer interface.

func NewMockNotificationServiceServer 

func NewMockNotificationServiceServer(ctrl *gomock.Controller) *MockNotificationServiceServer

NewMockNotificationServiceServer creates a new mock instance.

func (*MockNotificationServiceServer) EXPECT 

func (m *MockNotificationServiceServer) EXPECT() *MockNotificationServiceServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockNotificationServiceServer) Receive 

func (m *MockNotificationServiceServer) Receive(arg0 context.Context, arg1 *ReceiveRequest) (*ReceiveResponse, error)

Receive mocks base method.

func (*MockNotificationServiceServer) Release 

func (m *MockNotificationServiceServer) Release(arg0 context.Context, arg1 *ReleaseRequest) (*ReleaseResponse, error)

Release mocks base method.

func (*MockNotificationServiceServer) Search 

func (m *MockNotificationServiceServer) Search(arg0 *v1.SearchRequest, arg1 grpc.ServerStreamingServer[SearchResponse]) error

Search mocks base method.

func (*MockNotificationServiceServer) Send 

func (m *MockNotificationServiceServer) Send(arg0 context.Context, arg1 *SendRequest) (*SendResponse, error)

Send mocks base method.

func (*MockNotificationServiceServer) Status 

func (m *MockNotificationServiceServer) Status(arg0 context.Context, arg1 *v1.StatusRequest) (*v1.StatusResponse, error)

Status mocks base method.

func (*MockNotificationServiceServer) StatusUpdate 

func (m *MockNotificationServiceServer) StatusUpdate(arg0 context.Context, arg1 *v1.StatusUpdateRequest) (*v1.StatusUpdateResponse, error)

StatusUpdate mocks base method.

func (*MockNotificationServiceServer) TemplateSave added in v1.9.0 

func (m *MockNotificationServiceServer) TemplateSave(arg0 context.Context, arg1 *TemplateSaveRequest) (*TemplateSaveResponse, error)

TemplateSave mocks base method.

func (*MockNotificationServiceServer) TemplateSearch added in v1.9.0 

func (m *MockNotificationServiceServer) TemplateSearch(arg0 *TemplateSearchRequest, arg1 grpc.ServerStreamingServer[TemplateSearchResponse]) error

TemplateSearch mocks base method.

type MockNotificationServiceServerMockRecorder 

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

MockNotificationServiceServerMockRecorder is the mock recorder for MockNotificationServiceServer.

func (*MockNotificationServiceServerMockRecorder) Receive 

func (mr *MockNotificationServiceServerMockRecorder) Receive(arg0, arg1 any) *gomock.Call

Receive indicates an expected call of Receive.

func (*MockNotificationServiceServerMockRecorder) Release 

func (mr *MockNotificationServiceServerMockRecorder) Release(arg0, arg1 any) *gomock.Call

Release indicates an expected call of Release.

func (*MockNotificationServiceServerMockRecorder) Search 

func (mr *MockNotificationServiceServerMockRecorder) Search(arg0, arg1 any) *gomock.Call

Search indicates an expected call of Search.

func (*MockNotificationServiceServerMockRecorder) Send 

func (mr *MockNotificationServiceServerMockRecorder) Send(arg0, arg1 any) *gomock.Call

Send indicates an expected call of Send.

func (*MockNotificationServiceServerMockRecorder) Status 

func (mr *MockNotificationServiceServerMockRecorder) Status(arg0, arg1 any) *gomock.Call

Status indicates an expected call of Status.

func (*MockNotificationServiceServerMockRecorder) StatusUpdate 

func (mr *MockNotificationServiceServerMockRecorder) StatusUpdate(arg0, arg1 any) *gomock.Call

StatusUpdate indicates an expected call of StatusUpdate.

func (*MockNotificationServiceServerMockRecorder) TemplateSave added in v1.9.0 

func (mr *MockNotificationServiceServerMockRecorder) TemplateSave(arg0, arg1 any) *gomock.Call

TemplateSave indicates an expected call of TemplateSave.

func (*MockNotificationServiceServerMockRecorder) TemplateSearch added in v1.9.0 

func (mr *MockNotificationServiceServerMockRecorder) TemplateSearch(arg0, arg1 any) *gomock.Call

TemplateSearch indicates an expected call of TemplateSearch.

type MockUnsafeNotificationServiceServer 

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

MockUnsafeNotificationServiceServer is a mock of UnsafeNotificationServiceServer interface.

func NewMockUnsafeNotificationServiceServer 

func NewMockUnsafeNotificationServiceServer(ctrl *gomock.Controller) *MockUnsafeNotificationServiceServer

NewMockUnsafeNotificationServiceServer creates a new mock instance.

func (*MockUnsafeNotificationServiceServer) EXPECT 

func (m *MockUnsafeNotificationServiceServer) EXPECT() *MockUnsafeNotificationServiceServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockUnsafeNotificationServiceServerMockRecorder 

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

MockUnsafeNotificationServiceServerMockRecorder is the mock recorder for MockUnsafeNotificationServiceServer.

type Notification 

type Notification struct {
	Id          string             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ParentId    string             `protobuf:"bytes,2,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"`
	Source      *v1.ContactLink    `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`
	Recipient   *v1.ContactLink    `protobuf:"bytes,4,opt,name=recipient,proto3" json:"recipient,omitempty"`
	Type        string             `protobuf:"bytes,6,opt,name=type,proto3" json:"type,omitempty"`
	Template    string             `protobuf:"bytes,7,opt,name=template,proto3" json:"template,omitempty"`
	Payload     map[string]string  `` /* 155-byte string literal not displayed */
	Data        string             `protobuf:"bytes,9,opt,name=data,proto3" json:"data,omitempty"`
	Language    string             `protobuf:"bytes,10,opt,name=language,proto3" json:"language,omitempty"`
	OutBound    bool               `protobuf:"varint,11,opt,name=out_bound,json=outBound,proto3" json:"out_bound,omitempty"`
	AutoRelease bool               `protobuf:"varint,12,opt,name=auto_release,json=autoRelease,proto3" json:"auto_release,omitempty"`
	RouteId     string             `protobuf:"bytes,13,opt,name=route_id,json=routeId,proto3" json:"route_id,omitempty"`
	Status      *v1.StatusResponse `protobuf:"bytes,14,opt,name=status,proto3" json:"status,omitempty"`
	Extras      map[string]string  `` /* 154-byte string literal not displayed */
	Priority    PRIORITY           `protobuf:"varint,16,opt,name=priority,proto3,enum=notification.v1.PRIORITY" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

func (*Notification) Descriptor deprecated 

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

Deprecated: Use Notification.ProtoReflect.Descriptor instead.

func (*Notification) GetAutoRelease 

func (x *Notification) GetAutoRelease() bool

func (*Notification) GetData 

func (x *Notification) GetData() string

func (*Notification) GetExtras 

func (x *Notification) GetExtras() map[string]string

func (*Notification) GetId 

func (x *Notification) GetId() string

func (*Notification) GetLanguage 

func (x *Notification) GetLanguage() string

func (*Notification) GetOutBound 

func (x *Notification) GetOutBound() bool

func (*Notification) GetParentId added in v1.11.0 

func (x *Notification) GetParentId() string

func (*Notification) GetPayload 

func (x *Notification) GetPayload() map[string]string

func (*Notification) GetPriority 

func (x *Notification) GetPriority() PRIORITY

func (*Notification) GetRecipient added in v1.15.1 

func (x *Notification) GetRecipient() *v1.ContactLink

func (*Notification) GetRouteId 

func (x *Notification) GetRouteId() string

func (*Notification) GetSource added in v1.11.2 

func (x *Notification) GetSource() *v1.ContactLink

func (*Notification) GetStatus 

func (x *Notification) GetStatus() *v1.StatusResponse

func (*Notification) GetTemplate 

func (x *Notification) GetTemplate() string

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

type NotificationClient 

type NotificationClient struct {
	*common.GrpcClientBase

	// The gRPC API Client.
	Client NotificationServiceClient
}

NotificationClient is a Client for interacting with the notification service API.

Methods, except Close, may be called concurrently. However, fields must not be modified concurrently with method calls.

func FromContext 

func FromContext(ctx context.Context) *NotificationClient

func Init added in v1.9.1 

func Init(cBase *common.GrpcClientBase, service NotificationServiceClient) *NotificationClient

func NewNotificationClient 

func NewNotificationClient(ctx context.Context, opts ...common.ClientOption) (*NotificationClient, error)

NewNotificationClient creates a new notification Client.

The service that an application uses to send and access received messages

func (*NotificationClient) GetTemplate added in v1.9.0 

func (nc *NotificationClient) GetTemplate(ctx context.Context, name string, language string) (*Template, error)

func (*NotificationClient) Receive 

func (nc *NotificationClient) Receive(ctx context.Context, message *Notification) (*ReceiveResponse, error)

func (*NotificationClient) SaveTemplate added in v1.9.0 

func (nc *NotificationClient) SaveTemplate(ctx context.Context, name string, language string, data map[string]string) (*Template, error)

func (*NotificationClient) SearchTemplate added in v1.9.0 

func (nc *NotificationClient) SearchTemplate(ctx context.Context, query string, language string, page int64, count int32) (<-chan *Template, error)

func (*NotificationClient) Send 

func (nc *NotificationClient) Send(ctx context.Context, message *Notification) (*SendResponse, error)

func (*NotificationClient) UpdateStatus 

func (nc *NotificationClient) UpdateStatus(ctx context.Context, notificationId string,
	state commonv1.STATE, status commonv1.STATUS, externalId string,
	extras map[string]string) (*commonv1.StatusUpdateResponse, error)

type NotificationServiceClient 

type NotificationServiceClient interface {
	// Send method for queueing massages as requested
	Send(ctx context.Context, in *SendRequest, opts ...grpc.CallOption) (*SendResponse, error)
	// Release method for releasing queued massages and returns if notification status if released
	Release(ctx context.Context, in *ReleaseRequest, opts ...grpc.CallOption) (*ReleaseResponse, error)
	// Receive method is for client request for particular notification responses from system
	Receive(ctx context.Context, in *ReceiveRequest, opts ...grpc.CallOption) (*ReceiveResponse, error)
	// Search method is for client request for particular notification details from system
	Search(ctx context.Context, in *v1.SearchRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[SearchResponse], error)
	// Status request to determine if notification is prepared or released
	Status(ctx context.Context, in *v1.StatusRequest, opts ...grpc.CallOption) (*v1.StatusResponse, error)
	// Status update request to allow continuation of notification processing
	StatusUpdate(ctx context.Context, in *v1.StatusUpdateRequest, opts ...grpc.CallOption) (*v1.StatusUpdateResponse, error)
	// Utility to allow system obtain templates within the system
	TemplateSearch(ctx context.Context, in *TemplateSearchRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[TemplateSearchResponse], error)
	TemplateSave(ctx context.Context, in *TemplateSaveRequest, opts ...grpc.CallOption) (*TemplateSaveResponse, error)
}

NotificationServiceClient is the client API for NotificationService 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 NewNotificationServiceClient 

func NewNotificationServiceClient(cc grpc.ClientConnInterface) NotificationServiceClient

type NotificationServiceServer 

type NotificationServiceServer interface {
	// Send method for queueing massages as requested
	Send(context.Context, *SendRequest) (*SendResponse, error)
	// Release method for releasing queued massages and returns if notification status if released
	Release(context.Context, *ReleaseRequest) (*ReleaseResponse, error)
	// Receive method is for client request for particular notification responses from system
	Receive(context.Context, *ReceiveRequest) (*ReceiveResponse, error)
	// Search method is for client request for particular notification details from system
	Search(*v1.SearchRequest, grpc.ServerStreamingServer[SearchResponse]) error
	// Status request to determine if notification is prepared or released
	Status(context.Context, *v1.StatusRequest) (*v1.StatusResponse, error)
	// Status update request to allow continuation of notification processing
	StatusUpdate(context.Context, *v1.StatusUpdateRequest) (*v1.StatusUpdateResponse, error)
	// Utility to allow system obtain templates within the system
	TemplateSearch(*TemplateSearchRequest, grpc.ServerStreamingServer[TemplateSearchResponse]) error
	TemplateSave(context.Context, *TemplateSaveRequest) (*TemplateSaveResponse, error)
	// contains filtered or unexported methods
}

NotificationServiceServer is the server API for NotificationService service. All implementations must embed UnimplementedNotificationServiceServer for forward compatibility.

type NotificationService_SearchClient 

type NotificationService_SearchClient = grpc.ServerStreamingClient[SearchResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type NotificationService_SearchServer 

type NotificationService_SearchServer = grpc.ServerStreamingServer[SearchResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type NotificationService_TemplateSearchClient added in v1.9.0 

type NotificationService_TemplateSearchClient = grpc.ServerStreamingClient[TemplateSearchResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type NotificationService_TemplateSearchServer added in v1.9.0 

type NotificationService_TemplateSearchServer = grpc.ServerStreamingServer[TemplateSearchResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type PRIORITY 

type PRIORITY int32

buf:lint:ignore ENUM_VALUE_PREFIX 

const (
	// buf:lint:ignore ENUM_ZERO_VALUE_SUFFIX
	PRIORITY_HIGH     PRIORITY = 0
	PRIORITY_LOW      PRIORITY = 1
	PRIORITY_VERY_LOW PRIORITY = 2
)

func (PRIORITY) Descriptor 

func (PRIORITY) Descriptor() protoreflect.EnumDescriptor

func (PRIORITY) Enum 

func (x PRIORITY) Enum() *PRIORITY

func (PRIORITY) EnumDescriptor deprecated 

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

Deprecated: Use PRIORITY.Descriptor instead.

func (PRIORITY) Number 

func (x PRIORITY) Number() protoreflect.EnumNumber

func (PRIORITY) String 

func (x PRIORITY) String() string

func (PRIORITY) Type 

func (PRIORITY) Type() protoreflect.EnumType

type ReceiveRequest 

type ReceiveRequest struct {
	Data *Notification `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ReceiveRequest) Descriptor deprecated 

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

Deprecated: Use ReceiveRequest.ProtoReflect.Descriptor instead.

func (*ReceiveRequest) GetData 

func (x *ReceiveRequest) GetData() *Notification

func (*ReceiveRequest) ProtoMessage 

func (*ReceiveRequest) ProtoMessage()

func (*ReceiveRequest) ProtoReflect 

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

func (*ReceiveRequest) Reset 

func (x *ReceiveRequest) Reset()

func (*ReceiveRequest) String 

func (x *ReceiveRequest) String() string

type ReceiveResponse 

type ReceiveResponse struct {
	Data *v1.StatusResponse `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ReceiveResponse) Descriptor deprecated 

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

Deprecated: Use ReceiveResponse.ProtoReflect.Descriptor instead.

func (*ReceiveResponse) GetData 

func (x *ReceiveResponse) GetData() *v1.StatusResponse

func (*ReceiveResponse) ProtoMessage 

func (*ReceiveResponse) ProtoMessage()

func (*ReceiveResponse) ProtoReflect 

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

func (*ReceiveResponse) Reset 

func (x *ReceiveResponse) Reset()

func (*ReceiveResponse) String 

func (x *ReceiveResponse) String() string

type ReleaseRequest 

type ReleaseRequest struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Comment string `protobuf:"bytes,2,opt,name=comment,proto3" json:"comment,omitempty"`
	// contains filtered or unexported fields
}

func (*ReleaseRequest) Descriptor deprecated 

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

Deprecated: Use ReleaseRequest.ProtoReflect.Descriptor instead.

func (*ReleaseRequest) GetComment 

func (x *ReleaseRequest) GetComment() string

func (*ReleaseRequest) GetId 

func (x *ReleaseRequest) GetId() string

func (*ReleaseRequest) ProtoMessage 

func (*ReleaseRequest) ProtoMessage()

func (*ReleaseRequest) ProtoReflect 

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

func (*ReleaseRequest) Reset 

func (x *ReleaseRequest) Reset()

func (*ReleaseRequest) String 

func (x *ReleaseRequest) String() string

type ReleaseResponse 

type ReleaseResponse struct {
	Data *v1.StatusResponse `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ReleaseResponse) Descriptor deprecated 

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

Deprecated: Use ReleaseResponse.ProtoReflect.Descriptor instead.

func (*ReleaseResponse) GetData 

func (x *ReleaseResponse) GetData() *v1.StatusResponse

func (*ReleaseResponse) ProtoMessage 

func (*ReleaseResponse) ProtoMessage()

func (*ReleaseResponse) ProtoReflect 

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

func (*ReleaseResponse) Reset 

func (x *ReleaseResponse) Reset()

func (*ReleaseResponse) String 

func (x *ReleaseResponse) String() string

type SearchResponse 

type SearchResponse struct {
	Data []*Notification `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchResponse) Descriptor deprecated 

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

Deprecated: Use SearchResponse.ProtoReflect.Descriptor instead.

func (*SearchResponse) GetData 

func (x *SearchResponse) GetData() []*Notification

func (*SearchResponse) ProtoMessage 

func (*SearchResponse) ProtoMessage()

func (*SearchResponse) ProtoReflect 

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

func (*SearchResponse) Reset 

func (x *SearchResponse) Reset()

func (*SearchResponse) String 

func (x *SearchResponse) String() string

type SendRequest 

type SendRequest struct {
	Data *Notification `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*SendRequest) Descriptor deprecated 

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

Deprecated: Use SendRequest.ProtoReflect.Descriptor instead.

func (*SendRequest) GetData 

func (x *SendRequest) GetData() *Notification

func (*SendRequest) ProtoMessage 

func (*SendRequest) ProtoMessage()

func (*SendRequest) ProtoReflect 

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

func (*SendRequest) Reset 

func (x *SendRequest) Reset()

func (*SendRequest) String 

func (x *SendRequest) String() string

type SendResponse 

type SendResponse struct {
	Data *v1.StatusResponse `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*SendResponse) Descriptor deprecated 

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

Deprecated: Use SendResponse.ProtoReflect.Descriptor instead.

func (*SendResponse) GetData 

func (x *SendResponse) GetData() *v1.StatusResponse

func (*SendResponse) ProtoMessage 

func (*SendResponse) ProtoMessage()

func (*SendResponse) ProtoReflect 

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

func (*SendResponse) Reset 

func (x *SendResponse) Reset()

func (*SendResponse) String 

func (x *SendResponse) String() string

type Template added in v1.9.0 

type Template struct {
	Id    string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name  string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Data  []*TemplateData   `protobuf:"bytes,4,rep,name=data,proto3" json:"data,omitempty"`
	Extra map[string]string `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Template) Descriptor deprecated added in v1.9.0 

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

Deprecated: Use Template.ProtoReflect.Descriptor instead.

func (*Template) GetData added in v1.9.0 

func (x *Template) GetData() []*TemplateData

func (*Template) GetExtra added in v1.9.0 

func (x *Template) GetExtra() map[string]string

func (*Template) GetId added in v1.9.0 

func (x *Template) GetId() string

func (*Template) GetName added in v1.9.0 

func (x *Template) GetName() string

func (*Template) ProtoMessage added in v1.9.0 

func (*Template) ProtoMessage()

func (*Template) ProtoReflect added in v1.9.0 

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

func (*Template) Reset added in v1.9.0 

func (x *Template) Reset()

func (*Template) String added in v1.9.0 

func (x *Template) String() string

type TemplateData added in v1.9.0 

type TemplateData struct {
	Id       string    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type     string    `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Detail   string    `protobuf:"bytes,3,opt,name=detail,proto3" json:"detail,omitempty"`
	Language *Language `protobuf:"bytes,4,opt,name=language,proto3" json:"language,omitempty"`
	// contains filtered or unexported fields
}

func (*TemplateData) Descriptor deprecated added in v1.9.0 

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

Deprecated: Use TemplateData.ProtoReflect.Descriptor instead.

func (*TemplateData) GetDetail added in v1.9.0 

func (x *TemplateData) GetDetail() string

func (*TemplateData) GetId added in v1.9.0 

func (x *TemplateData) GetId() string

func (*TemplateData) GetLanguage added in v1.9.2 

func (x *TemplateData) GetLanguage() *Language

func (*TemplateData) GetType added in v1.9.0 

func (x *TemplateData) GetType() string

func (*TemplateData) ProtoMessage added in v1.9.0 

func (*TemplateData) ProtoMessage()

func (*TemplateData) ProtoReflect added in v1.9.0 

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

func (*TemplateData) Reset added in v1.9.0 

func (x *TemplateData) Reset()

func (*TemplateData) String added in v1.9.0 

func (x *TemplateData) String() string

type TemplateSaveRequest added in v1.9.0 

type TemplateSaveRequest struct {
	Name         string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	LanguageCode string            `protobuf:"bytes,2,opt,name=language_code,json=languageCode,proto3" json:"language_code,omitempty"`
	Data         map[string]string `` /* 149-byte string literal not displayed */
	Extra        map[string]string `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TemplateSaveRequest) Descriptor deprecated added in v1.9.0 

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

Deprecated: Use TemplateSaveRequest.ProtoReflect.Descriptor instead.

func (*TemplateSaveRequest) GetData added in v1.9.0 

func (x *TemplateSaveRequest) GetData() map[string]string

func (*TemplateSaveRequest) GetExtra added in v1.9.0 

func (x *TemplateSaveRequest) GetExtra() map[string]string

func (*TemplateSaveRequest) GetLanguageCode added in v1.9.0 

func (x *TemplateSaveRequest) GetLanguageCode() string

func (*TemplateSaveRequest) GetName added in v1.9.0 

func (x *TemplateSaveRequest) GetName() string

func (*TemplateSaveRequest) ProtoMessage added in v1.9.0 

func (*TemplateSaveRequest) ProtoMessage()

func (*TemplateSaveRequest) ProtoReflect added in v1.9.0 

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

func (*TemplateSaveRequest) Reset added in v1.9.0 

func (x *TemplateSaveRequest) Reset()

func (*TemplateSaveRequest) String added in v1.9.0 

func (x *TemplateSaveRequest) String() string

type TemplateSaveResponse added in v1.9.0 

type TemplateSaveResponse struct {
	Data *Template `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*TemplateSaveResponse) Descriptor deprecated added in v1.9.0 

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

Deprecated: Use TemplateSaveResponse.ProtoReflect.Descriptor instead.

func (*TemplateSaveResponse) GetData added in v1.9.0 

func (x *TemplateSaveResponse) GetData() *Template

func (*TemplateSaveResponse) ProtoMessage added in v1.9.0 

func (*TemplateSaveResponse) ProtoMessage()

func (*TemplateSaveResponse) ProtoReflect added in v1.9.0 

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

func (*TemplateSaveResponse) Reset added in v1.9.0 

func (x *TemplateSaveResponse) Reset()

func (*TemplateSaveResponse) String added in v1.9.0 

func (x *TemplateSaveResponse) String() string

type TemplateSearchRequest added in v1.9.0 

type TemplateSearchRequest struct {
	Query        string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	LanguageCode string `protobuf:"bytes,2,opt,name=language_code,json=languageCode,proto3" json:"language_code,omitempty"`
	Page         int64  `protobuf:"varint,3,opt,name=page,proto3" json:"page,omitempty"`
	Count        int32  `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*TemplateSearchRequest) Descriptor deprecated added in v1.9.0 

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

Deprecated: Use TemplateSearchRequest.ProtoReflect.Descriptor instead.

func (*TemplateSearchRequest) GetCount added in v1.9.0 

func (x *TemplateSearchRequest) GetCount() int32

func (*TemplateSearchRequest) GetLanguageCode added in v1.9.0 

func (x *TemplateSearchRequest) GetLanguageCode() string

func (*TemplateSearchRequest) GetPage added in v1.9.0 

func (x *TemplateSearchRequest) GetPage() int64

func (*TemplateSearchRequest) GetQuery added in v1.9.0 

func (x *TemplateSearchRequest) GetQuery() string

func (*TemplateSearchRequest) ProtoMessage added in v1.9.0 

func (*TemplateSearchRequest) ProtoMessage()

func (*TemplateSearchRequest) ProtoReflect added in v1.9.0 

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

func (*TemplateSearchRequest) Reset added in v1.9.0 

func (x *TemplateSearchRequest) Reset()

func (*TemplateSearchRequest) String added in v1.9.0 

func (x *TemplateSearchRequest) String() string

type TemplateSearchResponse added in v1.9.0 

type TemplateSearchResponse struct {
	Data []*Template `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*TemplateSearchResponse) Descriptor deprecated added in v1.9.0 

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

Deprecated: Use TemplateSearchResponse.ProtoReflect.Descriptor instead.

func (*TemplateSearchResponse) GetData added in v1.9.0 

func (x *TemplateSearchResponse) GetData() []*Template

func (*TemplateSearchResponse) ProtoMessage added in v1.9.0 

func (*TemplateSearchResponse) ProtoMessage()

func (*TemplateSearchResponse) ProtoReflect added in v1.9.0 

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

func (*TemplateSearchResponse) Reset added in v1.9.0 

func (x *TemplateSearchResponse) Reset()

func (*TemplateSearchResponse) String added in v1.9.0 

func (x *TemplateSearchResponse) String() string

type UnimplementedNotificationServiceServer 

type UnimplementedNotificationServiceServer struct{}

UnimplementedNotificationServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedNotificationServiceServer) Receive 

func (UnimplementedNotificationServiceServer) Receive(context.Context, *ReceiveRequest) (*ReceiveResponse, error)

func (UnimplementedNotificationServiceServer) Release 

func (UnimplementedNotificationServiceServer) Release(context.Context, *ReleaseRequest) (*ReleaseResponse, error)

func (UnimplementedNotificationServiceServer) Search 

func (UnimplementedNotificationServiceServer) Search(*v1.SearchRequest, grpc.ServerStreamingServer[SearchResponse]) error

func (UnimplementedNotificationServiceServer) Send 

func (UnimplementedNotificationServiceServer) Send(context.Context, *SendRequest) (*SendResponse, error)

func (UnimplementedNotificationServiceServer) Status 

func (UnimplementedNotificationServiceServer) Status(context.Context, *v1.StatusRequest) (*v1.StatusResponse, error)

func (UnimplementedNotificationServiceServer) StatusUpdate 

func (UnimplementedNotificationServiceServer) StatusUpdate(context.Context, *v1.StatusUpdateRequest) (*v1.StatusUpdateResponse, error)

func (UnimplementedNotificationServiceServer) TemplateSave added in v1.9.0 

func (UnimplementedNotificationServiceServer) TemplateSave(context.Context, *TemplateSaveRequest) (*TemplateSaveResponse, error)

func (UnimplementedNotificationServiceServer) TemplateSearch added in v1.9.0 

func (UnimplementedNotificationServiceServer) TemplateSearch(*TemplateSearchRequest, grpc.ServerStreamingServer[TemplateSearchResponse]) error

type UnsafeNotificationServiceServer 

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

UnsafeNotificationServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NotificationServiceServer 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.