Documentation ¶
Index ¶
- Constants
- type IMessageDistributionClientV1
- type MessageDistributionCommandableGrpcClientV1
- func (c *MessageDistributionCommandableGrpcClientV1) SendMessage(ctx context.Context, correlationId string, recipient *RecipientV1, ...) (err error)
- func (c *MessageDistributionCommandableGrpcClientV1) SendMessageToRecipient(ctx context.Context, correlationId string, recipientId string, ...) (err error)
- func (c *MessageDistributionCommandableGrpcClientV1) SendMessageToRecipients(ctx context.Context, correlationId string, recipientIds []string, ...) (err error)
- func (c *MessageDistributionCommandableGrpcClientV1) SendMessages(ctx context.Context, correlationId string, recipients []*RecipientV1, ...) (err error)
- type MessageDistributionGrpcClientV1
- func (c *MessageDistributionGrpcClientV1) SendMessage(ctx context.Context, correlationId string, recipient *RecipientV1, ...) (err error)
- func (c *MessageDistributionGrpcClientV1) SendMessageToRecipient(ctx context.Context, correlationId string, recipientId string, ...) (err error)
- func (c *MessageDistributionGrpcClientV1) SendMessageToRecipients(ctx context.Context, correlationId string, recipientIds []string, ...) (err error)
- func (c *MessageDistributionGrpcClientV1) SendMessages(ctx context.Context, correlationId string, recipients []*RecipientV1, ...) (err error)
- type MessageDistributionHttpClientV1
- func (c *MessageDistributionHttpClientV1) SendMessage(ctx context.Context, correlationId string, recipient *RecipientV1, ...) (err error)
- func (c *MessageDistributionHttpClientV1) SendMessageToRecipient(ctx context.Context, correlationId string, recipientId string, ...) (err error)
- func (c *MessageDistributionHttpClientV1) SendMessageToRecipients(ctx context.Context, correlationId string, recipientIds []string, ...) (err error)
- func (c *MessageDistributionHttpClientV1) SendMessages(ctx context.Context, correlationId string, recipients []*RecipientV1, ...) (err error)
- type MessageDistributionNullClientV1
- func (c *MessageDistributionNullClientV1) SendMessage(ctx context.Context, correlationId string, recipient *RecipientV1, ...) error
- func (c *MessageDistributionNullClientV1) SendMessageToRecipient(ctx context.Context, correlationId string, recipientId string, ...) error
- func (c *MessageDistributionNullClientV1) SendMessageToRecipients(ctx context.Context, correlationId string, recipientIds []string, ...) error
- func (c *MessageDistributionNullClientV1) SendMessages(ctx context.Context, correlationId string, recipients []*RecipientV1, ...) error
- type MessageResolverV1
- type MessageV1
- type RecipientV1
Constants ¶
View Source
const ( Email = "email" Sms = "sms" All = "all" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IMessageDistributionClientV1 ¶
type IMessageDistributionClientV1 interface { SendMessage(ctx context.Context, correlationId string, recipient *RecipientV1, message *MessageV1, parameters *cconf.ConfigParams, method string) error SendMessages(ctx context.Context, correlationId string, recipients []*RecipientV1, message *MessageV1, parameters *cconf.ConfigParams, method string) error SendMessageToRecipient(ctx context.Context, correlationId string, recipientId string, subscription string, message *MessageV1, parameters *cconf.ConfigParams, method string) error SendMessageToRecipients(ctx context.Context, correlationId string, recipientIds []string, subscription string, message *MessageV1, parameters *cconf.ConfigParams, method string) error }
type MessageDistributionCommandableGrpcClientV1 ¶
type MessageDistributionCommandableGrpcClientV1 struct { *clients.CommandableGrpcClient // contains filtered or unexported fields }
func NewMessageDistributionCommandableGrpcClientV1 ¶
func NewMessageDistributionCommandableGrpcClientV1() *MessageDistributionCommandableGrpcClientV1
func NewMessageDistributionCommandableGrpcClientV1WithConfig ¶
func NewMessageDistributionCommandableGrpcClientV1WithConfig(config *cconf.ConfigParams) *MessageDistributionCommandableGrpcClientV1
func (*MessageDistributionCommandableGrpcClientV1) SendMessage ¶
func (c *MessageDistributionCommandableGrpcClientV1) SendMessage(ctx context.Context, correlationId string, recipient *RecipientV1, message *MessageV1, parameters *cconf.ConfigParams, method string) (err error)
func (*MessageDistributionCommandableGrpcClientV1) SendMessageToRecipient ¶
func (*MessageDistributionCommandableGrpcClientV1) SendMessageToRecipients ¶
func (*MessageDistributionCommandableGrpcClientV1) SendMessages ¶
func (c *MessageDistributionCommandableGrpcClientV1) SendMessages(ctx context.Context, correlationId string, recipients []*RecipientV1, message *MessageV1, parameters *cconf.ConfigParams, method string) (err error)
type MessageDistributionGrpcClientV1 ¶
type MessageDistributionGrpcClientV1 struct { *clients.GrpcClient // contains filtered or unexported fields }
func NewMessageDistributionGrpcClientV1 ¶
func NewMessageDistributionGrpcClientV1() *MessageDistributionGrpcClientV1
func NewMessageDistributionGrpcClientV1WithConfig ¶
func NewMessageDistributionGrpcClientV1WithConfig(config *cconf.ConfigParams) *MessageDistributionGrpcClientV1
func (*MessageDistributionGrpcClientV1) SendMessage ¶
func (c *MessageDistributionGrpcClientV1) SendMessage(ctx context.Context, correlationId string, recipient *RecipientV1, message *MessageV1, parameters *cconf.ConfigParams, method string) (err error)
func (*MessageDistributionGrpcClientV1) SendMessageToRecipient ¶
func (*MessageDistributionGrpcClientV1) SendMessageToRecipients ¶
func (*MessageDistributionGrpcClientV1) SendMessages ¶
func (c *MessageDistributionGrpcClientV1) SendMessages(ctx context.Context, correlationId string, recipients []*RecipientV1, message *MessageV1, parameters *cconf.ConfigParams, method string) (err error)
type MessageDistributionHttpClientV1 ¶
type MessageDistributionHttpClientV1 struct { *cclnt.CommandableHttpClient // contains filtered or unexported fields }
func NewMessageDistributionHttpClientV1 ¶
func NewMessageDistributionHttpClientV1() *MessageDistributionHttpClientV1
func NewMessageDistributionHttpClientV1WithConfig ¶
func NewMessageDistributionHttpClientV1WithConfig(config *cconf.ConfigParams) *MessageDistributionHttpClientV1
func (*MessageDistributionHttpClientV1) SendMessage ¶
func (c *MessageDistributionHttpClientV1) SendMessage(ctx context.Context, correlationId string, recipient *RecipientV1, message *MessageV1, parameters *cconf.ConfigParams, method string) (err error)
func (*MessageDistributionHttpClientV1) SendMessageToRecipient ¶
func (*MessageDistributionHttpClientV1) SendMessageToRecipients ¶
func (*MessageDistributionHttpClientV1) SendMessages ¶
func (c *MessageDistributionHttpClientV1) SendMessages(ctx context.Context, correlationId string, recipients []*RecipientV1, message *MessageV1, parameters *cconf.ConfigParams, method string) (err error)
type MessageDistributionNullClientV1 ¶
type MessageDistributionNullClientV1 struct { }
func NewMessageDistributionNullClientV1 ¶
func NewMessageDistributionNullClientV1() *MessageDistributionNullClientV1
func (*MessageDistributionNullClientV1) SendMessage ¶
func (c *MessageDistributionNullClientV1) SendMessage(ctx context.Context, correlationId string, recipient *RecipientV1, message *MessageV1, parameters *cconf.ConfigParams, method string) error
func (*MessageDistributionNullClientV1) SendMessageToRecipient ¶
func (*MessageDistributionNullClientV1) SendMessageToRecipients ¶
func (*MessageDistributionNullClientV1) SendMessages ¶
func (c *MessageDistributionNullClientV1) SendMessages(ctx context.Context, correlationId string, recipients []*RecipientV1, message *MessageV1, parameters *cconf.ConfigParams, method string) error
type MessageResolverV1 ¶
type MessageResolverV1 struct {
// contains filtered or unexported fields
}
func NewMessageResolverV1 ¶
func NewMessageResolverV1() *MessageResolverV1
func NewMessageResolverV1FromTuples ¶
func NewMessageResolverV1FromTuples(tuples ...any) *MessageResolverV1
func NewMessageResolverV1WithConfig ¶
func NewMessageResolverV1WithConfig(config *cconf.ConfigParams) *MessageResolverV1
func (*MessageResolverV1) Configure ¶
func (c *MessageResolverV1) Configure(ctx context.Context, config *cconf.ConfigParams)
func (*MessageResolverV1) Put ¶
func (c *MessageResolverV1) Put(name string, template any)
func (*MessageResolverV1) Resolve ¶
func (c *MessageResolverV1) Resolve(name string) *MessageV1
type MessageV1 ¶
type MessageV1 struct { Template string `json:"template,omitempty"` From string `json:"from,omitempty"` Cc string `json:"cc,omitempty"` Bcc string `json:"bcc,omitempty"` ReplyTo string `json:"reply_to,omitempty"` Subject any `json:"subject,omitempty"` Text any `json:"text,omitempty"` Html any `json:"html,omitempty"` }
func NewEmptyMessageV1 ¶
func NewEmptyMessageV1() *MessageV1
type RecipientV1 ¶
type RecipientV1 struct { Id string `json:"id,omitempty"` Name string `json:"name,omitempty"` Email string `json:"email,omitempty"` Phone string `json:"phone,omitempty"` Language string `json:"language,omitempty"` }
func NewEmptyRecipientV1 ¶
func NewEmptyRecipientV1() *RecipientV1
func NewRecipientV1 ¶
func NewRecipientV1(id, name, email string) *RecipientV1
Source Files ¶
Click to show internal directories.
Click to hide internal directories.