protos

package
v1.1.0-4 Latest Latest
Warning

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

 Go to latest Published: Dec 27, 2022 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_protos_msgdistribution_v1_proto protoreflect.FileDescriptor
View Source 
var MessageDistribution_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "msgdistribution_v1.MessageDistribution",
	HandlerType: (*MessageDistributionServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "send_message",
			Handler:    _MessageDistribution_SendMessage_Handler,
		},
		{
			MethodName: "send_messages",
			Handler:    _MessageDistribution_SendMessages_Handler,
		},
		{
			MethodName: "send_message_to_recipient",
			Handler:    _MessageDistribution_SendMessageToRecipient_Handler,
		},
		{
			MethodName: "send_message_to_recipients",
			Handler:    _MessageDistribution_SendMessageToRecipients_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/msgdistribution_v1.proto",
}

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

Functions

func RegisterMessageDistributionServer 

func RegisterMessageDistributionServer(s grpc.ServiceRegistrar, srv MessageDistributionServer)

Types

type ErrorDescription 

type ErrorDescription struct {
	Type          string            `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Category      string            `protobuf:"bytes,2,opt,name=category,proto3" json:"category,omitempty"`
	Code          string            `protobuf:"bytes,3,opt,name=code,proto3" json:"code,omitempty"`
	CorrelationId string            `protobuf:"bytes,4,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Status        string            `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	Message       string            `protobuf:"bytes,6,opt,name=message,proto3" json:"message,omitempty"`
	Cause         string            `protobuf:"bytes,7,opt,name=cause,proto3" json:"cause,omitempty"`
	StackTrace    string            `protobuf:"bytes,8,opt,name=stack_trace,json=stackTrace,proto3" json:"stack_trace,omitempty"`
	Details       map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ErrorDescription) Descriptor deprecated 

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

Deprecated: Use ErrorDescription.ProtoReflect.Descriptor instead.

func (*ErrorDescription) GetCategory 

func (x *ErrorDescription) GetCategory() string

func (*ErrorDescription) GetCause 

func (x *ErrorDescription) GetCause() string

func (*ErrorDescription) GetCode 

func (x *ErrorDescription) GetCode() string

func (*ErrorDescription) GetCorrelationId 

func (x *ErrorDescription) GetCorrelationId() string

func (*ErrorDescription) GetDetails 

func (x *ErrorDescription) GetDetails() map[string]string

func (*ErrorDescription) GetMessage 

func (x *ErrorDescription) GetMessage() string

func (*ErrorDescription) GetStackTrace 

func (x *ErrorDescription) GetStackTrace() string

func (*ErrorDescription) GetStatus 

func (x *ErrorDescription) GetStatus() string

func (*ErrorDescription) GetType 

func (x *ErrorDescription) GetType() string

func (*ErrorDescription) ProtoMessage 

func (*ErrorDescription) ProtoMessage()

func (*ErrorDescription) ProtoReflect 

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

func (*ErrorDescription) Reset 

func (x *ErrorDescription) Reset()

func (*ErrorDescription) String 

func (x *ErrorDescription) String() string

type Message 

type Message struct {
	Template string `protobuf:"bytes,1,opt,name=template,proto3" json:"template,omitempty"`
	From     string `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
	Cc       string `protobuf:"bytes,3,opt,name=cc,proto3" json:"cc,omitempty"`
	Bcc      string `protobuf:"bytes,4,opt,name=bcc,proto3" json:"bcc,omitempty"`
	ReplyTo  string `protobuf:"bytes,5,opt,name=reply_to,json=replyTo,proto3" json:"reply_to,omitempty"`
	Subject  string `protobuf:"bytes,6,opt,name=subject,proto3" json:"subject,omitempty"`
	Text     string `protobuf:"bytes,7,opt,name=text,proto3" json:"text,omitempty"`
	Html     string `protobuf:"bytes,8,opt,name=html,proto3" json:"html,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetBcc 

func (x *Message) GetBcc() string

func (*Message) GetCc 

func (x *Message) GetCc() string

func (*Message) GetFrom 

func (x *Message) GetFrom() string

func (*Message) GetHtml 

func (x *Message) GetHtml() string

func (*Message) GetReplyTo 

func (x *Message) GetReplyTo() string

func (*Message) GetSubject 

func (x *Message) GetSubject() string

func (*Message) GetTemplate 

func (x *Message) GetTemplate() string

func (*Message) GetText 

func (x *Message) GetText() string

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

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

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

type MessageDistributionClient 

type MessageDistributionClient interface {
	SendMessage(ctx context.Context, in *SendMessageRequest, opts ...grpc.CallOption) (*SendEmptyReply, error)
	SendMessages(ctx context.Context, in *SendMessagesRequest, opts ...grpc.CallOption) (*SendEmptyReply, error)
	SendMessageToRecipient(ctx context.Context, in *SendMessageWithRecipientRequest, opts ...grpc.CallOption) (*SendEmptyReply, error)
	SendMessageToRecipients(ctx context.Context, in *SendMessageWithRecipientsRequest, opts ...grpc.CallOption) (*SendEmptyReply, error)
}

MessageDistributionClient is the client API for MessageDistribution 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 NewMessageDistributionClient 

func NewMessageDistributionClient(cc grpc.ClientConnInterface) MessageDistributionClient

type MessageDistributionServer 

type MessageDistributionServer interface {
	SendMessage(context.Context, *SendMessageRequest) (*SendEmptyReply, error)
	SendMessages(context.Context, *SendMessagesRequest) (*SendEmptyReply, error)
	SendMessageToRecipient(context.Context, *SendMessageWithRecipientRequest) (*SendEmptyReply, error)
	SendMessageToRecipients(context.Context, *SendMessageWithRecipientsRequest) (*SendEmptyReply, error)
	// contains filtered or unexported methods
}

MessageDistributionServer is the server API for MessageDistribution service. All implementations must embed UnimplementedMessageDistributionServer for forward compatibility

type Recipient 

type Recipient struct {
	Id       string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name     string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Email    string `protobuf:"bytes,3,opt,name=email,proto3" json:"email,omitempty"`
	Phone    string `protobuf:"bytes,4,opt,name=phone,proto3" json:"phone,omitempty"`
	Language string `protobuf:"bytes,5,opt,name=language,proto3" json:"language,omitempty"`
	// contains filtered or unexported fields
}

func (*Recipient) Descriptor deprecated 

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

Deprecated: Use Recipient.ProtoReflect.Descriptor instead.

func (*Recipient) GetEmail 

func (x *Recipient) GetEmail() string

func (*Recipient) GetId 

func (x *Recipient) GetId() string

func (*Recipient) GetLanguage 

func (x *Recipient) GetLanguage() string

func (*Recipient) GetName 

func (x *Recipient) GetName() string

func (*Recipient) GetPhone 

func (x *Recipient) GetPhone() string

func (*Recipient) ProtoMessage 

func (*Recipient) ProtoMessage()

func (*Recipient) ProtoReflect 

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

func (*Recipient) Reset 

func (x *Recipient) Reset()

func (*Recipient) String 

func (x *Recipient) String() string

type SendEmptyReply 

type SendEmptyReply struct {
	Error *ErrorDescription `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

The response message containing the send empty response

func (*SendEmptyReply) Descriptor deprecated 

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

Deprecated: Use SendEmptyReply.ProtoReflect.Descriptor instead.

func (*SendEmptyReply) GetError 

func (x *SendEmptyReply) GetError() *ErrorDescription

func (*SendEmptyReply) ProtoMessage 

func (*SendEmptyReply) ProtoMessage()

func (*SendEmptyReply) ProtoReflect 

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

func (*SendEmptyReply) Reset 

func (x *SendEmptyReply) Reset()

func (*SendEmptyReply) String 

func (x *SendEmptyReply) String() string

type SendMessageRequest 

type SendMessageRequest struct {
	CorrelationId string            `protobuf:"bytes,1,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Method        string            `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Message       *Message          `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Parameters    map[string]string `` /* 161-byte string literal not displayed */
	Recipient     *Recipient        `protobuf:"bytes,5,opt,name=recipient,proto3" json:"recipient,omitempty"`
	// contains filtered or unexported fields
}

The request message containing the send message request.

func (*SendMessageRequest) Descriptor deprecated 

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

Deprecated: Use SendMessageRequest.ProtoReflect.Descriptor instead.

func (*SendMessageRequest) GetCorrelationId 

func (x *SendMessageRequest) GetCorrelationId() string

func (*SendMessageRequest) GetMessage 

func (x *SendMessageRequest) GetMessage() *Message

func (*SendMessageRequest) GetMethod 

func (x *SendMessageRequest) GetMethod() string

func (*SendMessageRequest) GetParameters 

func (x *SendMessageRequest) GetParameters() map[string]string

func (*SendMessageRequest) GetRecipient 

func (x *SendMessageRequest) GetRecipient() *Recipient

func (*SendMessageRequest) ProtoMessage 

func (*SendMessageRequest) ProtoMessage()

func (*SendMessageRequest) ProtoReflect 

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

func (*SendMessageRequest) Reset 

func (x *SendMessageRequest) Reset()

func (*SendMessageRequest) String 

func (x *SendMessageRequest) String() string

type SendMessageWithRecipientRequest 

type SendMessageWithRecipientRequest struct {
	CorrelationId string            `protobuf:"bytes,1,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Method        string            `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Message       *Message          `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Parameters    map[string]string `` /* 161-byte string literal not displayed */
	Subscription  string            `protobuf:"bytes,5,opt,name=subscription,proto3" json:"subscription,omitempty"`
	RecipientId   string            `protobuf:"bytes,6,opt,name=recipient_id,json=recipientId,proto3" json:"recipient_id,omitempty"`
	// contains filtered or unexported fields
}

The request message containing the send message with recipient request.

func (*SendMessageWithRecipientRequest) Descriptor deprecated 

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

Deprecated: Use SendMessageWithRecipientRequest.ProtoReflect.Descriptor instead.

func (*SendMessageWithRecipientRequest) GetCorrelationId 

func (x *SendMessageWithRecipientRequest) GetCorrelationId() string

func (*SendMessageWithRecipientRequest) GetMessage 

func (x *SendMessageWithRecipientRequest) GetMessage() *Message

func (*SendMessageWithRecipientRequest) GetMethod 

func (x *SendMessageWithRecipientRequest) GetMethod() string

func (*SendMessageWithRecipientRequest) GetParameters 

func (x *SendMessageWithRecipientRequest) GetParameters() map[string]string

func (*SendMessageWithRecipientRequest) GetRecipientId 

func (x *SendMessageWithRecipientRequest) GetRecipientId() string

func (*SendMessageWithRecipientRequest) GetSubscription 

func (x *SendMessageWithRecipientRequest) GetSubscription() string

func (*SendMessageWithRecipientRequest) ProtoMessage 

func (*SendMessageWithRecipientRequest) ProtoMessage()

func (*SendMessageWithRecipientRequest) ProtoReflect 

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

func (*SendMessageWithRecipientRequest) Reset 

func (x *SendMessageWithRecipientRequest) Reset()

func (*SendMessageWithRecipientRequest) String 

func (x *SendMessageWithRecipientRequest) String() string

type SendMessageWithRecipientsRequest 

type SendMessageWithRecipientsRequest struct {
	CorrelationId string            `protobuf:"bytes,1,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Method        string            `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Message       *Message          `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Parameters    map[string]string `` /* 161-byte string literal not displayed */
	Subscription  string            `protobuf:"bytes,5,opt,name=subscription,proto3" json:"subscription,omitempty"`
	RecipientIds  []string          `protobuf:"bytes,6,rep,name=recipient_ids,json=recipientIds,proto3" json:"recipient_ids,omitempty"`
	// contains filtered or unexported fields
}

The request message containing the email message with recipients request.

func (*SendMessageWithRecipientsRequest) Descriptor deprecated 

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

Deprecated: Use SendMessageWithRecipientsRequest.ProtoReflect.Descriptor instead.

func (*SendMessageWithRecipientsRequest) GetCorrelationId 

func (x *SendMessageWithRecipientsRequest) GetCorrelationId() string

func (*SendMessageWithRecipientsRequest) GetMessage 

func (x *SendMessageWithRecipientsRequest) GetMessage() *Message

func (*SendMessageWithRecipientsRequest) GetMethod 

func (x *SendMessageWithRecipientsRequest) GetMethod() string

func (*SendMessageWithRecipientsRequest) GetParameters 

func (x *SendMessageWithRecipientsRequest) GetParameters() map[string]string

func (*SendMessageWithRecipientsRequest) GetRecipientIds 

func (x *SendMessageWithRecipientsRequest) GetRecipientIds() []string

func (*SendMessageWithRecipientsRequest) GetSubscription 

func (x *SendMessageWithRecipientsRequest) GetSubscription() string

func (*SendMessageWithRecipientsRequest) ProtoMessage 

func (*SendMessageWithRecipientsRequest) ProtoMessage()

func (*SendMessageWithRecipientsRequest) ProtoReflect 

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

func (*SendMessageWithRecipientsRequest) Reset 

func (x *SendMessageWithRecipientsRequest) Reset()

func (*SendMessageWithRecipientsRequest) String 

func (x *SendMessageWithRecipientsRequest) String() string

type SendMessagesRequest 

type SendMessagesRequest struct {
	CorrelationId string            `protobuf:"bytes,1,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Method        string            `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Message       *Message          `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Parameters    map[string]string `` /* 161-byte string literal not displayed */
	Recipients    []*Recipient      `protobuf:"bytes,5,rep,name=recipients,proto3" json:"recipients,omitempty"`
	// contains filtered or unexported fields
}

The request message containing the send messages request.

func (*SendMessagesRequest) Descriptor deprecated 

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

Deprecated: Use SendMessagesRequest.ProtoReflect.Descriptor instead.

func (*SendMessagesRequest) GetCorrelationId 

func (x *SendMessagesRequest) GetCorrelationId() string

func (*SendMessagesRequest) GetMessage 

func (x *SendMessagesRequest) GetMessage() *Message

func (*SendMessagesRequest) GetMethod 

func (x *SendMessagesRequest) GetMethod() string

func (*SendMessagesRequest) GetParameters 

func (x *SendMessagesRequest) GetParameters() map[string]string

func (*SendMessagesRequest) GetRecipients 

func (x *SendMessagesRequest) GetRecipients() []*Recipient

func (*SendMessagesRequest) ProtoMessage 

func (*SendMessagesRequest) ProtoMessage()

func (*SendMessagesRequest) ProtoReflect 

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

func (*SendMessagesRequest) Reset 

func (x *SendMessagesRequest) Reset()

func (*SendMessagesRequest) String 

func (x *SendMessagesRequest) String() string

type UnimplementedMessageDistributionServer 

type UnimplementedMessageDistributionServer struct {
}

UnimplementedMessageDistributionServer must be embedded to have forward compatible implementations.

func (UnimplementedMessageDistributionServer) SendMessage 

func (UnimplementedMessageDistributionServer) SendMessage(context.Context, *SendMessageRequest) (*SendEmptyReply, error)

func (UnimplementedMessageDistributionServer) SendMessageToRecipient 

func (UnimplementedMessageDistributionServer) SendMessageToRecipient(context.Context, *SendMessageWithRecipientRequest) (*SendEmptyReply, error)

func (UnimplementedMessageDistributionServer) SendMessageToRecipients 

func (UnimplementedMessageDistributionServer) SendMessageToRecipients(context.Context, *SendMessageWithRecipientsRequest) (*SendEmptyReply, error)

func (UnimplementedMessageDistributionServer) SendMessages 

func (UnimplementedMessageDistributionServer) SendMessages(context.Context, *SendMessagesRequest) (*SendEmptyReply, error)

type UnsafeMessageDistributionServer 

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

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