Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

storage

package

Go to main page

Versions in this module

v3

v3.3.2

May 1, 2020

v3.3.1

Apr 30, 2020

Changes in this version

+ type AADSASCredential struct

+ AccountName string

+ ContainerName string

+ ResourceGroup string

+ SubscriptionID string

+ func NewAADSASCredential(subscriptionID, resourceGroup, accountName, containerName string, ...) (*AADSASCredential, error)

+ func (cred *AADSASCredential) New(next pipeline.Policy, po *pipeline.PolicyOptions) pipeline.Policy

+ type AADSASCredentialOption func(*aad.TokenProviderConfiguration) error

+ func AADSASCredentialWithEnvironmentVars() AADSASCredentialOption

+ type Credential interface

+ type LeaserCheckpointer struct

+ LeasePersistenceInterval time.Duration

+ func NewStorageLeaserCheckpointer(credential Credential, accountName, containerName string, ...) (*LeaserCheckpointer, error)

+ func (sl *LeaserCheckpointer) AcquireLease(ctx context.Context, partitionID string) (eph.LeaseMarker, bool, error)

+ func (sl *LeaserCheckpointer) Close() error

+ func (sl *LeaserCheckpointer) DeleteCheckpoint(ctx context.Context, partitionID string) error

+ func (sl *LeaserCheckpointer) DeleteLease(ctx context.Context, partitionID string) error

+ func (sl *LeaserCheckpointer) DeleteStore(ctx context.Context) error

+ func (sl *LeaserCheckpointer) EnsureCheckpoint(ctx context.Context, partitionID string) (persist.Checkpoint, error)

+ func (sl *LeaserCheckpointer) EnsureLease(ctx context.Context, partitionID string) (eph.LeaseMarker, error)

+ func (sl *LeaserCheckpointer) EnsureStore(ctx context.Context) error

+ func (sl *LeaserCheckpointer) GetCheckpoint(ctx context.Context, partitionID string) (persist.Checkpoint, bool)

+ func (sl *LeaserCheckpointer) GetLeases(ctx context.Context) ([]eph.LeaseMarker, error)

+ func (sl *LeaserCheckpointer) ReleaseLease(ctx context.Context, partitionID string) (bool, error)

+ func (sl *LeaserCheckpointer) RenewLease(ctx context.Context, partitionID string) (eph.LeaseMarker, bool, error)

+ func (sl *LeaserCheckpointer) SetEventHostProcessor(eph *eph.EventProcessorHost)

+ func (sl *LeaserCheckpointer) StoreExists(ctx context.Context) (bool, error)

+ func (sl *LeaserCheckpointer) UpdateCheckpoint(ctx context.Context, partitionID string, checkpoint persist.Checkpoint) error

+ func (sl *LeaserCheckpointer) UpdateLease(ctx context.Context, partitionID string) (eph.LeaseMarker, bool, error)

+ type SASToken struct

v3.3.1-beta.0

Sep 3, 2020

Other modules containing this package

github.com/princjef/azure-event-hubs-go