entities

package
v0.0.15 Latest Latest
Warning

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

 Go to latest Published: Nov 15, 2021 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ApiErrorResponse 

type ApiErrorResponse struct {
	Code    int64  `json:"code,omitempty"`
	Error   string `json:"error"`
	Message string `json:"message,omitempty"`
}

LoginErrorResponse entity

func NewApiErrorResponse added in v0.0.7 

func NewApiErrorResponse(code int64, err string, message string) *ApiErrorResponse

NewApiSuccessResponse Creates a new API Success Response struct

type ApiSuccessResponse 

type ApiSuccessResponse struct {
	Code    int64                  `json:"code,omitempty"`
	Message string                 `json:"message"`
	Data    map[string]interface{} `json:"data,omitempty"`
}

ApiSuccessResponse entity

func NewApiSuccessResponse added in v0.0.7 

func NewApiSuccessResponse(code int64, message string, data map[string]interface{}) *ApiSuccessResponse

NewApiSuccessResponse Creates a new API Success Response struct

type BulkMessageRequest added in v0.0.7 

type BulkMessageRequest struct {
	Messages []MessageRequest `json:"messages"`
}

type BulkMessageResponse added in v0.0.7 

type BulkMessageResponse struct {
	SuccessCount int `json:"successCount"`
	ErrorCount   int `json:"errorCount"`
}

type BulkTemplateMessageRequest added in v0.0.7 

type BulkTemplateMessageRequest struct {
	TotalMessages             int            `json:"totalMessages"`
	Template                  MessageRequest `json:"template"`
	BatchOf                   int            `json:"batchOf"`
	WaitBetweenBatchesInMilli int            `json:"waitBetweenBatchesInMilli"`
}

type ConfigRequest added in v0.0.7 

type ConfigRequest struct {
	ConnectionString string `json:"connectionString"`
}

Forward struct

type CountDetails added in v0.0.7 

type CountDetails struct {
	ActiveMessageCount             *int32 `json:"activeMessageCount"`
	DeadLetterMessageCount         *int32 `json:"deadLetterMessageCount"`
	ScheduledMessageCount          *int32 `json:"scheduledMessageCount"`
	TransferDeadLetterMessageCount *int32 `json:"transferDeadLetterMessageCount"`
	TransferMessageCount           *int32 `json:"transferMessageCount"`
}

func (*CountDetails) FromServiceBus added in v0.0.7 

func (c *CountDetails) FromServiceBus(countDetails *servicebus.CountDetails)

type Forward added in v0.0.7 

type Forward struct {
	To string
	In ForwardDestination
}

Forward struct

type ForwardDestination added in v0.0.7 

type ForwardDestination int

ForwardDestination Enum 

const (
	ForwardToTopic ForwardDestination = iota
	ForwardToQueue
)

ForwardingDestination Enum definition

func (ForwardDestination) MarshalJSON added in v0.0.7 

func (s ForwardDestination) MarshalJSON() ([]byte, error)

MarshalJSON Custom Marsheller of ForwardingDestinationEntity Enum to JSON

func (ForwardDestination) String added in v0.0.7 

func (s ForwardDestination) String() string

String Gets the ForwardingDestinationEntity Enum string representation

func (*ForwardDestination) UnmarshalJSON added in v0.0.7 

func (s *ForwardDestination) UnmarshalJSON(b []byte) error

UnmarshalJSON Custom UnMarsheller of ForwardingDestinationEntity Enum to JSON

type MessageRequest added in v0.0.7 

type MessageRequest struct {
	Label          string                 `json:"label"`
	CorrelationID  string                 `json:"correlationId"`
	ContentType    string                 `json:"contentType"`
	Data           map[string]interface{} `json:"data"`
	UserProperties map[string]interface{} `json:"userProperties"`
}

func (*MessageRequest) FromFile added in v0.0.7 

func (m *MessageRequest) FromFile(filePath string) error

func (*MessageRequest) FromServiceBus added in v0.0.7 

func (m *MessageRequest) FromServiceBus(msg *servicebus.Message) error

func (*MessageRequest) ToServiceBus added in v0.0.7 

func (m *MessageRequest) ToServiceBus() (*servicebus.Message, error)

type MessageResponse added in v0.0.7 

type MessageResponse struct {
	ID             string                 `json:"id"`
	Label          string                 `json:"label"`
	CorrelationID  string                 `json:"correlationId"`
	ContentType    string                 `json:"contentType"`
	Data           map[string]interface{} `json:"data"`
	UserProperties map[string]interface{} `json:"userProperties"`
}

func (*MessageResponse) FromServiceBus added in v0.0.7 

func (m *MessageResponse) FromServiceBus(msg *servicebus.Message) error

type QueueRequest added in v0.0.7 

type QueueRequest struct {
	Name              string               `json:"name"`
	MaxDeliveryCount  int32                `json:"maxDeliveryCount"`
	Forward           *Forward             `json:"forward"`
	ForwardDeadLetter *Forward             `json:"forwardDeadLetter"`
	Options           *QueueRequestOptions `json:"options,omitempty"`
}

QueueEntity structure

func NewQueueRequest 

func NewQueueRequest(name string) *QueueRequest

NewQueue Creates a Queue entity

func (*QueueRequest) FromFile added in v0.0.7 

func (q *QueueRequest) FromFile(filePath string) error

func (*QueueRequest) GetOptions added in v0.0.7 

func (q *QueueRequest) GetOptions() (*[]servicebus.QueueManagementOption, *ApiErrorResponse)

func (*QueueRequest) IsValid added in v0.0.7 

func (q *QueueRequest) IsValid() (bool, *ApiErrorResponse)

func (*QueueRequest) MapDeadLetterForwardFlag added in v0.0.7 

func (q *QueueRequest) MapDeadLetterForwardFlag(value string)

MapDeadLetterForwardFlag Maps a forward dead letter flag string into it's sub components

func (*QueueRequest) MapMessageForwardFlag added in v0.0.7 

func (q *QueueRequest) MapMessageForwardFlag(value string)

MapMessageForwardFlag Maps a forward flag string into it's sub components

type QueueRequestOptions 

type QueueRequestOptions struct {
	AutoDeleteOnIdle                 *string `json:"autoDeleteOnIdle,omitempty"`
	EnableDuplicateDetection         *string `json:"enableDuplicateDetection,omitempty"`
	MaxSizeInMegabytes               *int    `json:"maxSizeInMegabytes,omitempty"`
	DefaultMessageTimeToLive         *string `json:"defaultMessageTimeToLive,omitempty"`
	LockDuration                     *string `json:"lockDuration,omitempty"`
	SupportOrdering                  *bool   `json:"supportOrdering,omitempty"`
	EnablePartitioning               *bool   `json:"enablePartitioning,omitempty"`
	RequireSession                   *bool   `json:"requireSession,omitempty"`
	DeadLetteringOnMessageExpiration *bool   `json:"deadLetteringOnMessageExpiration,omitempty"`
}

type QueueResponse added in v0.0.7 

type QueueResponse struct {
	Name                                string             `json:"name"`
	ID                                  string             `json:"id"`
	CountDetails                        CountDetails       `json:"countDetails"`
	LockDuration                        *duration.Duration `json:"lockDuration"`
	MaxSizeInMegabytes                  *int32             `json:"maxSizeInMegabytes"`
	RequiresDuplicateDetection          *bool              `json:"requiresDuplicateDetection"`
	RequiresSession                     *bool              `json:"requiresSession"`
	DefaultMessageTimeToLive            *duration.Duration `json:"defaultMessageTimeToLive"`
	DeadLetteringOnMessageExpiration    *bool              `json:"deadLetteringOnMessageExpiration"`
	DuplicateDetectionHistoryTimeWindow *duration.Duration `json:"duplicateDetectionHistoryTimeWindow"`
	MaxDeliveryCount                    *int32             `json:"maxDeliveryCount"`
	EnableBatchedOperations             *bool              `json:"enableBatchedOperations"`
	SizeInBytes                         *int64             `json:"sizeInBytes"`
	MessageCount                        *int64             `json:"messageCount"`
	IsAnonymousAccessible               *bool              `json:"isAnonymousAccessible"`
	Status                              string             `json:"status"`
	CreatedAt                           time.Time          `json:"createdAt"`
	UpdatedAt                           time.Time          `json:"updatedAt"`
	SupportOrdering                     *bool              `json:"supportOrdering"`
	AutoDeleteOnIdle                    *duration.Duration `json:"autoDeleteOnIdle"`
	EnablePartitioning                  *bool              `json:"enablePartitioning"`
	EnableExpress                       *bool              `json:"enableExpress"`
	ForwardTo                           *string            `json:"forwardTo"`
	ForwardDeadLetteredMessagesTo       *string            `json:"forwardDeadLetteredMessagesTo"`
}

QueueResponse

func (*QueueResponse) FromServiceBus added in v0.0.7 

func (q *QueueResponse) FromServiceBus(queue *servicebus.QueueEntity)

type RuleRequest added in v0.0.7 

type RuleRequest struct {
	Name      string `json:"name"`
	SQLFilter string `json:"sqlFilter"`
	SQLAction string `json:"sqlAction"`
}

RuleRequest struct

func (*RuleRequest) FromFile added in v0.0.7 

func (r *RuleRequest) FromFile(filePath string) error

func (*RuleRequest) IsValid added in v0.0.7 

func (r *RuleRequest) IsValid() (bool, *ApiErrorResponse)

type RuleResponse added in v0.0.7 

type RuleResponse struct {
	Name   string             `json:"name"`
	ID     string             `json:"id"`
	Filter RuleResponseFilter `json:"filter"`
	Action RuleResponseAction `json:"action"`
}

func (*RuleResponse) FromServiceBus added in v0.0.7 

func (r *RuleResponse) FromServiceBus(msg *servicebus.RuleEntity) error

type RuleResponseAction added in v0.0.7 

type RuleResponseAction struct {
	Type                  string `json:"type"`
	RequiresPreprocessing bool   `json:"requiresPreprocessing"`
	SQLExpression         string `json:"sqlExpression"`
	CompatibilityLevel    int    `json:"compatibilityLevel"`
}

func (*RuleResponseAction) FromServiceBus added in v0.0.7 

func (e *RuleResponseAction) FromServiceBus(action *servicebus.ActionDescription) error

type RuleResponseFilter added in v0.0.7 

type RuleResponseFilter struct {
	CorrelationID      *string                `json:"correlationID"`
	MessageID          *string                `json:"messageID"`
	To                 *string                `json:"to"`
	ReplyTo            *string                `json:"replyTo"`
	Label              *string                `json:"label"`
	SessionID          *string                `json:"sessionID"`
	ReplyToSessionID   *string                `json:"replyToSessionID"`
	ContentType        *string                `json:"contentType"`
	Properties         map[string]interface{} `json:"properties"`
	Type               string                 `json:"type"`
	SQLExpression      *string                `json:"sqlExpression"`
	CompatibilityLevel int                    `json:"compatibilityLevel"`
}

func (*RuleResponseFilter) FromServiceBus added in v0.0.7 

func (c *RuleResponseFilter) FromServiceBus(filter servicebus.FilterDescription) error

type SubscriptionRequest added in v0.0.7 

type SubscriptionRequest struct {
	Name              string                      `json:"name"`
	TopicName         string                      `json:"topicName"`
	UserDescription   string                      `json:"userDescription"`
	MaxDeliveryCount  int32                       `json:"maxDeliveryCount,omitempty"`
	Forward           *Forward                    `json:"forward,omitempty"`
	ForwardDeadLetter *Forward                    `json:"forwardDeadLetter,omitempty"`
	Rules             []*RuleRequest              `json:"rules,omitempty"`
	Options           *SubscriptionRequestOptions `json:"options,omitempty"`
}

func NewSubscriptionRequest 

func NewSubscriptionRequest(topicName string, name string) *SubscriptionRequest

NewSubscriptionRequest Creates a new subscription entity

func (*SubscriptionRequest) AddSQLAction added in v0.0.7 

func (s *SubscriptionRequest) AddSQLAction(ruleName string, action string)

AddSQLAction Adds a Sql Action to a specific rule

func (*SubscriptionRequest) AddSQLFilter added in v0.0.7 

func (s *SubscriptionRequest) AddSQLFilter(ruleName string, filter string)

AddSQLFilter Adds a Sql filter to a specific Rule

func (*SubscriptionRequest) FromFile added in v0.0.7 

func (s *SubscriptionRequest) FromFile(filePath string) error

func (*SubscriptionRequest) GetOptions added in v0.0.7 

func (s *SubscriptionRequest) GetOptions() (*[]servicebus.SubscriptionManagementOption, *ApiErrorResponse)

func (*SubscriptionRequest) IsValid added in v0.0.7 

func (s *SubscriptionRequest) IsValid() (bool, *ApiErrorResponse)

func (*SubscriptionRequest) MapDeadLetterForwardFlag added in v0.0.7 

func (s *SubscriptionRequest) MapDeadLetterForwardFlag(value string)

MapDeadLetterForwardFlag Maps a forward dead letter flag string into it's sub components

func (*SubscriptionRequest) MapMessageForwardFlag added in v0.0.7 

func (s *SubscriptionRequest) MapMessageForwardFlag(value string)

MapMessageForwardFlag Maps a forward flag string into it's sub components

func (*SubscriptionRequest) MapRuleFlag added in v0.0.7 

func (s *SubscriptionRequest) MapRuleFlag(value string)

MapRuleFlag Maps a rule flag string into it's sub components

type SubscriptionRequestOptions 

type SubscriptionRequestOptions struct {
	AutoDeleteOnIdle                 *string `json:"autoDeleteOnIdle,omitempty"`
	DefaultMessageTimeToLive         *string `json:"defaultMessageTimeToLive,omitempty"`
	LockDuration                     *string `json:"lockDuration,omitempty"`
	EnableBatchedOperation           *bool   `json:"enableBatchedOperation,omitempty"`
	DeadLetteringOnMessageExpiration *bool   `json:"deadLetteringOnMessageExpiration,omitempty"`
	RequireSession                   *bool   `json:"requireSession,omitempty"`
}

SubscriptionRequestOptions Entity

type SubscriptionResponse added in v0.0.7 

type SubscriptionResponse struct {
	Name                                      string            `json:"name"`
	ID                                        string            `json:"url"`
	CountDetails                              CountDetails      `json:"countDetails"`
	LockDuration                              duration.Duration `json:"lockDuration"`
	RequiresSession                           *bool             `json:"requiresSession"`
	DefaultMessageTimeToLive                  duration.Duration `json:"defaultMessageTimeToLive"`
	AutoDeleteOnIdle                          duration.Duration `json:"autoDeleteOnIdle"`
	DeadLetteringOnMessageExpiration          *bool             `json:"deadLetteringOnMessageExpiration"`
	DeadLetteringOnFilterEvaluationExceptions *bool             `json:"deadLetteringOnFilterEvaluationExceptions"`
	MessageCount                              *int64            `json:"messageCount"`
	MaxDeliveryCount                          int64             `json:"maxDeliveryCount"`
	EnableBatchedOperations                   *bool             `json:"enableBatchedOperations"`
	Status                                    string            `json:"status"`
	CreatedAt                                 time.Time         `json:"createdAt"`
	UpdatedAt                                 time.Time         `json:"updatedAt"`
	AccessedAt                                time.Time         `json:"accessedAt"`
	ForwardTo                                 *string           `json:"forwardTo"`
	ForwardDeadLetteredMessagesTo             *string           `json:"forwardDeadLetteredMessagesTo"`
}

func (*SubscriptionResponse) FromServiceBus added in v0.0.7 

func (e *SubscriptionResponse) FromServiceBus(subscription *azservicebus.SubscriptionEntity)

type TopicRequestEntity 

type TopicRequestEntity struct {
	Name    string               `json:"name"`
	Options *TopicRequestOptions `json:"options,omitempty"`
}

func (*TopicRequestEntity) GetOptions 

func (tr *TopicRequestEntity) GetOptions() (*[]servicebus.TopicManagementOption, *ApiErrorResponse)

func (*TopicRequestEntity) IsValid added in v0.0.7 

func (tr *TopicRequestEntity) IsValid() (bool, *ApiErrorResponse)

type TopicRequestOptions 

type TopicRequestOptions struct {
	AutoDeleteOnIdle         *string `json:"autoDeleteOnIdle,omitempty"`
	EnableBatchedOperation   *bool   `json:"enableBatchedOperation,omitempty"`
	EnableDuplicateDetection *string `json:"enableDuplicateDetection,omitempty"`
	EnableExpress            *bool   `json:"enableExpress,omitempty"`
	MaxSizeInMegabytes       *int    `json:"maxSizeInMegabytes,omitempty"`
	DefaultMessageTimeToLive *string `json:"defaultMessageTimeToLive,omitempty"`
	SupportOrdering          *bool   `json:"supportOrdering,omitempty"`
	EnablePartitioning       *bool   `json:"enablePartitioning,omitempty"`
}

type TopicResponseEntity 

type TopicResponseEntity struct {
	Name                                string       `json:"name"`
	ID                                  string       `json:"id"`
	CountDetails                        CountDetails `json:"countDetails,omitempty"`
	DefaultMessageTimeToLive            *string      `json:"defaultMessageTimeToLive"`
	MaxSizeInMegabytes                  *int32       `json:"maxSizeInMegabytes"`
	RequiresDuplicateDetection          *bool        `json:"requiresDuplicateDetection"`
	DuplicateDetectionHistoryTimeWindow *string      `json:"duplicateDetectionHistoryTimeWindow"`
	EnableBatchedOperations             *bool        `json:"enableBatchedOperations"`
	SizeInBytes                         *int64       `json:"sizeInBytes"`
	FilteringMessagesBeforePublishing   *bool        `json:"filteringMessagesBeforePublishing"`
	IsAnonymousAccessible               *bool        `json:"isAnonymousAccessible"`
	Status                              string       `json:"status"`
	CreatedAt                           time.Time    `json:"createdAt"`
	UpdatedAt                           time.Time    `json:"updatedAt"`
	SupportOrdering                     *bool        `json:"supportOrdering"`
	AutoDeleteOnIdle                    *string      `json:"autoDeleteOnIdle"`
	EnablePartitioning                  *bool        `json:"enablePartitioning"`
	EnableSubscriptionPartitioning      *bool        `json:"enableSubscriptionPartitioning"`
	EnableExpress                       *bool        `json:"enableExpress"`
}

func (*TopicResponseEntity) FromServiceBus 

func (t *TopicResponseEntity) FromServiceBus(topic *servicebus.TopicEntity)

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.