Versions in this module Expand all Collapse all v1 v1.1.0 Dec 4, 2018 Changes in this version type Conn + func NewDebugConn() (*Conn, error) v1.0.0 Dec 3, 2018 Changes in this version + type Conn struct + func NewConn(project, clientID, clientSecret string) (*Conn, error) + type Function struct + func Func(key string, i interface{}) *Function + func (f *Function) Call(ctx context.Context, queue QueueSpec, args ...interface{}) error + func (f *Function) Task(args ...interface{}) (*pbqueues.SendTask, error) + type Listener struct + func NewListener(sentryDSN string) *Listener + func (lis *Listener) Handle(queue QueueSpec) + type QueueSpec struct + func Queue(conn *Conn, name string) QueueSpec + func (queue QueueSpec) SendTasks(ctx context.Context, tasks []*pbqueues.SendTask) error