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
- Variables
- func RegisterNotificationServiceServer(s grpc.ServiceRegistrar, srv NotificationServiceServer)
- func ToContext(ctx context.Context, client *NotificationClient) context.Context
- type MockNotificationServiceClient
- func (m *MockNotificationServiceClient) EXPECT() *MockNotificationServiceClientMockRecorder
- func (m *MockNotificationServiceClient) Receive(ctx context.Context, in *ReceiveRequest, opts ...grpc.CallOption) (*ReceiveResponse, error)
- func (m *MockNotificationServiceClient) Release(ctx context.Context, in *ReleaseRequest, opts ...grpc.CallOption) (*ReleaseResponse, error)
- func (m *MockNotificationServiceClient) Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (NotificationService_SearchClient, error)
- func (m *MockNotificationServiceClient) Send(ctx context.Context, in *SendRequest, opts ...grpc.CallOption) (*SendResponse, error)
- func (m *MockNotificationServiceClient) Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
- func (m *MockNotificationServiceClient) StatusUpdate(ctx context.Context, in *StatusUpdateRequest, opts ...grpc.CallOption) (*StatusUpdateResponse, error)
- type MockNotificationServiceClientMockRecorder
- func (mr *MockNotificationServiceClientMockRecorder) Receive(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockNotificationServiceClientMockRecorder) Release(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockNotificationServiceClientMockRecorder) Search(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockNotificationServiceClientMockRecorder) Send(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockNotificationServiceClientMockRecorder) Status(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockNotificationServiceClientMockRecorder) StatusUpdate(ctx, in any, opts ...any) *gomock.Call
- type MockNotificationServiceServer
- func (m *MockNotificationServiceServer) EXPECT() *MockNotificationServiceServerMockRecorder
- func (m *MockNotificationServiceServer) Receive(arg0 context.Context, arg1 *ReceiveRequest) (*ReceiveResponse, error)
- func (m *MockNotificationServiceServer) Release(arg0 context.Context, arg1 *ReleaseRequest) (*ReleaseResponse, error)
- func (m *MockNotificationServiceServer) Search(arg0 *SearchRequest, arg1 NotificationService_SearchServer) error
- func (m *MockNotificationServiceServer) Send(arg0 context.Context, arg1 *SendRequest) (*SendResponse, error)
- func (m *MockNotificationServiceServer) Status(arg0 context.Context, arg1 *StatusRequest) (*StatusResponse, error)
- func (m *MockNotificationServiceServer) StatusUpdate(arg0 context.Context, arg1 *StatusUpdateRequest) (*StatusUpdateResponse, error)
- type MockNotificationServiceServerMockRecorder
- func (mr *MockNotificationServiceServerMockRecorder) Receive(arg0, arg1 any) *gomock.Call
- func (mr *MockNotificationServiceServerMockRecorder) Release(arg0, arg1 any) *gomock.Call
- func (mr *MockNotificationServiceServerMockRecorder) Search(arg0, arg1 any) *gomock.Call
- func (mr *MockNotificationServiceServerMockRecorder) Send(arg0, arg1 any) *gomock.Call
- func (mr *MockNotificationServiceServerMockRecorder) Status(arg0, arg1 any) *gomock.Call
- func (mr *MockNotificationServiceServerMockRecorder) StatusUpdate(arg0, arg1 any) *gomock.Call
- type MockNotificationService_SearchClient
- func (m *MockNotificationService_SearchClient) CloseSend() error
- func (m *MockNotificationService_SearchClient) Context() context.Context
- func (m *MockNotificationService_SearchClient) EXPECT() *MockNotificationService_SearchClientMockRecorder
- func (m *MockNotificationService_SearchClient) Header() (metadata.MD, error)
- func (m *MockNotificationService_SearchClient) Recv() (*SearchResponse, error)
- func (m_2 *MockNotificationService_SearchClient) RecvMsg(m any) error
- func (m_2 *MockNotificationService_SearchClient) SendMsg(m any) error
- func (m *MockNotificationService_SearchClient) Trailer() metadata.MD
- type MockNotificationService_SearchClientMockRecorder
- func (mr *MockNotificationService_SearchClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockNotificationService_SearchClientMockRecorder) Context() *gomock.Call
- func (mr *MockNotificationService_SearchClientMockRecorder) Header() *gomock.Call
- func (mr *MockNotificationService_SearchClientMockRecorder) Recv() *gomock.Call
- func (mr *MockNotificationService_SearchClientMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockNotificationService_SearchClientMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockNotificationService_SearchClientMockRecorder) Trailer() *gomock.Call
- type MockNotificationService_SearchServer
- func (m *MockNotificationService_SearchServer) Context() context.Context
- func (m *MockNotificationService_SearchServer) EXPECT() *MockNotificationService_SearchServerMockRecorder
- func (m_2 *MockNotificationService_SearchServer) RecvMsg(m any) error
- func (m *MockNotificationService_SearchServer) Send(arg0 *SearchResponse) error
- func (m *MockNotificationService_SearchServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockNotificationService_SearchServer) SendMsg(m any) error
- func (m *MockNotificationService_SearchServer) SetHeader(arg0 metadata.MD) error
- func (m *MockNotificationService_SearchServer) SetTrailer(arg0 metadata.MD)
- type MockNotificationService_SearchServerMockRecorder
- func (mr *MockNotificationService_SearchServerMockRecorder) Context() *gomock.Call
- func (mr *MockNotificationService_SearchServerMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockNotificationService_SearchServerMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockNotificationService_SearchServerMockRecorder) SendHeader(arg0 any) *gomock.Call
- func (mr *MockNotificationService_SearchServerMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockNotificationService_SearchServerMockRecorder) SetHeader(arg0 any) *gomock.Call
- func (mr *MockNotificationService_SearchServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
- type MockUnsafeNotificationServiceServer
- type MockUnsafeNotificationServiceServerMockRecorder
- type Notification
- func (*Notification) Descriptor() ([]byte, []int)deprecated
- func (x *Notification) GetAccessId() string
- func (x *Notification) GetAutoRelease() bool
- func (m *Notification) GetContact() isNotification_Contact
- func (x *Notification) GetContactId() string
- func (x *Notification) GetData() string
- func (x *Notification) GetDetail() string
- func (x *Notification) GetExtras() map[string]string
- func (x *Notification) GetId() string
- func (x *Notification) GetLanguage() string
- func (x *Notification) GetOutBound() bool
- func (x *Notification) GetPayload() map[string]string
- func (x *Notification) GetPriority() PRIORITY
- func (x *Notification) GetProfileId() string
- func (x *Notification) GetRouteId() string
- func (x *Notification) GetStatus() *StatusResponse
- func (x *Notification) GetTemplate() string
- func (x *Notification) GetType() string
- func (*Notification) ProtoMessage()
- func (x *Notification) ProtoReflect() protoreflect.Message
- func (x *Notification) Reset()
- func (x *Notification) String() string
- type NotificationClient
- func (nc *NotificationClient) Close() error
- func (nc *NotificationClient) Receive(ctx context.Context, accessID string, contactId string, contactDetail string, ...) (*ReceiveResponse, error)
- func (nc *NotificationClient) Send(ctx context.Context, accessID string, contactId string, contactDetail string, ...) (*SendResponse, error)
- func (nc *NotificationClient) Service() NotificationServiceClient
- func (nc *NotificationClient) UpdateStatus(ctx context.Context, notificationId string, accessId string, externalId string, ...) (*StatusUpdateResponse, error)
- type NotificationServiceClient
- type NotificationServiceServer
- type NotificationService_SearchClient
- type NotificationService_SearchServer
- type Notification_ContactId
- type Notification_Detail
- type PRIORITY
- type ReceiveRequest
- type ReceiveResponse
- type ReleaseRequest
- func (*ReleaseRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReleaseRequest) GetAccessId() string
- func (x *ReleaseRequest) GetComment() string
- func (x *ReleaseRequest) GetId() string
- func (*ReleaseRequest) ProtoMessage()
- func (x *ReleaseRequest) ProtoReflect() protoreflect.Message
- func (x *ReleaseRequest) Reset()
- func (x *ReleaseRequest) String() string
- type ReleaseResponse
- type SearchRequest
- func (*SearchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SearchRequest) GetCount() int32
- func (x *SearchRequest) GetEndDate() string
- func (x *SearchRequest) GetExtras() map[string]string
- func (x *SearchRequest) GetPage() int64
- func (x *SearchRequest) GetProperties() []string
- func (x *SearchRequest) GetQuery() string
- func (x *SearchRequest) GetStartDate() string
- func (*SearchRequest) ProtoMessage()
- func (x *SearchRequest) ProtoReflect() protoreflect.Message
- func (x *SearchRequest) Reset()
- func (x *SearchRequest) String() string
- type SearchResponse
- type SendRequest
- type SendResponse
- type StatusRequest
- func (*StatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StatusRequest) GetExtras() map[string]string
- func (x *StatusRequest) GetId() string
- func (*StatusRequest) ProtoMessage()
- func (x *StatusRequest) ProtoReflect() protoreflect.Message
- func (x *StatusRequest) Reset()
- func (x *StatusRequest) String() string
- type StatusResponse
- func (*StatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StatusResponse) GetExternalId() string
- func (x *StatusResponse) GetExtras() map[string]string
- func (x *StatusResponse) GetId() string
- func (x *StatusResponse) GetState() v1.STATE
- func (x *StatusResponse) GetStatus() v1.STATUS
- func (x *StatusResponse) GetTransientId() string
- func (*StatusResponse) ProtoMessage()
- func (x *StatusResponse) ProtoReflect() protoreflect.Message
- func (x *StatusResponse) Reset()
- func (x *StatusResponse) String() string
- type StatusUpdateRequest
- func (*StatusUpdateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StatusUpdateRequest) GetAccessId() string
- func (x *StatusUpdateRequest) GetExternalId() string
- func (x *StatusUpdateRequest) GetExtras() map[string]string
- func (x *StatusUpdateRequest) GetId() string
- func (x *StatusUpdateRequest) GetState() v1.STATE
- func (x *StatusUpdateRequest) GetStatus() v1.STATUS
- func (*StatusUpdateRequest) ProtoMessage()
- func (x *StatusUpdateRequest) ProtoReflect() protoreflect.Message
- func (x *StatusUpdateRequest) Reset()
- func (x *StatusUpdateRequest) String() string
- type StatusUpdateResponse
- func (*StatusUpdateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StatusUpdateResponse) GetData() *StatusResponse
- func (*StatusUpdateResponse) ProtoMessage()
- func (x *StatusUpdateResponse) ProtoReflect() protoreflect.Message
- func (x *StatusUpdateResponse) Reset()
- func (x *StatusUpdateResponse) String() string
- type UnimplementedNotificationServiceServer
- func (UnimplementedNotificationServiceServer) Receive(context.Context, *ReceiveRequest) (*ReceiveResponse, error)
- func (UnimplementedNotificationServiceServer) Release(context.Context, *ReleaseRequest) (*ReleaseResponse, error)
- func (UnimplementedNotificationServiceServer) Search(*SearchRequest, NotificationService_SearchServer) error
- func (UnimplementedNotificationServiceServer) Send(context.Context, *SendRequest) (*SendResponse, error)
- func (UnimplementedNotificationServiceServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)
- func (UnimplementedNotificationServiceServer) StatusUpdate(context.Context, *StatusUpdateRequest) (*StatusUpdateResponse, error)
- type UnsafeNotificationServiceServer
Constants ¶
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 ¶
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.
var File_notification_v1_notification_proto protoreflect.FileDescriptor
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)
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) 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
func (PRIORITY) Descriptor ¶
func (PRIORITY) Descriptor() protoreflect.EnumDescriptor
func (PRIORITY) EnumDescriptor
deprecated
func (PRIORITY) Number ¶
func (x PRIORITY) Number() protoreflect.EnumNumber
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) 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.