Versions in this module Expand all Collapse all v3 v3.3.39 Oct 20, 2022 Changes in this version + const DefaultConsumerGroup + const MsftVendor + const Version + var ErrMessageIsTooBig = errors.New("message is too big") + func ApplyComponentInfo(span tab.Spanner) + type BaseEntityDescription struct + InstanceMetadataSchema *string + ServiceBusSchema *string + type BatchIterator interface + Done func() bool + Next func(messageID string, opts *BatchOptions) (*EventBatch, error) + type BatchOption func(opt *BatchOptions) error + func BatchWithMaxSizeInBytes(sizeInBytes int) BatchOption + type BatchOptions struct + MaxSize MaxMessageSizeInBytes + type ErrNoMessages struct + func (e ErrNoMessages) Error() string + type Event struct + Data []byte + ID string + PartitionKey *string + Properties map[string]interface{} + RawAMQPMessage struct{ ... } + SystemProperties *SystemProperties + func NewEvent(data []byte) *Event + func NewEventFromString(message string) *Event + func (e *Event) Get(key string) (interface{}, bool) + func (e *Event) GetCheckpoint() persist.Checkpoint + func (e *Event) GetKeyValues() map[string]interface{} + func (e *Event) Set(key string, value interface{}) + type EventBatch struct + MaxSize MaxMessageSizeInBytes + func NewEventBatch(eventID string, opts *BatchOptions) *EventBatch + func (eb *EventBatch) Add(e *Event) (bool, error) + func (eb *EventBatch) Clear() + func (eb *EventBatch) Size() int + type EventBatchIterator struct + Cursors map[string]int + PartitionEventsMap map[string][]*Event + func NewEventBatchIterator(events ...*Event) *EventBatchIterator + func (ebi *EventBatchIterator) Done() bool + func (ebi *EventBatchIterator) Next(eventID string, opts *BatchOptions) (*EventBatch, error) + type Handler func(ctx context.Context, event *Event) error + type Hub struct + func NewHub(namespace, name string, tokenProvider auth.TokenProvider, opts ...HubOption) (*Hub, error) + func NewHubFromConnectionString(connStr string, opts ...HubOption) (*Hub, error) + func NewHubFromEnvironment(opts ...HubOption) (*Hub, error) + func NewHubWithNamespaceNameAndEnvironment(namespace, name string, opts ...HubOption) (*Hub, error) + func (h *Hub) Close(ctx context.Context) error + func (h *Hub) GetPartitionInformation(ctx context.Context, partitionID string) (*HubPartitionRuntimeInformation, error) + func (h *Hub) GetRuntimeInformation(ctx context.Context) (*HubRuntimeInformation, error) + func (h *Hub) Receive(ctx context.Context, partitionID string, handler Handler, ...) (*ListenerHandle, error) + func (h *Hub) Send(ctx context.Context, event *Event, opts ...SendOption) error + func (h *Hub) SendBatch(ctx context.Context, iterator BatchIterator, opts ...BatchOption) error + type HubDescription struct + CreatedAt *date.Time + EntityAvailabilityStatus *string + MessageRetentionInDays *int32 + PartitionCount *int32 + PartitionIDs *[]string + SizeInBytes *int64 + Status *eventhub.EntityStatus + UpdatedAt *date.Time + XMLName xml.Name + type HubEntity struct + Name string + type HubManagementOption func(description *HubDescription) error + func HubWithMessageRetentionInDays(days int32) HubManagementOption + func HubWithPartitionCount(count int32) HubManagementOption + type HubManager struct + func NewHubManagerFromAzureEnvironment(namespace string, tokenProvider auth.TokenProvider, env azure.Environment) (*HubManager, error) + func NewHubManagerFromConnectionString(connStr string) (*HubManager, error) + func (em HubManager) Execute(ctx context.Context, method string, entityPath string, body io.Reader) (*http.Response, error) + func (em HubManager) Post(ctx context.Context, entityPath string, body []byte) (*http.Response, error) + func (hm *HubManager) Delete(ctx context.Context, name string) error + func (hm *HubManager) Get(ctx context.Context, name string) (*HubEntity, error) + func (hm *HubManager) List(ctx context.Context) ([]*HubEntity, error) + func (hm *HubManager) Put(ctx context.Context, name string, opts ...HubManagementOption) (*HubEntity, error) + type HubOption func(h *Hub) error + func HubWithEnvironment(env azure.Environment) HubOption + func HubWithOffsetPersistence(offsetPersister persist.CheckpointPersister) HubOption + func HubWithPartitionedSender(partitionID string) HubOption + func HubWithSenderMaxRetryCount(maxRetryCount int) HubOption + func HubWithUserAgent(userAgent string) HubOption + func HubWithWebSocketConnection() HubOption + type HubPartitionRuntimeInformation struct + BeginningSequenceNumber int64 + HubPath string + LastEnqueuedOffset string + LastEnqueuedTimeUtc time.Time + LastSequenceNumber int64 + PartitionID string + type HubRuntimeInformation struct + CreatedAt time.Time + PartitionCount int + PartitionIDs []string + Path string + type ListenerHandle struct + func (lc *ListenerHandle) Close(ctx context.Context) error + func (lc *ListenerHandle) Done() <-chan struct{} + func (lc *ListenerHandle) Err() error + type Manager interface + GetPartitionInformation func(context.Context, string) (HubPartitionRuntimeInformation, error) + GetRuntimeInformation func(context.Context) (HubRuntimeInformation, error) + type MaxMessageSizeInBytes uint + const DefaultMaxMessageSizeInBytes + const KeyOfNoPartitionKey + type PartitionedReceiver interface + Receive func(ctx context.Context, partitionID string, handler Handler, ...) (ListenerHandle, error) + type ReceiveOption func(receiver *receiver) error + func ReceiveFromTimestamp(t time.Time) ReceiveOption + func ReceiveWithConsumerGroup(consumerGroup string) ReceiveOption + func ReceiveWithEpoch(epoch int64) ReceiveOption + func ReceiveWithLatestOffset() ReceiveOption + func ReceiveWithPrefetchCount(prefetch uint32) ReceiveOption + func ReceiveWithStartingOffset(offset string) ReceiveOption + type SendOption func(event *Event) error + func SendWithMessageID(messageID string) SendOption + type Sender interface + Send func(ctx context.Context, event *Event, opts ...SendOption) error + SendBatch func(ctx context.Context, batch *EventBatch, opts ...SendOption) error + type SystemProperties struct + Annotations map[string]interface{} + EnqueuedTime *time.Time + IoTHubAuthGenerationID *string + IoTHubConnectionAuthMethod *string + IoTHubConnectionModuleID *string + IoTHubDeviceConnectionID *string + IoTHubEnqueuedTime *time.Time + Offset *int64 + PartitionID *int16 + PartitionKey *string + SequenceNumber *int64
Go to main page