Versions in this module Expand all Collapse all v0 v0.1.0 Jul 6, 2018 Changes in this version + const Megabytes + const Version + type BaseEntityDescription struct + InstanceMetadataSchema *string + ServiceBusSchema *string + type CountDetails struct + ActiveMessageCount *int32 + DeadLetterMessageCount *int32 + ScheduledMessageCount *int32 + TransferDeadLetterMessageCount *int32 + TransferMessageCount *int32 + XMLName xml.Name + type DispositionAction func(ctx context.Context) + type Handler func(context.Context, *Message) DispositionAction + type ListenerHandle struct + func (lc *ListenerHandle) Close(ctx context.Context) error + func (lc *ListenerHandle) Done() <-chan struct{} + func (lc *ListenerHandle) Err() error + type Message struct + ContentType string + CorrelationID string + Data []byte + DeliveryCount uint32 + GroupID *string + GroupSequence *uint32 + ID string + Label string + LockToken *uuid.UUID + ReplyTo string + ReplyToGroupID string + SystemProperties *SystemProperties + TTL *time.Duration + To string + UserProperties map[string]interface{} + func NewMessage(data []byte) *Message + func NewMessageFromString(message string) *Message + func (m *Message) Abandon() DispositionAction + func (m *Message) Complete() DispositionAction + func (m *Message) DeadLetter(err error) DispositionAction + func (m *Message) DeadLetterWithInfo(err error, condition MessageErrorCondition, additionalData map[string]string) DispositionAction + func (m *Message) ForeachKey(handler func(key, val string) error) error + func (m *Message) Set(key, value string) + type MessageErrorCondition string + const ErrorDecodeError + const ErrorIllegalState + const ErrorInternalError + const ErrorInvalidField + const ErrorNotAllowed + const ErrorNotFound + const ErrorNotImplemented + const ErrorPreconditionFailed + const ErrorResourceDeleted + const ErrorResourceLimitExceeded + const ErrorResourceLocked + const ErrorUnauthorizedAccess + type MessageWithContext struct + Ctx context.Context + func (m *MessageWithContext) Abandon() + func (m *MessageWithContext) Complete() + func (m *MessageWithContext) DeadLetter(err error) + func (m *MessageWithContext) DeadLetterWithInfo(err error, condition MessageErrorCondition, additionalData map[string]string) + type Namespace struct + Environment azure.Environment + Name string + TokenProvider auth.TokenProvider + func NewNamespace(opts ...NamespaceOption) (*Namespace, error) + func (ns *Namespace) NewQueue(ctx context.Context, name string, opts ...QueueOption) (*Queue, error) + func (ns *Namespace) NewQueueManager() *QueueManager + func (ns *Namespace) NewSubscriptionManager(ctx context.Context, topicName string) (*SubscriptionManager, error) + func (ns *Namespace) NewTopic(ctx context.Context, name string, opts ...TopicOption) (*Topic, error) + func (ns *Namespace) NewTopicManager() *TopicManager + type NamespaceOption func(h *Namespace) error + func NamespaceWithConnectionString(connStr string) NamespaceOption + type Queue struct + func (q *Queue) Close(ctx context.Context) error + func (q *Queue) Receive(ctx context.Context, handler Handler) (*ListenerHandle, error) + func (q *Queue) ReceiveOne(ctx context.Context) (*MessageWithContext, error) + func (q *Queue) Send(ctx context.Context, event *Message) error + type QueueDescription struct + AutoDeleteOnIdle *string + CountDetails *CountDetails + CreatedAt *date.Time + DeadLetteringOnMessageExpiration *bool + DefaultMessageTimeToLive *string + DuplicateDetectionHistoryTimeWindow *string + EnableBatchedOperations *bool + EnableExpress *bool + EnablePartitioning *bool + IsAnonymousAccessible *bool + LockDuration *string + MaxDeliveryCount *int32 + MaxSizeInMegabytes *int32 + MessageCount *int64 + RequiresDuplicateDetection *bool + RequiresSession *bool + SizeInBytes *int64 + Status *servicebus.EntityStatus + SupportOrdering *bool + UpdatedAt *date.Time + XMLName xml.Name + type QueueEntity struct + Name string + type QueueManagementOption func(*QueueDescription) error + func QueueEntityWithAutoDeleteOnIdle(window *time.Duration) QueueManagementOption + func QueueEntityWithDeadLetteringOnMessageExpiration() QueueManagementOption + func QueueEntityWithDuplicateDetection(window *time.Duration) QueueManagementOption + func QueueEntityWithLockDuration(window *time.Duration) QueueManagementOption + func QueueEntityWithMaxDeliveryCount(count int32) QueueManagementOption + func QueueEntityWithMaxSizeInMegabytes(size int) QueueManagementOption + func QueueEntityWithMessageTimeToLive(window *time.Duration) QueueManagementOption + func QueueEntityWithPartitioning() QueueManagementOption + func QueueEntityWithRequiredSessions() QueueManagementOption + type QueueManager struct + func (em QueueManager) Execute(ctx context.Context, method string, entityPath string, body io.Reader) (*http.Response, error) + func (em QueueManager) Post(ctx context.Context, entityPath string, body []byte) (*http.Response, error) + func (qm *QueueManager) Delete(ctx context.Context, name string) error + func (qm *QueueManager) Get(ctx context.Context, name string) (*QueueEntity, error) + func (qm *QueueManager) List(ctx context.Context) ([]*QueueEntity, error) + func (qm *QueueManager) Put(ctx context.Context, name string, opts ...QueueManagementOption) (*QueueEntity, error) + type QueueOption func(*Queue) error + func QueueWithReceiveAndDelete() QueueOption + type ReceiveMode int + const PeekLockMode + const ReceiveAndDeleteMode + type SendOption func(event *Message) error + type Subscription struct + Topic *Topic + func (s *Subscription) Close(ctx context.Context) error + func (s *Subscription) Receive(ctx context.Context, handler Handler) (*ListenerHandle, error) + func (s *Subscription) ReceiveOne(ctx context.Context) (*MessageWithContext, error) + type SubscriptionDescription struct + AccessedAt *date.Time + AutoDeleteOnIdle *string + CreatedAt *date.Time + DeadLetteringOnFilterEvaluationExceptions *bool + DeadLetteringOnMessageExpiration *bool + DefaultMessageTimeToLive *string + EnableBatchedOperations *bool + LockDuration *string + MaxDeliveryCount *int32 + MessageCount *int64 + RequiresSession *bool + Status *servicebus.EntityStatus + UpdatedAt *date.Time + XMLName xml.Name + type SubscriptionEntity struct + Name string + type SubscriptionManagementOption func(*SubscriptionDescription) error + func SubscriptionWithAutoDeleteOnIdle(window *time.Duration) SubscriptionManagementOption + func SubscriptionWithBatchedOperations() SubscriptionManagementOption + func SubscriptionWithDeadLetteringOnMessageExpiration() SubscriptionManagementOption + func SubscriptionWithLockDuration(window *time.Duration) SubscriptionManagementOption + func SubscriptionWithMessageTimeToLive(window *time.Duration) SubscriptionManagementOption + func SubscriptionWithRequiredSessions() SubscriptionManagementOption + type SubscriptionManager struct + Topic *Topic + func (em SubscriptionManager) Execute(ctx context.Context, method string, entityPath string, body io.Reader) (*http.Response, error) + func (em SubscriptionManager) Post(ctx context.Context, entityPath string, body []byte) (*http.Response, error) + func (sm *SubscriptionManager) Delete(ctx context.Context, name string) error + func (sm *SubscriptionManager) Get(ctx context.Context, name string) (*SubscriptionEntity, error) + func (sm *SubscriptionManager) List(ctx context.Context) ([]*SubscriptionEntity, error) + func (sm *SubscriptionManager) Put(ctx context.Context, name string, opts ...SubscriptionManagementOption) (*SubscriptionEntity, error) + type SubscriptionOption func(*Subscription) error + func SubscriptionWithReceiveAndDelete() SubscriptionOption + type SystemProperties struct + DeadLetterSource *string + EnqueuedSequenceNumber *int64 + EnqueuedTime *time.Time + LockedUntil *time.Time + PartitionID *int16 + PartitionKey *string + ScheduledEnqueueTime *time.Time + SequenceNumber *int64 + ViaPartitionKey *string + type Topic struct + func (t *Topic) Close(ctx context.Context) error + func (t *Topic) NewSubscription(ctx context.Context, name string, opts ...SubscriptionOption) (*Subscription, error) + func (t *Topic) NewSubscriptionManager() *SubscriptionManager + func (t *Topic) Send(ctx context.Context, event *Message, opts ...SendOption) error + type TopicDescription struct + AutoDeleteOnIdle *string + CountDetails *CountDetails + CreatedAt *date.Time + DefaultMessageTimeToLive *string + DuplicateDetectionHistoryTimeWindow *string + EnableBatchedOperations *bool + EnableExpress *bool + EnablePartitioning *bool + EnableSubscriptionPartitioning *bool + FilteringMessagesBeforePublishing *bool + IsAnonymousAccessible *bool + MaxSizeInMegabytes *int32 + RequiresDuplicateDetection *bool + SizeInBytes *int64 + Status *servicebus.EntityStatus + SupportOrdering *bool + UpdatedAt *date.Time + XMLName xml.Name + type TopicEntity struct + Name string + type TopicManagementOption func(*TopicDescription) error + func TopicWithAutoDeleteOnIdle(window *time.Duration) TopicManagementOption + func TopicWithBatchedOperations() TopicManagementOption + func TopicWithDuplicateDetection(window *time.Duration) TopicManagementOption + func TopicWithExpress() TopicManagementOption + func TopicWithMaxSizeInMegabytes(size int) TopicManagementOption + func TopicWithMessageTimeToLive(window *time.Duration) TopicManagementOption + func TopicWithOrdering() TopicManagementOption + func TopicWithPartitioning() TopicManagementOption + type TopicManager struct + func (em TopicManager) Execute(ctx context.Context, method string, entityPath string, body io.Reader) (*http.Response, error) + func (em TopicManager) Post(ctx context.Context, entityPath string, body []byte) (*http.Response, error) + func (tm *TopicManager) Delete(ctx context.Context, name string) error + func (tm *TopicManager) Get(ctx context.Context, name string) (*TopicEntity, error) + func (tm *TopicManager) List(ctx context.Context) ([]*TopicEntity, error) + func (tm *TopicManager) Put(ctx context.Context, name string, opts ...TopicManagementOption) (*TopicEntity, error) + type TopicOption func(*Topic) error
Go to main page