notificationv1

package
v0.0.0-...-e947567 Latest Latest
Warning

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

 Go to latest Published: Dec 12, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

Code generated by MockGen. DO NOT EDIT. Source: /home/j/code/antinvestor/apis/notification/v1/notification_grpc.pb.go

Generated by this command: 

mockgen -source=/home/j/code/antinvestor/apis/notification/v1/notification_grpc.pb.go -self_package=github.com/antinvestor/apis/notification/v1 -package=notificationv1 -destination=/home/j/code/antinvestor/apis/notification/v1/notification_grpc_mock.go

Package notificationv1 is a generated GoMock package.

Index

Constants

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

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: "Status",
			Handler:    _NotificationService_Status_Handler,
		},
		{
			MethodName: "StatusUpdate",
			Handler:    _NotificationService_StatusUpdate_Handler,
		},
		{
			MethodName: "Release",
			Handler:    _NotificationService_Release_Handler,
		},
		{
			MethodName: "Receive",
			Handler:    _NotificationService_Receive_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Search",
			Handler:       _NotificationService_Search_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 RegisterNotificationServiceServer 

func RegisterNotificationServiceServer(s grpc.ServiceRegistrar, srv NotificationServiceServer)

func ToContext 

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

Types

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 *SearchRequest, opts ...grpc.CallOption) (NotificationService_SearchClient, 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 *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)

Status mocks base method.

func (*MockNotificationServiceClient) StatusUpdate 

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

StatusUpdate 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.

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 *SearchRequest, arg1 NotificationService_SearchServer) 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 *StatusRequest) (*StatusResponse, error)

Status mocks base method.

func (*MockNotificationServiceServer) StatusUpdate 

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

StatusUpdate 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.

type MockNotificationService_SearchClient 

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

MockNotificationService_SearchClient is a mock of NotificationService_SearchClient interface.

func NewMockNotificationService_SearchClient 

func NewMockNotificationService_SearchClient(ctrl *gomock.Controller) *MockNotificationService_SearchClient

NewMockNotificationService_SearchClient creates a new mock instance.

func (*MockNotificationService_SearchClient) CloseSend 

func (m *MockNotificationService_SearchClient) CloseSend() error

CloseSend mocks base method.

func (*MockNotificationService_SearchClient) Context 

func (m *MockNotificationService_SearchClient) Context() context.Context

Context mocks base method.

func (*MockNotificationService_SearchClient) EXPECT 

func (m *MockNotificationService_SearchClient) EXPECT() *MockNotificationService_SearchClientMockRecorder

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

func (*MockNotificationService_SearchClient) Header 

func (m *MockNotificationService_SearchClient) Header() (metadata.MD, error)

Header mocks base method.

func (*MockNotificationService_SearchClient) Recv 

func (m *MockNotificationService_SearchClient) Recv() (*SearchResponse, error)

Recv mocks base method.

func (*MockNotificationService_SearchClient) RecvMsg 

func (m_2 *MockNotificationService_SearchClient) RecvMsg(m any) error

RecvMsg mocks base method.

func (*MockNotificationService_SearchClient) SendMsg 

func (m_2 *MockNotificationService_SearchClient) SendMsg(m any) error

SendMsg mocks base method.

func (*MockNotificationService_SearchClient) Trailer 

func (m *MockNotificationService_SearchClient) Trailer() metadata.MD

Trailer mocks base method.

type MockNotificationService_SearchClientMockRecorder 

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

MockNotificationService_SearchClientMockRecorder is the mock recorder for MockNotificationService_SearchClient.

func (*MockNotificationService_SearchClientMockRecorder) CloseSend 

func (mr *MockNotificationService_SearchClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend.

func (*MockNotificationService_SearchClientMockRecorder) Context 

func (mr *MockNotificationService_SearchClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockNotificationService_SearchClientMockRecorder) Header 

func (mr *MockNotificationService_SearchClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header.

func (*MockNotificationService_SearchClientMockRecorder) Recv 

func (mr *MockNotificationService_SearchClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockNotificationService_SearchClientMockRecorder) RecvMsg 

func (mr *MockNotificationService_SearchClientMockRecorder) RecvMsg(m any) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockNotificationService_SearchClientMockRecorder) SendMsg 

func (mr *MockNotificationService_SearchClientMockRecorder) SendMsg(m any) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockNotificationService_SearchClientMockRecorder) Trailer 

func (mr *MockNotificationService_SearchClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer.

type MockNotificationService_SearchServer 

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

MockNotificationService_SearchServer is a mock of NotificationService_SearchServer interface.

func NewMockNotificationService_SearchServer 

func NewMockNotificationService_SearchServer(ctrl *gomock.Controller) *MockNotificationService_SearchServer

NewMockNotificationService_SearchServer creates a new mock instance.

func (*MockNotificationService_SearchServer) Context 

func (m *MockNotificationService_SearchServer) Context() context.Context

Context mocks base method.

func (*MockNotificationService_SearchServer) EXPECT 

func (m *MockNotificationService_SearchServer) EXPECT() *MockNotificationService_SearchServerMockRecorder

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

func (*MockNotificationService_SearchServer) RecvMsg 

func (m_2 *MockNotificationService_SearchServer) RecvMsg(m any) error

RecvMsg mocks base method.

func (*MockNotificationService_SearchServer) Send 

func (m *MockNotificationService_SearchServer) Send(arg0 *SearchResponse) error

Send mocks base method.

func (*MockNotificationService_SearchServer) SendHeader 

func (m *MockNotificationService_SearchServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method.

func (*MockNotificationService_SearchServer) SendMsg 

func (m_2 *MockNotificationService_SearchServer) SendMsg(m any) error

SendMsg mocks base method.

func (*MockNotificationService_SearchServer) SetHeader 

func (m *MockNotificationService_SearchServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method.

func (*MockNotificationService_SearchServer) SetTrailer 

func (m *MockNotificationService_SearchServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method.

type MockNotificationService_SearchServerMockRecorder 

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

MockNotificationService_SearchServerMockRecorder is the mock recorder for MockNotificationService_SearchServer.

func (*MockNotificationService_SearchServerMockRecorder) Context 

func (mr *MockNotificationService_SearchServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockNotificationService_SearchServerMockRecorder) RecvMsg 

func (mr *MockNotificationService_SearchServerMockRecorder) RecvMsg(m any) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockNotificationService_SearchServerMockRecorder) Send 

func (mr *MockNotificationService_SearchServerMockRecorder) Send(arg0 any) *gomock.Call

Send indicates an expected call of Send.

func (*MockNotificationService_SearchServerMockRecorder) SendHeader 

func (mr *MockNotificationService_SearchServerMockRecorder) SendHeader(arg0 any) *gomock.Call

SendHeader indicates an expected call of SendHeader.

func (*MockNotificationService_SearchServerMockRecorder) SendMsg 

func (mr *MockNotificationService_SearchServerMockRecorder) SendMsg(m any) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockNotificationService_SearchServerMockRecorder) SetHeader 

func (mr *MockNotificationService_SearchServerMockRecorder) SetHeader(arg0 any) *gomock.Call

SetHeader indicates an expected call of SetHeader.

func (*MockNotificationService_SearchServerMockRecorder) SetTrailer 

func (mr *MockNotificationService_SearchServerMockRecorder) SetTrailer(arg0 any) *gomock.Call

SetTrailer indicates an expected call of SetTrailer.

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 {
	AccessId  string `protobuf:"bytes,1,opt,name=access_id,json=accessId,proto3" json:"access_id,omitempty"`
	Id        string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	ProfileId string `protobuf:"bytes,3,opt,name=profile_id,json=profileId,proto3" json:"profile_id,omitempty"`
	// Types that are assignable to Contact:
	//
	//	*Notification_ContactId
	//	*Notification_Detail
	Contact     isNotification_Contact `protobuf_oneof:"contact"`
	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      *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) GetAccessId 

func (x *Notification) GetAccessId() string

func (*Notification) GetAutoRelease 

func (x *Notification) GetAutoRelease() bool

func (*Notification) GetContact 

func (m *Notification) GetContact() isNotification_Contact

func (*Notification) GetContactId 

func (x *Notification) GetContactId() string

func (*Notification) GetData 

func (x *Notification) GetData() string

func (*Notification) GetDetail 

func (x *Notification) GetDetail() 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) GetPayload 

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

func (*Notification) GetPriority 

func (x *Notification) GetPriority() PRIORITY

func (*Notification) GetProfileId 

func (x *Notification) GetProfileId() string

func (*Notification) GetRouteId 

func (x *Notification) GetRouteId() string

func (*Notification) GetStatus 

func (x *Notification) GetStatus() *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 {
	// contains filtered or unexported fields
}

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 InstantiateNotificationClient 

func InstantiateNotificationClient(clientConnection *grpc.ClientConn, notificationServiceCli NotificationServiceClient) *NotificationClient

InstantiateNotificationClient creates a new notification client.

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

func NewNotificationClient 

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

NewNotificationClient creates a new notification client.

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

func (*NotificationClient) Close 

func (nc *NotificationClient) Close() error

Close closes the connection to the API service. The user should invoke this when the client is no longer required.

func (*NotificationClient) Receive 

func (nc *NotificationClient) Receive(ctx context.Context, accessID string, contactId string, contactDetail string,
	language string, template string, variables map[string]string, extras map[string]string) (*ReceiveResponse, error)

func (*NotificationClient) Send 

func (nc *NotificationClient) Send(ctx context.Context, accessID string, contactId string, contactDetail string,
	language string, template string, variables map[string]string) (*SendResponse, error)

func (*NotificationClient) Service 

func (nc *NotificationClient) Service() NotificationServiceClient

Service creates a new notification service for use to invoke.

func (*NotificationClient) UpdateStatus 

func (nc *NotificationClient) UpdateStatus(ctx context.Context, notificationId string, accessId string,
	externalId string, extras map[string]string) (*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)
	// Status request to determine if notification is prepared or released
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	// Status update request to allow continuation of notification processing
	StatusUpdate(ctx context.Context, in *StatusUpdateRequest, opts ...grpc.CallOption) (*StatusUpdateResponse, 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 *SearchRequest, opts ...grpc.CallOption) (NotificationService_SearchClient, 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)
	// Status request to determine if notification is prepared or released
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
	// Status update request to allow continuation of notification processing
	StatusUpdate(context.Context, *StatusUpdateRequest) (*StatusUpdateResponse, 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(*SearchRequest, NotificationService_SearchServer) 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 interface {
	Recv() (*SearchResponse, error)
	grpc.ClientStream
}

type NotificationService_SearchServer 

type NotificationService_SearchServer interface {
	Send(*SearchResponse) error
	grpc.ServerStream
}

type Notification_ContactId 

type Notification_ContactId struct {
	ContactId string `protobuf:"bytes,4,opt,name=contact_id,json=contactId,proto3,oneof"`
}

type Notification_Detail 

type Notification_Detail struct {
	Detail string `protobuf:"bytes,5,opt,name=detail,proto3,oneof"`
}

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 *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() *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 {
	AccessId string `protobuf:"bytes,1,opt,name=access_id,json=accessId,proto3" json:"access_id,omitempty"`
	Id       string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Comment  string `protobuf:"bytes,3,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) GetAccessId 

func (x *ReleaseRequest) GetAccessId() string

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 *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() *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 SearchRequest 

type SearchRequest struct {
	Query      string            `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	Page       int64             `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"`
	Count      int32             `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	StartDate  string            `protobuf:"bytes,4,opt,name=start_date,json=startDate,proto3" json:"start_date,omitempty"`
	EndDate    string            `protobuf:"bytes,5,opt,name=end_date,json=endDate,proto3" json:"end_date,omitempty"`
	Properties []string          `protobuf:"bytes,6,rep,name=properties,proto3" json:"properties,omitempty"`
	Extras     map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SearchRequest) Descriptor deprecated 

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

Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.

func (*SearchRequest) GetCount 

func (x *SearchRequest) GetCount() int32

func (*SearchRequest) GetEndDate 

func (x *SearchRequest) GetEndDate() string

func (*SearchRequest) GetExtras 

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

func (*SearchRequest) GetPage 

func (x *SearchRequest) GetPage() int64

func (*SearchRequest) GetProperties 

func (x *SearchRequest) GetProperties() []string

func (*SearchRequest) GetQuery 

func (x *SearchRequest) GetQuery() string

func (*SearchRequest) GetStartDate 

func (x *SearchRequest) GetStartDate() string

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) ProtoReflect 

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

func (*SearchRequest) Reset 

func (x *SearchRequest) Reset()

func (*SearchRequest) String 

func (x *SearchRequest) 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 *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() *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 StatusRequest 

type StatusRequest struct {
	Id     string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Extras map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StatusRequest) Descriptor deprecated 

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

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) GetExtras 

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

func (*StatusRequest) GetId 

func (x *StatusRequest) GetId() string

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) ProtoReflect 

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

func (*StatusRequest) Reset 

func (x *StatusRequest) Reset()

func (*StatusRequest) String 

func (x *StatusRequest) String() string

type StatusResponse 

type StatusResponse struct {
	Id          string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State       v1.STATE          `protobuf:"varint,2,opt,name=state,proto3,enum=common.v1.STATE" json:"state,omitempty"`
	Status      v1.STATUS         `protobuf:"varint,3,opt,name=status,proto3,enum=common.v1.STATUS" json:"status,omitempty"`
	ExternalId  string            `protobuf:"bytes,4,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"`
	TransientId string            `protobuf:"bytes,5,opt,name=transient_id,json=transientId,proto3" json:"transient_id,omitempty"`
	Extras      map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StatusResponse) Descriptor deprecated 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetExternalId 

func (x *StatusResponse) GetExternalId() string

func (*StatusResponse) GetExtras 

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

func (*StatusResponse) GetId 

func (x *StatusResponse) GetId() string

func (*StatusResponse) GetState 

func (x *StatusResponse) GetState() v1.STATE

func (*StatusResponse) GetStatus 

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

func (*StatusResponse) GetTransientId 

func (x *StatusResponse) GetTransientId() string

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect 

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

func (*StatusResponse) Reset 

func (x *StatusResponse) Reset()

func (*StatusResponse) String 

func (x *StatusResponse) String() string

type StatusUpdateRequest 

type StatusUpdateRequest struct {
	AccessId   string            `protobuf:"bytes,1,opt,name=access_id,json=accessId,proto3" json:"access_id,omitempty"`
	Id         string            `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	State      v1.STATE          `protobuf:"varint,3,opt,name=state,proto3,enum=common.v1.STATE" json:"state,omitempty"`
	Status     v1.STATUS         `protobuf:"varint,4,opt,name=status,proto3,enum=common.v1.STATUS" json:"status,omitempty"`
	ExternalId string            `protobuf:"bytes,5,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"`
	Extras     map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StatusUpdateRequest) Descriptor deprecated 

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

Deprecated: Use StatusUpdateRequest.ProtoReflect.Descriptor instead.

func (*StatusUpdateRequest) GetAccessId 

func (x *StatusUpdateRequest) GetAccessId() string

func (*StatusUpdateRequest) GetExternalId 

func (x *StatusUpdateRequest) GetExternalId() string

func (*StatusUpdateRequest) GetExtras 

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

func (*StatusUpdateRequest) GetId 

func (x *StatusUpdateRequest) GetId() string

func (*StatusUpdateRequest) GetState 

func (x *StatusUpdateRequest) GetState() v1.STATE

func (*StatusUpdateRequest) GetStatus 

func (x *StatusUpdateRequest) GetStatus() v1.STATUS

func (*StatusUpdateRequest) ProtoMessage 

func (*StatusUpdateRequest) ProtoMessage()

func (*StatusUpdateRequest) ProtoReflect 

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

func (*StatusUpdateRequest) Reset 

func (x *StatusUpdateRequest) Reset()

func (*StatusUpdateRequest) String 

func (x *StatusUpdateRequest) String() string

type StatusUpdateResponse 

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

func (*StatusUpdateResponse) Descriptor deprecated 

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

Deprecated: Use StatusUpdateResponse.ProtoReflect.Descriptor instead.

func (*StatusUpdateResponse) GetData 

func (x *StatusUpdateResponse) GetData() *StatusResponse

func (*StatusUpdateResponse) ProtoMessage 

func (*StatusUpdateResponse) ProtoMessage()

func (*StatusUpdateResponse) ProtoReflect 

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

func (*StatusUpdateResponse) Reset 

func (x *StatusUpdateResponse) Reset()

func (*StatusUpdateResponse) String 

func (x *StatusUpdateResponse) String() string

type UnimplementedNotificationServiceServer 

type UnimplementedNotificationServiceServer struct {
}

UnimplementedNotificationServiceServer must be embedded to have forward compatible implementations.

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(*SearchRequest, NotificationService_SearchServer) error

func (UnimplementedNotificationServiceServer) Send 

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

func (UnimplementedNotificationServiceServer) Status 

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

func (UnimplementedNotificationServiceServer) StatusUpdate 

func (UnimplementedNotificationServiceServer) StatusUpdate(context.Context, *StatusUpdateRequest) (*StatusUpdateResponse, 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.