Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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

msg

package

Go to main page

Versions in this module

v0

v0.24.0

Dec 28, 2018

Changes in this version

+ const ResourceTypeQueue

+ const ResourceTypeSubscription

+ const ResourceTypeTopic

+ const ResourceVendorAmazonWebService

+ const ResourceVendorGoogleCloud

+ const ServiceID

+ func New() endly.Service

+ type Client interface

+ Close func() error

+ Create func(resource *ResourceSetup) (*Resource, error)

+ Delete func(resource *Resource) error

+ PullN func(source *Resource, count int) ([]*Message, error)

+ Push func(dest *Resource, message *Message) (Result, error)

+ func NewPubSubClient(context *endly.Context, dest *Resource, timeout time.Duration) (Client, error)

+ type Config struct

+ AckDeadline time.Duration

+ Attributes map[string]string

+ Labels map[string]string

+ RetainAckedMessages bool

+ RetentionDuration time.Duration

+ Topic *Resource

+ func NewConfig(topic string) *Config

+ type CreateRequest struct

+ Resources []*ResourceSetup

+ func (r *CreateRequest) Init() error

+ func (r *CreateRequest) Validate() error

+ type CreateResponse struct

+ Resources []*Resource

+ type DeleteRequest struct

+ Resources []*Resource

+ func (r *DeleteRequest) Init() error

+ type DeleteResponse struct

type Message

+ Attributes map[string]string

+ Data interface{}

+ ID string

+ Subject string

+ func (m *Message) Expand(state data.Map) *Message

+ type PullRequest struct

+ Count int

+ Source *Resource

+ TimeoutMs int

+ UDF string

+ func (r *PullRequest) Init() error

+ func (r *PullRequest) Validate() error

+ type PullResponse struct

+ Messages []*Message

+ type PushRequest struct

+ Dest *Resource

+ Messages []*Message

+ Source *url.Resource

+ TimeoutMs int

+ UDF string

+ func (r *PushRequest) Init() error

+ func (r *PushRequest) Validate() error

+ type PushResponse struct

+ Results []Result

+ type Resource struct

+ Config interface{}

+ Credentials string

+ ID string

+ Name string

+ Type string

+ URL string

+ Vendor string

+ func NewResource(resourceType, URL, credentials string) *Resource

+ func (r *Resource) Init() error

+ type ResourceSetup struct

+ Config *Config

+ Recreate bool

+ func NewResourceSetup(resourceType, URL, credentials string, recreate bool, config *Config) *ResourceSetup

+ func (r *ResourceSetup) Init() error

+ type Result interface

v0.23.0

Dec 12, 2018

v0.22.0

Dec 8, 2018

v0.21.2

Dec 1, 2018

v0.20.0

Nov 26, 2018

Changes in this version

+ const MessageStyleError

+ const MessageStyleGeneric

+ const MessageStyleGroup

+ const MessageStyleInput

+ const MessageStyleOutput

+ const MessageStyleSuccess

+ func NewEvent(value interface{}) *event

+ func ReportError(err error) error

+ type ErrorEvent struct

+ Error string

+ func NewErrorEvent(message string) *ErrorEvent

+ func (e *ErrorEvent) Messages() []*Message

+ type Event interface

+ Init func() Event

+ Package func() string

+ Timestamp func() time.Time

+ Type func() string

+ Value func() interface{}

+ func NewEventWithInit(value interface{}, init Event) Event

+ type Events struct

+ Events []Event

+ func NewEvents() *Events

+ func (e *Events) AsListener() Listener

+ type Listener func(event Event)

+ type Message struct

+ Header *Styled

+ Items []*Styled

+ Tag *Styled

+ func NewMessage(header *Styled, tag *Styled, items ...*Styled) *Message

+ type Repeated struct

+ Count int

+ Spent time.Duration

+ Type string

+ type RepeatedReporter interface

+ Message func(repeated *Repeated) *Message

+ type Reporter interface

+ Messages func() []*Message

+ type RunnerInput interface

+ IsInput func() bool

+ type RunnerOutput interface

+ IsOutput func() bool

+ type SleepEvent struct

+ SleepTimeMs int

+ func NewSleepEvent(sleepTimeMs int) *SleepEvent

+ func (e *SleepEvent) Message(repeated *Repeated) *Message

+ type Styled struct

+ Style int

+ Text string

+ func NewStyled(text string, style int) *Styled