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

data

package

Go to main page

Versions in this module

v0

v0.1.2

Jan 22, 2022

v0.1.1

Jun 22, 2021

v0.1.0

Mar 30, 2021

Changes in this version

+ const JobDead

+ const JobDeadStr

+ const JobDelivered

+ const JobDeliveredStr

+ const JobInflight

+ const JobInflightStr

+ const JobQueued

+ const JobQueuedStr

+ const MsgStatusAcknowledged

+ const MsgStatusAcknowledgedStr

+ const MsgStatusDispatched

+ const MsgStatusDispatchedStr

+ var ErrInsufficientInformationForCreating = errors.New("Necessary information missing for persistence")

+ var ErrLockableNil = errors.New("lockable can not be nil")

+ type App struct

+ func NewApp(seedData *config.SeedData, status AppStatus) *App

+ func (app *App) GetSeedData() *config.SeedData

+ func (app *App) GetStatus() AppStatus

+ type AppStatus int

+ const Initialized

+ const Initializing

+ const NotInitialized

+ type BasePaginateable struct

+ CreatedAt time.Time

+ ID xid.ID

+ UpdatedAt time.Time

+ func (paginateable *BasePaginateable) GetCursor() (cursor *Cursor, err error)

+ func (paginateable *BasePaginateable) GetLastUpdatedHTTPTimeString() string

+ func (paginateable *BasePaginateable) QuickFix() bool

+ type Channel struct

+ ChannelID string

+ func NewChannel(channelID string, token string) (*Channel, error)

+ func (channel *Channel) IsInValidState() bool

+ func (channel *Channel) QuickFix() bool

+ type Consumer struct

+ CallbackURL string

+ ConsumerID string

+ ConsumingFrom *Channel

+ func NewConsumer(channel *Channel, consumerID, token string, callbackURL *url.URL) (*Consumer, error)

+ func (consumer *Consumer) GetChannelIDSafely() (channelID string)

+ func (consumer *Consumer) IsInValidState() bool

+ func (consumer *Consumer) QuickFix() bool

+ type Cursor struct

+ ID string

+ Timestamp time.Time

+ func ParseCursor(encodedCursorString string) (cursor *Cursor, err error)

+ func (c *Cursor) String() string

+ type DeliveryJob struct

+ DispatchReceivedAt time.Time

+ EarliestNextAttemptAt time.Time

+ Listener *Consumer

+ Message *Message

+ RetryAttemptCount uint

+ Status JobStatus

+ StatusChangedAt time.Time

+ func NewDeliveryJob(msg *Message, consumer *Consumer) (job *DeliveryJob, err error)

+ func (job *DeliveryJob) GetLockID() string

+ func (job *DeliveryJob) IsInValidState() bool

+ func (job *DeliveryJob) QuickFix() bool

+ type JobStatus int

+ func (status JobStatus) String() string

+ type Lock struct

+ AttainedAt time.Time

+ LockID string

+ func NewLock(lockable Lockable) (lock *Lock, err error)

+ type Lockable interface

+ GetLockID func() string

+ type Message struct

+ BroadcastedTo *Channel

+ ContentType string

+ MessageID string

+ OutboxedAt time.Time

+ Payload string

+ Priority uint

+ ProducedBy *Producer

+ ReceivedAt time.Time

+ Status MsgStatus

+ func NewMessage(channel *Channel, producedBy *Producer, payload, contentType string) (*Message, error)

+ func (message *Message) GetChannelIDSafely() (channelID string)

+ func (message *Message) GetLockID() string

+ func (message *Message) IsInValidState() bool

+ func (message *Message) QuickFix() bool

+ type MessageStakeholder struct

+ Name string

+ Token string

+ type MsgStatus int

+ func (status MsgStatus) String() string

+ type Paginateable interface

+ GetCursor func() (*Cursor, error)

+ type Pagination struct

+ Next *Cursor

+ Previous *Cursor

+ func NewPagination(after Paginateable, before Paginateable) *Pagination

+ type Producer struct

+ ProducerID string

+ func NewProducer(producerID string, token string) (*Producer, error)

+ func (prod *Producer) IsInValidState() bool

+ func (prod *Producer) QuickFix() bool

+ type Updateable interface

+ GetLastUpdatedHTTPTimeString func() string

+ type ValidateableModel interface

+ IsInValidState func() bool

+ QuickFix func() bool

v0.1.0-release-test-v3

Mar 30, 2021

v0.1.0-release-test-v2

Jan 26, 2021

v0.1.0-beta-3

Mar 22, 2021

v0.1.0-beta-2

Feb 9, 2021

v0.1.0-beta-1

Jan 21, 2021