workflow

package
v0.2.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 21, 2020 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source 
const Connection_TypeID = 0xfdce09f9d8aeb8ae

Connection_TypeID is the unique identifier for the type Connection.

View Source 
const Connection_ackJob_Params_TypeID = 0xbc929b168c2d35bc

Connection_ackJob_Params_TypeID is the unique identifier for the type Connection_ackJob_Params.

View Source 
const Connection_ackJob_Results_TypeID = 0x9824c247770da692

Connection_ackJob_Results_TypeID is the unique identifier for the type Connection_ackJob_Results.

View Source 
const Connection_getEvent_Params_TypeID = 0x858fba217e5b6d0a

Connection_getEvent_Params_TypeID is the unique identifier for the type Connection_getEvent_Params.

View Source 
const Connection_getEvent_Results_TypeID = 0xe84cea99f5f10902

Connection_getEvent_Results_TypeID is the unique identifier for the type Connection_getEvent_Results.

View Source 
const Connection_getJob_Params_TypeID = 0xea6a21a6e04621e8

Connection_getJob_Params_TypeID is the unique identifier for the type Connection_getJob_Params.

View Source 
const Connection_getJob_Results_TypeID = 0xafa27e7eec8d315d

Connection_getJob_Results_TypeID is the unique identifier for the type Connection_getJob_Results.

View Source 
const Connection_putEvent_Params_TypeID = 0xde10a9cc0d72b72e

Connection_putEvent_Params_TypeID is the unique identifier for the type Connection_putEvent_Params.

View Source 
const Connection_putEvent_Results_TypeID = 0x88498a4904c5c24b

Connection_putEvent_Results_TypeID is the unique identifier for the type Connection_putEvent_Results.

View Source 
const Connection_putNewEvent_Params_TypeID = 0xf6ca343646120f95

Connection_putNewEvent_Params_TypeID is the unique identifier for the type Connection_putNewEvent_Params.

View Source 
const Connection_putNewEvent_Results_TypeID = 0xc9cfdb3e090d737d

Connection_putNewEvent_Results_TypeID is the unique identifier for the type Connection_putNewEvent_Results.

View Source 
const Event_Metadata_TypeID = 0xe9a0380ad629b742

Event_Metadata_TypeID is the unique identifier for the type Event_Metadata.

View Source 
const Event_TypeID = 0xf57a5642b033d8c1

Event_TypeID is the unique identifier for the type Event.

View Source 
const Node_TypeID = 0xbf62f9456cb02d81

Node_TypeID is the unique identifier for the type Node.

View Source 
const Queue_TypeID = 0x8be40c5e90cff4cf

Queue_TypeID is the unique identifier for the type Queue.

View Source 
const Task_TypeID = 0xfe4f04fe9f35eb7d

Task_TypeID is the unique identifier for the type Task.

View Source 
const Workflow_TypeID = 0xa35d193330adceaf

Workflow_TypeID is the unique identifier for the type Workflow.

View Source 
const Workflow_connect_Params_TypeID = 0xfb7429c9d23d519b

Workflow_connect_Params_TypeID is the unique identifier for the type Workflow_connect_Params.

View Source 
const Workflow_connect_Results_TypeID = 0x8bcafe9abfa2fdc5

Workflow_connect_Results_TypeID is the unique identifier for the type Workflow_connect_Results.

View Source 
const Workflow_getEventAllVersions_Params_TypeID = 0x8c160cee2c28c32f

Workflow_getEventAllVersions_Params_TypeID is the unique identifier for the type Workflow_getEventAllVersions_Params.

View Source 
const Workflow_getEventAllVersions_Results_TypeID = 0xa6863ad17f79d808

Workflow_getEventAllVersions_Results_TypeID is the unique identifier for the type Workflow_getEventAllVersions_Results.

View Source 
const Workflow_getLatestEventID_Params_TypeID = 0x8dde89bb27860684

Workflow_getLatestEventID_Params_TypeID is the unique identifier for the type Workflow_getLatestEventID_Params.

View Source 
const Workflow_getLatestEventID_Results_TypeID = 0xb222156f3117892c

Workflow_getLatestEventID_Results_TypeID is the unique identifier for the type Workflow_getLatestEventID_Results.

View Source 
const Workflow_getQueue_Params_TypeID = 0xcc590b8e644c6381

Workflow_getQueue_Params_TypeID is the unique identifier for the type Workflow_getQueue_Params.

View Source 
const Workflow_getQueue_Results_TypeID = 0xc6682ec0740925e5

Workflow_getQueue_Results_TypeID is the unique identifier for the type Workflow_getQueue_Results.

View Source 
const Workflow_getQueues_Params_TypeID = 0x814b25c6a90ab3fd

Workflow_getQueues_Params_TypeID is the unique identifier for the type Workflow_getQueues_Params.

View Source 
const Workflow_getQueues_Results_TypeID = 0x90eb69d2aa988bfb

Workflow_getQueues_Results_TypeID is the unique identifier for the type Workflow_getQueues_Results.

Variables

This section is empty.

Functions

func Connection_Methods added in v0.2.3 

func Connection_Methods(methods []server.Method, s Connection_Server) []server.Method

func Workflow_Methods 

func Workflow_Methods(methods []server.Method, s Workflow_Server) []server.Method

Types

type Connection added in v0.2.3 

type Connection struct{ Client capnp.Client }

func Connection_ServerToClient added in v0.2.3 

func Connection_ServerToClient(s Connection_Server) Connection

func (Connection) AckJob added in v0.2.3 

func (c Connection) AckJob(ctx context.Context, params func(Connection_ackJob_Params) error, opts ...capnp.CallOption) Connection_ackJob_Results_Promise

func (Connection) GetEvent added in v0.2.3 

func (c Connection) GetEvent(ctx context.Context, params func(Connection_getEvent_Params) error, opts ...capnp.CallOption) Connection_getEvent_Results_Promise

func (Connection) GetJob added in v0.2.3 

func (c Connection) GetJob(ctx context.Context, params func(Connection_getJob_Params) error, opts ...capnp.CallOption) Connection_getJob_Results_Promise

func (Connection) PutEvent added in v0.2.3 

func (c Connection) PutEvent(ctx context.Context, params func(Connection_putEvent_Params) error, opts ...capnp.CallOption) Connection_putEvent_Results_Promise

func (Connection) PutNewEvent added in v0.2.3 

func (c Connection) PutNewEvent(ctx context.Context, params func(Connection_putNewEvent_Params) error, opts ...capnp.CallOption) Connection_putNewEvent_Results_Promise

type Connection_Server added in v0.2.3 

type Connection_Server interface {
	PutEvent(Connection_putEvent) error

	PutNewEvent(Connection_putNewEvent) error

	GetEvent(Connection_getEvent) error

	GetJob(Connection_getJob) error

	AckJob(Connection_ackJob) error
}

type Connection_ackJob added in v0.2.3 

type Connection_ackJob struct {
	Ctx     context.Context
	Options capnp.CallOptions
	Params  Connection_ackJob_Params
	Results Connection_ackJob_Results
}

Connection_ackJob holds the arguments for a server call to Connection.ackJob.

type Connection_ackJob_Params added in v0.2.3 

type Connection_ackJob_Params struct{ capnp.Struct }

func NewConnection_ackJob_Params added in v0.2.3 

func NewConnection_ackJob_Params(s *capnp.Segment) (Connection_ackJob_Params, error)

func NewRootConnection_ackJob_Params added in v0.2.3 

func NewRootConnection_ackJob_Params(s *capnp.Segment) (Connection_ackJob_Params, error)

func ReadRootConnection_ackJob_Params added in v0.2.3 

func ReadRootConnection_ackJob_Params(msg *capnp.Message) (Connection_ackJob_Params, error)

func (Connection_ackJob_Params) AckID added in v0.2.3 

func (s Connection_ackJob_Params) AckID() ([]byte, error)

func (Connection_ackJob_Params) Event added in v0.2.3 

func (s Connection_ackJob_Params) Event() (Event, error)

func (Connection_ackJob_Params) HasAckID added in v0.2.3 

func (s Connection_ackJob_Params) HasAckID() bool

func (Connection_ackJob_Params) HasEvent added in v0.2.3 

func (s Connection_ackJob_Params) HasEvent() bool

func (Connection_ackJob_Params) NewEvent added in v0.2.3 

func (s Connection_ackJob_Params) NewEvent() (Event, error)

NewEvent sets the event field to a newly allocated Event struct, preferring placement in s's segment.

func (Connection_ackJob_Params) SetAckID added in v0.2.3 

func (s Connection_ackJob_Params) SetAckID(v []byte) error

func (Connection_ackJob_Params) SetEvent added in v0.2.3 

func (s Connection_ackJob_Params) SetEvent(v Event) error

func (Connection_ackJob_Params) String added in v0.2.3 

func (s Connection_ackJob_Params) String() string

type Connection_ackJob_Params_List added in v0.2.3 

type Connection_ackJob_Params_List struct{ capnp.List }

Connection_ackJob_Params_List is a list of Connection_ackJob_Params.

func NewConnection_ackJob_Params_List added in v0.2.3 

func NewConnection_ackJob_Params_List(s *capnp.Segment, sz int32) (Connection_ackJob_Params_List, error)

NewConnection_ackJob_Params creates a new list of Connection_ackJob_Params.

func (Connection_ackJob_Params_List) At added in v0.2.3 

func (s Connection_ackJob_Params_List) At(i int) Connection_ackJob_Params

func (Connection_ackJob_Params_List) Set added in v0.2.3 

func (s Connection_ackJob_Params_List) Set(i int, v Connection_ackJob_Params) error

func (Connection_ackJob_Params_List) String added in v0.2.3 

func (s Connection_ackJob_Params_List) String() string

type Connection_ackJob_Params_Promise added in v0.2.3 

type Connection_ackJob_Params_Promise struct{ *capnp.Pipeline }

Connection_ackJob_Params_Promise is a wrapper for a Connection_ackJob_Params promised by a client call.

func (Connection_ackJob_Params_Promise) Event added in v0.2.3 

func (p Connection_ackJob_Params_Promise) Event() Event_Promise

func (Connection_ackJob_Params_Promise) Struct added in v0.2.3 

func (p Connection_ackJob_Params_Promise) Struct() (Connection_ackJob_Params, error)

type Connection_ackJob_Results added in v0.2.3 

type Connection_ackJob_Results struct{ capnp.Struct }

func NewConnection_ackJob_Results added in v0.2.3 

func NewConnection_ackJob_Results(s *capnp.Segment) (Connection_ackJob_Results, error)

func NewRootConnection_ackJob_Results added in v0.2.3 

func NewRootConnection_ackJob_Results(s *capnp.Segment) (Connection_ackJob_Results, error)

func ReadRootConnection_ackJob_Results added in v0.2.3 

func ReadRootConnection_ackJob_Results(msg *capnp.Message) (Connection_ackJob_Results, error)

func (Connection_ackJob_Results) Acked added in v0.2.3 

func (s Connection_ackJob_Results) Acked() bool

func (Connection_ackJob_Results) SetAcked added in v0.2.3 

func (s Connection_ackJob_Results) SetAcked(v bool)

func (Connection_ackJob_Results) String added in v0.2.3 

func (s Connection_ackJob_Results) String() string

type Connection_ackJob_Results_List added in v0.2.3 

type Connection_ackJob_Results_List struct{ capnp.List }

Connection_ackJob_Results_List is a list of Connection_ackJob_Results.

func NewConnection_ackJob_Results_List added in v0.2.3 

func NewConnection_ackJob_Results_List(s *capnp.Segment, sz int32) (Connection_ackJob_Results_List, error)

NewConnection_ackJob_Results creates a new list of Connection_ackJob_Results.

func (Connection_ackJob_Results_List) At added in v0.2.3 

func (s Connection_ackJob_Results_List) At(i int) Connection_ackJob_Results

func (Connection_ackJob_Results_List) Set added in v0.2.3 

func (s Connection_ackJob_Results_List) Set(i int, v Connection_ackJob_Results) error

func (Connection_ackJob_Results_List) String added in v0.2.3 

func (s Connection_ackJob_Results_List) String() string

type Connection_ackJob_Results_Promise added in v0.2.3 

type Connection_ackJob_Results_Promise struct{ *capnp.Pipeline }

Connection_ackJob_Results_Promise is a wrapper for a Connection_ackJob_Results promised by a client call.

func (Connection_ackJob_Results_Promise) Struct added in v0.2.3 

func (p Connection_ackJob_Results_Promise) Struct() (Connection_ackJob_Results, error)

type Connection_getEvent added in v0.2.3 

type Connection_getEvent struct {
	Ctx     context.Context
	Options capnp.CallOptions
	Params  Connection_getEvent_Params
	Results Connection_getEvent_Results
}

Connection_getEvent holds the arguments for a server call to Connection.getEvent.

type Connection_getEvent_Params added in v0.2.3 

type Connection_getEvent_Params struct{ capnp.Struct }

func NewConnection_getEvent_Params added in v0.2.3 

func NewConnection_getEvent_Params(s *capnp.Segment) (Connection_getEvent_Params, error)

func NewRootConnection_getEvent_Params added in v0.2.3 

func NewRootConnection_getEvent_Params(s *capnp.Segment) (Connection_getEvent_Params, error)

func ReadRootConnection_getEvent_Params added in v0.2.3 

func ReadRootConnection_getEvent_Params(msg *capnp.Message) (Connection_getEvent_Params, error)

func (Connection_getEvent_Params) EventID added in v0.2.3 

func (s Connection_getEvent_Params) EventID() ([]byte, error)

func (Connection_getEvent_Params) HasEventID added in v0.2.3 

func (s Connection_getEvent_Params) HasEventID() bool

func (Connection_getEvent_Params) SetEventID added in v0.2.3 

func (s Connection_getEvent_Params) SetEventID(v []byte) error

func (Connection_getEvent_Params) String added in v0.2.3 

func (s Connection_getEvent_Params) String() string

type Connection_getEvent_Params_List added in v0.2.3 

type Connection_getEvent_Params_List struct{ capnp.List }

Connection_getEvent_Params_List is a list of Connection_getEvent_Params.

func NewConnection_getEvent_Params_List added in v0.2.3 

func NewConnection_getEvent_Params_List(s *capnp.Segment, sz int32) (Connection_getEvent_Params_List, error)

NewConnection_getEvent_Params creates a new list of Connection_getEvent_Params.

func (Connection_getEvent_Params_List) At added in v0.2.3 

func (s Connection_getEvent_Params_List) At(i int) Connection_getEvent_Params

func (Connection_getEvent_Params_List) Set added in v0.2.3 

func (s Connection_getEvent_Params_List) Set(i int, v Connection_getEvent_Params) error

func (Connection_getEvent_Params_List) String added in v0.2.3 

func (s Connection_getEvent_Params_List) String() string

type Connection_getEvent_Params_Promise added in v0.2.3 

type Connection_getEvent_Params_Promise struct{ *capnp.Pipeline }

Connection_getEvent_Params_Promise is a wrapper for a Connection_getEvent_Params promised by a client call.

func (Connection_getEvent_Params_Promise) Struct added in v0.2.3 

func (p Connection_getEvent_Params_Promise) Struct() (Connection_getEvent_Params, error)

type Connection_getEvent_Results added in v0.2.3 

type Connection_getEvent_Results struct{ capnp.Struct }

func NewConnection_getEvent_Results added in v0.2.3 

func NewConnection_getEvent_Results(s *capnp.Segment) (Connection_getEvent_Results, error)

func NewRootConnection_getEvent_Results added in v0.2.3 

func NewRootConnection_getEvent_Results(s *capnp.Segment) (Connection_getEvent_Results, error)

func ReadRootConnection_getEvent_Results added in v0.2.3 

func ReadRootConnection_getEvent_Results(msg *capnp.Message) (Connection_getEvent_Results, error)

func (Connection_getEvent_Results) Event added in v0.2.3 

func (s Connection_getEvent_Results) Event() (Event, error)

func (Connection_getEvent_Results) HasEvent added in v0.2.3 

func (s Connection_getEvent_Results) HasEvent() bool

func (Connection_getEvent_Results) NewEvent added in v0.2.3 

func (s Connection_getEvent_Results) NewEvent() (Event, error)

NewEvent sets the event field to a newly allocated Event struct, preferring placement in s's segment.

func (Connection_getEvent_Results) SetEvent added in v0.2.3 

func (s Connection_getEvent_Results) SetEvent(v Event) error

func (Connection_getEvent_Results) String added in v0.2.3 

func (s Connection_getEvent_Results) String() string

type Connection_getEvent_Results_List added in v0.2.3 

type Connection_getEvent_Results_List struct{ capnp.List }

Connection_getEvent_Results_List is a list of Connection_getEvent_Results.

func NewConnection_getEvent_Results_List added in v0.2.3 

func NewConnection_getEvent_Results_List(s *capnp.Segment, sz int32) (Connection_getEvent_Results_List, error)

NewConnection_getEvent_Results creates a new list of Connection_getEvent_Results.

func (Connection_getEvent_Results_List) At added in v0.2.3 

func (s Connection_getEvent_Results_List) At(i int) Connection_getEvent_Results

func (Connection_getEvent_Results_List) Set added in v0.2.3 

func (s Connection_getEvent_Results_List) Set(i int, v Connection_getEvent_Results) error

func (Connection_getEvent_Results_List) String added in v0.2.3 

func (s Connection_getEvent_Results_List) String() string

type Connection_getEvent_Results_Promise added in v0.2.3 

type Connection_getEvent_Results_Promise struct{ *capnp.Pipeline }

Connection_getEvent_Results_Promise is a wrapper for a Connection_getEvent_Results promised by a client call.

func (Connection_getEvent_Results_Promise) Event added in v0.2.3 

func (p Connection_getEvent_Results_Promise) Event() Event_Promise

func (Connection_getEvent_Results_Promise) Struct added in v0.2.3 

func (p Connection_getEvent_Results_Promise) Struct() (Connection_getEvent_Results, error)

type Connection_getJob added in v0.2.3 

type Connection_getJob struct {
	Ctx     context.Context
	Options capnp.CallOptions
	Params  Connection_getJob_Params
	Results Connection_getJob_Results
}

Connection_getJob holds the arguments for a server call to Connection.getJob.

type Connection_getJob_Params added in v0.2.3 

type Connection_getJob_Params struct{ capnp.Struct }

func NewConnection_getJob_Params added in v0.2.3 

func NewConnection_getJob_Params(s *capnp.Segment) (Connection_getJob_Params, error)

func NewRootConnection_getJob_Params added in v0.2.3 

func NewRootConnection_getJob_Params(s *capnp.Segment) (Connection_getJob_Params, error)

func ReadRootConnection_getJob_Params added in v0.2.3 

func ReadRootConnection_getJob_Params(msg *capnp.Message) (Connection_getJob_Params, error)

func (Connection_getJob_Params) String added in v0.2.3 

func (s Connection_getJob_Params) String() string

type Connection_getJob_Params_List added in v0.2.3 

type Connection_getJob_Params_List struct{ capnp.List }

Connection_getJob_Params_List is a list of Connection_getJob_Params.

func NewConnection_getJob_Params_List added in v0.2.3 

func NewConnection_getJob_Params_List(s *capnp.Segment, sz int32) (Connection_getJob_Params_List, error)

NewConnection_getJob_Params creates a new list of Connection_getJob_Params.

func (Connection_getJob_Params_List) At added in v0.2.3 

func (s Connection_getJob_Params_List) At(i int) Connection_getJob_Params

func (Connection_getJob_Params_List) Set added in v0.2.3 

func (s Connection_getJob_Params_List) Set(i int, v Connection_getJob_Params) error

func (Connection_getJob_Params_List) String added in v0.2.3 

func (s Connection_getJob_Params_List) String() string

type Connection_getJob_Params_Promise added in v0.2.3 

type Connection_getJob_Params_Promise struct{ *capnp.Pipeline }

Connection_getJob_Params_Promise is a wrapper for a Connection_getJob_Params promised by a client call.

func (Connection_getJob_Params_Promise) Struct added in v0.2.3 

func (p Connection_getJob_Params_Promise) Struct() (Connection_getJob_Params, error)

type Connection_getJob_Results added in v0.2.3 

type Connection_getJob_Results struct{ capnp.Struct }

func NewConnection_getJob_Results added in v0.2.3 

func NewConnection_getJob_Results(s *capnp.Segment) (Connection_getJob_Results, error)

func NewRootConnection_getJob_Results added in v0.2.3 

func NewRootConnection_getJob_Results(s *capnp.Segment) (Connection_getJob_Results, error)

func ReadRootConnection_getJob_Results added in v0.2.3 

func ReadRootConnection_getJob_Results(msg *capnp.Message) (Connection_getJob_Results, error)

func (Connection_getJob_Results) AckID added in v0.2.3 

func (s Connection_getJob_Results) AckID() ([]byte, error)

func (Connection_getJob_Results) EventID added in v0.2.3 

func (s Connection_getJob_Results) EventID() ([]byte, error)

func (Connection_getJob_Results) HasAckID added in v0.2.3 

func (s Connection_getJob_Results) HasAckID() bool

func (Connection_getJob_Results) HasEventID added in v0.2.3 

func (s Connection_getJob_Results) HasEventID() bool

func (Connection_getJob_Results) SetAckID added in v0.2.3 

func (s Connection_getJob_Results) SetAckID(v []byte) error

func (Connection_getJob_Results) SetEventID added in v0.2.3 

func (s Connection_getJob_Results) SetEventID(v []byte) error

func (Connection_getJob_Results) String added in v0.2.3 

func (s Connection_getJob_Results) String() string

type Connection_getJob_Results_List added in v0.2.3 

type Connection_getJob_Results_List struct{ capnp.List }

Connection_getJob_Results_List is a list of Connection_getJob_Results.

func NewConnection_getJob_Results_List added in v0.2.3 

func NewConnection_getJob_Results_List(s *capnp.Segment, sz int32) (Connection_getJob_Results_List, error)

NewConnection_getJob_Results creates a new list of Connection_getJob_Results.

func (Connection_getJob_Results_List) At added in v0.2.3 

func (s Connection_getJob_Results_List) At(i int) Connection_getJob_Results

func (Connection_getJob_Results_List) Set added in v0.2.3 

func (s Connection_getJob_Results_List) Set(i int, v Connection_getJob_Results) error

func (Connection_getJob_Results_List) String added in v0.2.3 

func (s Connection_getJob_Results_List) String() string

type Connection_getJob_Results_Promise added in v0.2.3 

type Connection_getJob_Results_Promise struct{ *capnp.Pipeline }

Connection_getJob_Results_Promise is a wrapper for a Connection_getJob_Results promised by a client call.

func (Connection_getJob_Results_Promise) Struct added in v0.2.3 

func (p Connection_getJob_Results_Promise) Struct() (Connection_getJob_Results, error)

type Connection_putEvent added in v0.2.3 

type Connection_putEvent struct {
	Ctx     context.Context
	Options capnp.CallOptions
	Params  Connection_putEvent_Params
	Results Connection_putEvent_Results
}

Connection_putEvent holds the arguments for a server call to Connection.putEvent.

type Connection_putEvent_Params added in v0.2.3 

type Connection_putEvent_Params struct{ capnp.Struct }

func NewConnection_putEvent_Params added in v0.2.3 

func NewConnection_putEvent_Params(s *capnp.Segment) (Connection_putEvent_Params, error)

func NewRootConnection_putEvent_Params added in v0.2.3 

func NewRootConnection_putEvent_Params(s *capnp.Segment) (Connection_putEvent_Params, error)

func ReadRootConnection_putEvent_Params added in v0.2.3 

func ReadRootConnection_putEvent_Params(msg *capnp.Message) (Connection_putEvent_Params, error)

func (Connection_putEvent_Params) Event added in v0.2.3 

func (s Connection_putEvent_Params) Event() (Event, error)

func (Connection_putEvent_Params) EventID added in v0.2.3 

func (s Connection_putEvent_Params) EventID() ([]byte, error)

func (Connection_putEvent_Params) HasEvent added in v0.2.3 

func (s Connection_putEvent_Params) HasEvent() bool

func (Connection_putEvent_Params) HasEventID added in v0.2.3 

func (s Connection_putEvent_Params) HasEventID() bool

func (Connection_putEvent_Params) NewEvent added in v0.2.3 

func (s Connection_putEvent_Params) NewEvent() (Event, error)

NewEvent sets the event field to a newly allocated Event struct, preferring placement in s's segment.

func (Connection_putEvent_Params) SetEvent added in v0.2.3 

func (s Connection_putEvent_Params) SetEvent(v Event) error

func (Connection_putEvent_Params) SetEventID added in v0.2.3 

func (s Connection_putEvent_Params) SetEventID(v []byte) error

func (Connection_putEvent_Params) String added in v0.2.3 

func (s Connection_putEvent_Params) String() string

type Connection_putEvent_Params_List added in v0.2.3 

type Connection_putEvent_Params_List struct{ capnp.List }

Connection_putEvent_Params_List is a list of Connection_putEvent_Params.

func NewConnection_putEvent_Params_List added in v0.2.3 

func NewConnection_putEvent_Params_List(s *capnp.Segment, sz int32) (Connection_putEvent_Params_List, error)

NewConnection_putEvent_Params creates a new list of Connection_putEvent_Params.

func (Connection_putEvent_Params_List) At added in v0.2.3 

func (s Connection_putEvent_Params_List) At(i int) Connection_putEvent_Params

func (Connection_putEvent_Params_List) Set added in v0.2.3 

func (s Connection_putEvent_Params_List) Set(i int, v Connection_putEvent_Params) error

func (Connection_putEvent_Params_List) String added in v0.2.3 

func (s Connection_putEvent_Params_List) String() string

type Connection_putEvent_Params_Promise added in v0.2.3 

type Connection_putEvent_Params_Promise struct{ *capnp.Pipeline }

Connection_putEvent_Params_Promise is a wrapper for a Connection_putEvent_Params promised by a client call.

func (Connection_putEvent_Params_Promise) Event added in v0.2.3 

func (p Connection_putEvent_Params_Promise) Event() Event_Promise

func (Connection_putEvent_Params_Promise) Struct added in v0.2.3 

func (p Connection_putEvent_Params_Promise) Struct() (Connection_putEvent_Params, error)

type Connection_putEvent_Results added in v0.2.3 

type Connection_putEvent_Results struct{ capnp.Struct }

func NewConnection_putEvent_Results added in v0.2.3 

func NewConnection_putEvent_Results(s *capnp.Segment) (Connection_putEvent_Results, error)

func NewRootConnection_putEvent_Results added in v0.2.3 

func NewRootConnection_putEvent_Results(s *capnp.Segment) (Connection_putEvent_Results, error)

func ReadRootConnection_putEvent_Results added in v0.2.3 

func ReadRootConnection_putEvent_Results(msg *capnp.Message) (Connection_putEvent_Results, error)

func (Connection_putEvent_Results) String added in v0.2.3 

func (s Connection_putEvent_Results) String() string

type Connection_putEvent_Results_List added in v0.2.3 

type Connection_putEvent_Results_List struct{ capnp.List }

Connection_putEvent_Results_List is a list of Connection_putEvent_Results.

func NewConnection_putEvent_Results_List added in v0.2.3 

func NewConnection_putEvent_Results_List(s *capnp.Segment, sz int32) (Connection_putEvent_Results_List, error)

NewConnection_putEvent_Results creates a new list of Connection_putEvent_Results.

func (Connection_putEvent_Results_List) At added in v0.2.3 

func (s Connection_putEvent_Results_List) At(i int) Connection_putEvent_Results

func (Connection_putEvent_Results_List) Set added in v0.2.3 

func (s Connection_putEvent_Results_List) Set(i int, v Connection_putEvent_Results) error

func (Connection_putEvent_Results_List) String added in v0.2.3 

func (s Connection_putEvent_Results_List) String() string

type Connection_putEvent_Results_Promise added in v0.2.3 

type Connection_putEvent_Results_Promise struct{ *capnp.Pipeline }

Connection_putEvent_Results_Promise is a wrapper for a Connection_putEvent_Results promised by a client call.

func (Connection_putEvent_Results_Promise) Struct added in v0.2.3 

func (p Connection_putEvent_Results_Promise) Struct() (Connection_putEvent_Results, error)

type Connection_putNewEvent added in v0.2.3 

type Connection_putNewEvent struct {
	Ctx     context.Context
	Options capnp.CallOptions
	Params  Connection_putNewEvent_Params
	Results Connection_putNewEvent_Results
}

Connection_putNewEvent holds the arguments for a server call to Connection.putNewEvent.

type Connection_putNewEvent_Params added in v0.2.3 

type Connection_putNewEvent_Params struct{ capnp.Struct }

func NewConnection_putNewEvent_Params added in v0.2.3 

func NewConnection_putNewEvent_Params(s *capnp.Segment) (Connection_putNewEvent_Params, error)

func NewRootConnection_putNewEvent_Params added in v0.2.3 

func NewRootConnection_putNewEvent_Params(s *capnp.Segment) (Connection_putNewEvent_Params, error)

func ReadRootConnection_putNewEvent_Params added in v0.2.3 

func ReadRootConnection_putNewEvent_Params(msg *capnp.Message) (Connection_putNewEvent_Params, error)

func (Connection_putNewEvent_Params) Event added in v0.2.3 

func (s Connection_putNewEvent_Params) Event() (Event, error)

func (Connection_putNewEvent_Params) HasEvent added in v0.2.3 

func (s Connection_putNewEvent_Params) HasEvent() bool

func (Connection_putNewEvent_Params) NewEvent added in v0.2.3 

func (s Connection_putNewEvent_Params) NewEvent() (Event, error)

NewEvent sets the event field to a newly allocated Event struct, preferring placement in s's segment.

func (Connection_putNewEvent_Params) SetEvent added in v0.2.3 

func (s Connection_putNewEvent_Params) SetEvent(v Event) error

func (Connection_putNewEvent_Params) String added in v0.2.3 

func (s Connection_putNewEvent_Params) String() string

type Connection_putNewEvent_Params_List added in v0.2.3 

type Connection_putNewEvent_Params_List struct{ capnp.List }

Connection_putNewEvent_Params_List is a list of Connection_putNewEvent_Params.

func NewConnection_putNewEvent_Params_List added in v0.2.3 

func NewConnection_putNewEvent_Params_List(s *capnp.Segment, sz int32) (Connection_putNewEvent_Params_List, error)

NewConnection_putNewEvent_Params creates a new list of Connection_putNewEvent_Params.

func (Connection_putNewEvent_Params_List) At added in v0.2.3 

func (s Connection_putNewEvent_Params_List) At(i int) Connection_putNewEvent_Params

func (Connection_putNewEvent_Params_List) Set added in v0.2.3 

func (s Connection_putNewEvent_Params_List) Set(i int, v Connection_putNewEvent_Params) error

func (Connection_putNewEvent_Params_List) String added in v0.2.3 

func (s Connection_putNewEvent_Params_List) String() string

type Connection_putNewEvent_Params_Promise added in v0.2.3 

type Connection_putNewEvent_Params_Promise struct{ *capnp.Pipeline }

Connection_putNewEvent_Params_Promise is a wrapper for a Connection_putNewEvent_Params promised by a client call.

func (Connection_putNewEvent_Params_Promise) Event added in v0.2.3 

func (p Connection_putNewEvent_Params_Promise) Event() Event_Promise

func (Connection_putNewEvent_Params_Promise) Struct added in v0.2.3 

func (p Connection_putNewEvent_Params_Promise) Struct() (Connection_putNewEvent_Params, error)

type Connection_putNewEvent_Results added in v0.2.3 

type Connection_putNewEvent_Results struct{ capnp.Struct }

func NewConnection_putNewEvent_Results added in v0.2.3 

func NewConnection_putNewEvent_Results(s *capnp.Segment) (Connection_putNewEvent_Results, error)

func NewRootConnection_putNewEvent_Results added in v0.2.3 

func NewRootConnection_putNewEvent_Results(s *capnp.Segment) (Connection_putNewEvent_Results, error)

func ReadRootConnection_putNewEvent_Results added in v0.2.3 

func ReadRootConnection_putNewEvent_Results(msg *capnp.Message) (Connection_putNewEvent_Results, error)

func (Connection_putNewEvent_Results) EventID added in v0.2.3 

func (s Connection_putNewEvent_Results) EventID() ([]byte, error)

func (Connection_putNewEvent_Results) HasEventID added in v0.2.3 

func (s Connection_putNewEvent_Results) HasEventID() bool

func (Connection_putNewEvent_Results) SetEventID added in v0.2.3 

func (s Connection_putNewEvent_Results) SetEventID(v []byte) error

func (Connection_putNewEvent_Results) String added in v0.2.3 

func (s Connection_putNewEvent_Results) String() string

type Connection_putNewEvent_Results_List added in v0.2.3 

type Connection_putNewEvent_Results_List struct{ capnp.List }

Connection_putNewEvent_Results_List is a list of Connection_putNewEvent_Results.

func NewConnection_putNewEvent_Results_List added in v0.2.3 

func NewConnection_putNewEvent_Results_List(s *capnp.Segment, sz int32) (Connection_putNewEvent_Results_List, error)

NewConnection_putNewEvent_Results creates a new list of Connection_putNewEvent_Results.

func (Connection_putNewEvent_Results_List) At added in v0.2.3 

func (s Connection_putNewEvent_Results_List) At(i int) Connection_putNewEvent_Results

func (Connection_putNewEvent_Results_List) Set added in v0.2.3 

func (s Connection_putNewEvent_Results_List) Set(i int, v Connection_putNewEvent_Results) error

func (Connection_putNewEvent_Results_List) String added in v0.2.3 

func (s Connection_putNewEvent_Results_List) String() string

type Connection_putNewEvent_Results_Promise added in v0.2.3 

type Connection_putNewEvent_Results_Promise struct{ *capnp.Pipeline }

Connection_putNewEvent_Results_Promise is a wrapper for a Connection_putNewEvent_Results promised by a client call.

func (Connection_putNewEvent_Results_Promise) Struct added in v0.2.3 

func (p Connection_putNewEvent_Results_Promise) Struct() (Connection_putNewEvent_Results, error)

type Event 

type Event struct{ capnp.Struct }

func NewEvent 

func NewEvent(s *capnp.Segment) (Event, error)

func NewRootEvent 

func NewRootEvent(s *capnp.Segment) (Event, error)

func ReadRootEvent 

func ReadRootEvent(msg *capnp.Message) (Event, error)

func (Event) Content 

func (s Event) Content() ([]byte, error)

func (Event) Filter 

func (s Event) Filter() bool

func (Event) HasContent 

func (s Event) HasContent() bool

func (Event) HasMeta 

func (s Event) HasMeta() bool

func (Event) HasWorker 

func (s Event) HasWorker() bool

func (Event) Meta 

func (s Event) Meta() (Event_Metadata_List, error)

func (Event) NewMeta 

func (s Event) NewMeta(n int32) (Event_Metadata_List, error)

NewMeta sets the meta field to a newly allocated Event_Metadata_List, preferring placement in s's segment.

func (Event) SetContent 

func (s Event) SetContent(v []byte) error

func (Event) SetFilter 

func (s Event) SetFilter(v bool)

func (Event) SetMeta 

func (s Event) SetMeta(v Event_Metadata_List) error

func (Event) SetWorker 

func (s Event) SetWorker(v []byte) error

func (Event) String 

func (s Event) String() string

func (Event) Worker 

func (s Event) Worker() ([]byte, error)

type Event_List 

type Event_List struct{ capnp.List }

Event_List is a list of Event.

func NewEvent_List 

func NewEvent_List(s *capnp.Segment, sz int32) (Event_List, error)

NewEvent creates a new list of Event.

func (Event_List) At 

func (s Event_List) At(i int) Event

func (Event_List) Set 

func (s Event_List) Set(i int, v Event) error

func (Event_List) String 

func (s Event_List) String() string

type Event_Metadata 

type Event_Metadata struct{ capnp.Struct }

func NewEvent_Metadata 

func NewEvent_Metadata(s *capnp.Segment) (Event_Metadata, error)

func NewRootEvent_Metadata 

func NewRootEvent_Metadata(s *capnp.Segment) (Event_Metadata, error)

func ReadRootEvent_Metadata 

func ReadRootEvent_Metadata(msg *capnp.Message) (Event_Metadata, error)

func (Event_Metadata) HasKey 

func (s Event_Metadata) HasKey() bool

func (Event_Metadata) HasValue 

func (s Event_Metadata) HasValue() bool

func (Event_Metadata) Key 

func (s Event_Metadata) Key() (string, error)

func (Event_Metadata) KeyBytes 

func (s Event_Metadata) KeyBytes() ([]byte, error)

func (Event_Metadata) SetKey 

func (s Event_Metadata) SetKey(v string) error

func (Event_Metadata) SetValue 

func (s Event_Metadata) SetValue(v string) error

func (Event_Metadata) String 

func (s Event_Metadata) String() string

func (Event_Metadata) Value 

func (s Event_Metadata) Value() (string, error)

func (Event_Metadata) ValueBytes 

func (s Event_Metadata) ValueBytes() ([]byte, error)

type Event_Metadata_List 

type Event_Metadata_List struct{ capnp.List }

Event_Metadata_List is a list of Event_Metadata.

func NewEvent_Metadata_List 

func NewEvent_Metadata_List(s *capnp.Segment, sz int32) (Event_Metadata_List, error)

NewEvent_Metadata creates a new list of Event_Metadata.

func (Event_Metadata_List) At 

func (s Event_Metadata_List) At(i int) Event_Metadata

func (Event_Metadata_List) Set 

func (s Event_Metadata_List) Set(i int, v Event_Metadata) error

func (Event_Metadata_List) String 

func (s Event_Metadata_List) String() string

type Event_Metadata_Promise 

type Event_Metadata_Promise struct{ *capnp.Pipeline }

Event_Metadata_Promise is a wrapper for a Event_Metadata promised by a client call.

func (Event_Metadata_Promise) Struct 

func (p Event_Metadata_Promise) Struct() (Event_Metadata, error)

type Event_Promise 

type Event_Promise struct{ *capnp.Pipeline }

Event_Promise is a wrapper for a Event promised by a client call.

func (Event_Promise) Struct 

func (p Event_Promise) Struct() (Event, error)

type Node added in v0.2.6 

type Node struct{ capnp.Struct }

func NewNode added in v0.2.6 

func NewNode(s *capnp.Segment) (Node, error)

func NewRootNode added in v0.2.6 

func NewRootNode(s *capnp.Segment) (Node, error)

func ReadRootNode added in v0.2.6 

func ReadRootNode(msg *capnp.Message) (Node, error)

func (Node) HasNextNode added in v0.2.6 

func (s Node) HasNextNode() bool

func (Node) HasValue added in v0.2.6 

func (s Node) HasValue() bool

func (Node) NextNode added in v0.2.6 

func (s Node) NextNode() (string, error)

func (Node) NextNodeBytes added in v0.2.6 

func (s Node) NextNodeBytes() ([]byte, error)

func (Node) SetNextNode added in v0.2.6 

func (s Node) SetNextNode(v string) error

func (Node) SetValue added in v0.2.6 

func (s Node) SetValue(v []byte) error

func (Node) String added in v0.2.6 

func (s Node) String() string

func (Node) Value added in v0.2.6 

func (s Node) Value() ([]byte, error)

type Node_List added in v0.2.6 

type Node_List struct{ capnp.List }

Node_List is a list of Node.

func NewNode_List added in v0.2.6 

func NewNode_List(s *capnp.Segment, sz int32) (Node_List, error)

NewNode creates a new list of Node.

func (Node_List) At added in v0.2.6 

func (s Node_List) At(i int) Node

func (Node_List) Set added in v0.2.6 

func (s Node_List) Set(i int, v Node) error

func (Node_List) String added in v0.2.6 

func (s Node_List) String() string

type Node_Promise added in v0.2.6 

type Node_Promise struct{ *capnp.Pipeline }

Node_Promise is a wrapper for a Node promised by a client call.

func (Node_Promise) Struct added in v0.2.6 

func (p Node_Promise) Struct() (Node, error)

type Queue added in v0.2.3 

type Queue struct{ capnp.Struct }

func NewQueue added in v0.2.3 

func NewQueue(s *capnp.Segment) (Queue, error)

func NewRootQueue added in v0.2.3 

func NewRootQueue(s *capnp.Segment) (Queue, error)

func ReadRootQueue added in v0.2.3 

func ReadRootQueue(msg *capnp.Message) (Queue, error)

func (Queue) HasWorkerId added in v0.2.3 

func (s Queue) HasWorkerId() bool

func (Queue) QueueSize added in v0.2.3 

func (s Queue) QueueSize() uint64

func (Queue) SetQueueSize added in v0.2.3 

func (s Queue) SetQueueSize(v uint64)

func (Queue) SetWorkerId added in v0.2.3 

func (s Queue) SetWorkerId(v []byte) error

func (Queue) String added in v0.2.3 

func (s Queue) String() string

func (Queue) WorkerId added in v0.2.3 

func (s Queue) WorkerId() ([]byte, error)

type Queue_List added in v0.2.3 

type Queue_List struct{ capnp.List }

Queue_List is a list of Queue.

func NewQueue_List added in v0.2.3 

func NewQueue_List(s *capnp.Segment, sz int32) (Queue_List, error)

NewQueue creates a new list of Queue.

func (Queue_List) At added in v0.2.3 

func (s Queue_List) At(i int) Queue

func (Queue_List) Set added in v0.2.3 

func (s Queue_List) Set(i int, v Queue) error

func (Queue_List) String added in v0.2.3 

func (s Queue_List) String() string

type Queue_Promise added in v0.2.3 

type Queue_Promise struct{ *capnp.Pipeline }

Queue_Promise is a wrapper for a Queue promised by a client call.

func (Queue_Promise) Struct added in v0.2.3 

func (p Queue_Promise) Struct() (Queue, error)

type Task added in v0.2.6 

type Task struct{ capnp.Struct }

func NewRootTask added in v0.2.6 

func NewRootTask(s *capnp.Segment) (Task, error)

func NewTask added in v0.2.6 

func NewTask(s *capnp.Segment) (Task, error)

func ReadRootTask added in v0.2.6 

func ReadRootTask(msg *capnp.Message) (Task, error)

func (Task) Current added in v0.2.6 

func (s Task) Current() ([]byte, error)

func (Task) Event added in v0.2.6 

func (s Task) Event() ([]byte, error)

func (Task) Flow added in v0.2.6 

func (s Task) Flow() ([]byte, error)

func (Task) HasCurrent added in v0.2.6 

func (s Task) HasCurrent() bool

func (Task) HasEvent added in v0.2.6 

func (s Task) HasEvent() bool

func (Task) HasFlow added in v0.2.6 

func (s Task) HasFlow() bool

func (Task) HasJob added in v0.2.6 

func (s Task) HasJob() bool

func (Task) HasNext added in v0.2.6 

func (s Task) HasNext() bool

func (Task) Job added in v0.2.6 

func (s Task) Job() ([]byte, error)

func (Task) NewNext added in v0.2.6 

func (s Task) NewNext(n int32) (capnp.DataList, error)

NewNext sets the next field to a newly allocated capnp.DataList, preferring placement in s's segment.

func (Task) Next added in v0.2.6 

func (s Task) Next() (capnp.DataList, error)

func (Task) SetCurrent added in v0.2.6 

func (s Task) SetCurrent(v []byte) error

func (Task) SetEvent added in v0.2.6 

func (s Task) SetEvent(v []byte) error

func (Task) SetFlow added in v0.2.6 

func (s Task) SetFlow(v []byte) error

func (Task) SetJob added in v0.2.6 

func (s Task) SetJob(v []byte) error

func (Task) SetNext added in v0.2.6 

func (s Task) SetNext(v capnp.DataList) error

func (Task) String added in v0.2.6 

func (s Task) String() string

type Task_List added in v0.2.6 

type Task_List struct{ capnp.List }

Task_List is a list of Task.

func NewTask_List added in v0.2.6 

func NewTask_List(s *capnp.Segment, sz int32) (Task_List, error)

NewTask creates a new list of Task.

func (Task_List) At added in v0.2.6 

func (s Task_List) At(i int) Task

func (Task_List) Set added in v0.2.6 

func (s Task_List) Set(i int, v Task) error

func (Task_List) String added in v0.2.6 

func (s Task_List) String() string

type Task_Promise added in v0.2.6 

type Task_Promise struct{ *capnp.Pipeline }

Task_Promise is a wrapper for a Task promised by a client call.

func (Task_Promise) Struct added in v0.2.6 

func (p Task_Promise) Struct() (Task, error)

type Workflow 

type Workflow struct{ Client capnp.Client }

func Workflow_ServerToClient 

func Workflow_ServerToClient(s Workflow_Server) Workflow

func (Workflow) Connect added in v0.2.3 

func (c Workflow) Connect(ctx context.Context, params func(Workflow_connect_Params) error, opts ...capnp.CallOption) Workflow_connect_Results_Promise

func (Workflow) GetEventAllVersions 

func (c Workflow) GetEventAllVersions(ctx context.Context, params func(Workflow_getEventAllVersions_Params) error, opts ...capnp.CallOption) Workflow_getEventAllVersions_Results_Promise

func (Workflow) GetLatestEventID 

func (c Workflow) GetLatestEventID(ctx context.Context, params func(Workflow_getLatestEventID_Params) error, opts ...capnp.CallOption) Workflow_getLatestEventID_Results_Promise

func (Workflow) GetQueue added in v0.2.3 

func (c Workflow) GetQueue(ctx context.Context, params func(Workflow_getQueue_Params) error, opts ...capnp.CallOption) Workflow_getQueue_Results_Promise

func (Workflow) GetQueues added in v0.2.3 

func (c Workflow) GetQueues(ctx context.Context, params func(Workflow_getQueues_Params) error, opts ...capnp.CallOption) Workflow_getQueues_Results_Promise

type Workflow_Server 

type Workflow_Server interface {
	Connect(Workflow_connect) error

	GetEventAllVersions(Workflow_getEventAllVersions) error

	GetQueue(Workflow_getQueue) error

	GetQueues(Workflow_getQueues) error

	GetLatestEventID(Workflow_getLatestEventID) error
}

type Workflow_connect added in v0.2.3 

type Workflow_connect struct {
	Ctx     context.Context
	Options capnp.CallOptions
	Params  Workflow_connect_Params
	Results Workflow_connect_Results
}

Workflow_connect holds the arguments for a server call to Workflow.connect.

type Workflow_connect_Params added in v0.2.3 

type Workflow_connect_Params struct{ capnp.Struct }

func NewRootWorkflow_connect_Params added in v0.2.3 

func NewRootWorkflow_connect_Params(s *capnp.Segment) (Workflow_connect_Params, error)

func NewWorkflow_connect_Params added in v0.2.3 

func NewWorkflow_connect_Params(s *capnp.Segment) (Workflow_connect_Params, error)

func ReadRootWorkflow_connect_Params added in v0.2.3 

func ReadRootWorkflow_connect_Params(msg *capnp.Message) (Workflow_connect_Params, error)

func (Workflow_connect_Params) FlowID added in v0.2.3 

func (s Workflow_connect_Params) FlowID() ([]byte, error)

func (Workflow_connect_Params) HasFlowID added in v0.2.3 

func (s Workflow_connect_Params) HasFlowID() bool

func (Workflow_connect_Params) HasWorkerID added in v0.2.3 

func (s Workflow_connect_Params) HasWorkerID() bool

func (Workflow_connect_Params) SetFlowID added in v0.2.3 

func (s Workflow_connect_Params) SetFlowID(v []byte) error

func (Workflow_connect_Params) SetWorkerID added in v0.2.3 

func (s Workflow_connect_Params) SetWorkerID(v []byte) error

func (Workflow_connect_Params) String added in v0.2.3 

func (s Workflow_connect_Params) String() string

func (Workflow_connect_Params) WorkerID added in v0.2.3 

func (s Workflow_connect_Params) WorkerID() ([]byte, error)

type Workflow_connect_Params_List added in v0.2.3 

type Workflow_connect_Params_List struct{ capnp.List }

Workflow_connect_Params_List is a list of Workflow_connect_Params.

func NewWorkflow_connect_Params_List added in v0.2.3 

func NewWorkflow_connect_Params_List(s *capnp.Segment, sz int32) (Workflow_connect_Params_List, error)

NewWorkflow_connect_Params creates a new list of Workflow_connect_Params.

func (Workflow_connect_Params_List) At added in v0.2.3 

func (s Workflow_connect_Params_List) At(i int) Workflow_connect_Params

func (Workflow_connect_Params_List) Set added in v0.2.3 

func (s Workflow_connect_Params_List) Set(i int, v Workflow_connect_Params) error

func (Workflow_connect_Params_List) String added in v0.2.3 

func (s Workflow_connect_Params_List) String() string

type Workflow_connect_Params_Promise added in v0.2.3 

type Workflow_connect_Params_Promise struct{ *capnp.Pipeline }

Workflow_connect_Params_Promise is a wrapper for a Workflow_connect_Params promised by a client call.

func (Workflow_connect_Params_Promise) Struct added in v0.2.3 

func (p Workflow_connect_Params_Promise) Struct() (Workflow_connect_Params, error)

type Workflow_connect_Results added in v0.2.3 

type Workflow_connect_Results struct{ capnp.Struct }

func NewRootWorkflow_connect_Results added in v0.2.3 

func NewRootWorkflow_connect_Results(s *capnp.Segment) (Workflow_connect_Results, error)

func NewWorkflow_connect_Results added in v0.2.3 

func NewWorkflow_connect_Results(s *capnp.Segment) (Workflow_connect_Results, error)

func ReadRootWorkflow_connect_Results added in v0.2.3 

func ReadRootWorkflow_connect_Results(msg *capnp.Message) (Workflow_connect_Results, error)

func (Workflow_connect_Results) Connection added in v0.2.3 

func (s Workflow_connect_Results) Connection() Connection

func (Workflow_connect_Results) HasConnection added in v0.2.3 

func (s Workflow_connect_Results) HasConnection() bool

func (Workflow_connect_Results) SetConnection added in v0.2.3 

func (s Workflow_connect_Results) SetConnection(v Connection) error

func (Workflow_connect_Results) String added in v0.2.3 

func (s Workflow_connect_Results) String() string

type Workflow_connect_Results_List added in v0.2.3 

type Workflow_connect_Results_List struct{ capnp.List }

Workflow_connect_Results_List is a list of Workflow_connect_Results.

func NewWorkflow_connect_Results_List added in v0.2.3 

func NewWorkflow_connect_Results_List(s *capnp.Segment, sz int32) (Workflow_connect_Results_List, error)

NewWorkflow_connect_Results creates a new list of Workflow_connect_Results.

func (Workflow_connect_Results_List) At added in v0.2.3 

func (s Workflow_connect_Results_List) At(i int) Workflow_connect_Results

func (Workflow_connect_Results_List) Set added in v0.2.3 

func (s Workflow_connect_Results_List) Set(i int, v Workflow_connect_Results) error

func (Workflow_connect_Results_List) String added in v0.2.3 

func (s Workflow_connect_Results_List) String() string

type Workflow_connect_Results_Promise added in v0.2.3 

type Workflow_connect_Results_Promise struct{ *capnp.Pipeline }

Workflow_connect_Results_Promise is a wrapper for a Workflow_connect_Results promised by a client call.

func (Workflow_connect_Results_Promise) Connection added in v0.2.3 

func (p Workflow_connect_Results_Promise) Connection() Connection

func (Workflow_connect_Results_Promise) Struct added in v0.2.3 

func (p Workflow_connect_Results_Promise) Struct() (Workflow_connect_Results, error)

type Workflow_getEventAllVersions 

type Workflow_getEventAllVersions struct {
	Ctx     context.Context
	Options capnp.CallOptions
	Params  Workflow_getEventAllVersions_Params
	Results Workflow_getEventAllVersions_Results
}

Workflow_getEventAllVersions holds the arguments for a server call to Workflow.getEventAllVersions.

type Workflow_getEventAllVersions_Params 

type Workflow_getEventAllVersions_Params struct{ capnp.Struct }

func NewRootWorkflow_getEventAllVersions_Params 

func NewRootWorkflow_getEventAllVersions_Params(s *capnp.Segment) (Workflow_getEventAllVersions_Params, error)

func NewWorkflow_getEventAllVersions_Params 

func NewWorkflow_getEventAllVersions_Params(s *capnp.Segment) (Workflow_getEventAllVersions_Params, error)

func ReadRootWorkflow_getEventAllVersions_Params 

func ReadRootWorkflow_getEventAllVersions_Params(msg *capnp.Message) (Workflow_getEventAllVersions_Params, error)

func (Workflow_getEventAllVersions_Params) EventID 

func (s Workflow_getEventAllVersions_Params) EventID() ([]byte, error)

func (Workflow_getEventAllVersions_Params) HasEventID 

func (s Workflow_getEventAllVersions_Params) HasEventID() bool

func (Workflow_getEventAllVersions_Params) SetEventID 

func (s Workflow_getEventAllVersions_Params) SetEventID(v []byte) error

func (Workflow_getEventAllVersions_Params) String 

func (s Workflow_getEventAllVersions_Params) String() string

type Workflow_getEventAllVersions_Params_List 

type Workflow_getEventAllVersions_Params_List struct{ capnp.List }

Workflow_getEventAllVersions_Params_List is a list of Workflow_getEventAllVersions_Params.

func NewWorkflow_getEventAllVersions_Params_List 

func NewWorkflow_getEventAllVersions_Params_List(s *capnp.Segment, sz int32) (Workflow_getEventAllVersions_Params_List, error)

NewWorkflow_getEventAllVersions_Params creates a new list of Workflow_getEventAllVersions_Params.

func (Workflow_getEventAllVersions_Params_List) At 

func (s Workflow_getEventAllVersions_Params_List) At(i int) Workflow_getEventAllVersions_Params

func (Workflow_getEventAllVersions_Params_List) Set 

func (s Workflow_getEventAllVersions_Params_List) Set(i int, v Workflow_getEventAllVersions_Params) error

func (Workflow_getEventAllVersions_Params_List) String 

func (s Workflow_getEventAllVersions_Params_List) String() string

type Workflow_getEventAllVersions_Params_Promise 

type Workflow_getEventAllVersions_Params_Promise struct{ *capnp.Pipeline }

Workflow_getEventAllVersions_Params_Promise is a wrapper for a Workflow_getEventAllVersions_Params promised by a client call.

func (Workflow_getEventAllVersions_Params_Promise) Struct 

func (p Workflow_getEventAllVersions_Params_Promise) Struct() (Workflow_getEventAllVersions_Params, error)

type Workflow_getEventAllVersions_Results 

type Workflow_getEventAllVersions_Results struct{ capnp.Struct }

func NewRootWorkflow_getEventAllVersions_Results 

func NewRootWorkflow_getEventAllVersions_Results(s *capnp.Segment) (Workflow_getEventAllVersions_Results, error)

func NewWorkflow_getEventAllVersions_Results 

func NewWorkflow_getEventAllVersions_Results(s *capnp.Segment) (Workflow_getEventAllVersions_Results, error)

func ReadRootWorkflow_getEventAllVersions_Results 

func ReadRootWorkflow_getEventAllVersions_Results(msg *capnp.Message) (Workflow_getEventAllVersions_Results, error)

func (Workflow_getEventAllVersions_Results) Events 

func (s Workflow_getEventAllVersions_Results) Events() (Event_List, error)

func (Workflow_getEventAllVersions_Results) HasEvents 

func (s Workflow_getEventAllVersions_Results) HasEvents() bool

func (Workflow_getEventAllVersions_Results) NewEvents 

func (s Workflow_getEventAllVersions_Results) NewEvents(n int32) (Event_List, error)

NewEvents sets the events field to a newly allocated Event_List, preferring placement in s's segment.

func (Workflow_getEventAllVersions_Results) SetEvents 

func (s Workflow_getEventAllVersions_Results) SetEvents(v Event_List) error

func (Workflow_getEventAllVersions_Results) String 

func (s Workflow_getEventAllVersions_Results) String() string

type Workflow_getEventAllVersions_Results_List 

type Workflow_getEventAllVersions_Results_List struct{ capnp.List }

Workflow_getEventAllVersions_Results_List is a list of Workflow_getEventAllVersions_Results.

func NewWorkflow_getEventAllVersions_Results_List 

func NewWorkflow_getEventAllVersions_Results_List(s *capnp.Segment, sz int32) (Workflow_getEventAllVersions_Results_List, error)

NewWorkflow_getEventAllVersions_Results creates a new list of Workflow_getEventAllVersions_Results.

func (Workflow_getEventAllVersions_Results_List) At 

func (s Workflow_getEventAllVersions_Results_List) At(i int) Workflow_getEventAllVersions_Results

func (Workflow_getEventAllVersions_Results_List) Set 

func (s Workflow_getEventAllVersions_Results_List) Set(i int, v Workflow_getEventAllVersions_Results) error

func (Workflow_getEventAllVersions_Results_List) String 

func (s Workflow_getEventAllVersions_Results_List) String() string

type Workflow_getEventAllVersions_Results_Promise 

type Workflow_getEventAllVersions_Results_Promise struct{ *capnp.Pipeline }

Workflow_getEventAllVersions_Results_Promise is a wrapper for a Workflow_getEventAllVersions_Results promised by a client call.

func (Workflow_getEventAllVersions_Results_Promise) Struct 

func (p Workflow_getEventAllVersions_Results_Promise) Struct() (Workflow_getEventAllVersions_Results, error)

type Workflow_getLatestEventID 

type Workflow_getLatestEventID struct {
	Ctx     context.Context
	Options capnp.CallOptions
	Params  Workflow_getLatestEventID_Params
	Results Workflow_getLatestEventID_Results
}

Workflow_getLatestEventID holds the arguments for a server call to Workflow.getLatestEventID.

type Workflow_getLatestEventID_Params 

type Workflow_getLatestEventID_Params struct{ capnp.Struct }

func NewRootWorkflow_getLatestEventID_Params 

func NewRootWorkflow_getLatestEventID_Params(s *capnp.Segment) (Workflow_getLatestEventID_Params, error)

func NewWorkflow_getLatestEventID_Params 

func NewWorkflow_getLatestEventID_Params(s *capnp.Segment) (Workflow_getLatestEventID_Params, error)

func ReadRootWorkflow_getLatestEventID_Params 

func ReadRootWorkflow_getLatestEventID_Params(msg *capnp.Message) (Workflow_getLatestEventID_Params, error)

func (Workflow_getLatestEventID_Params) FlowID 

func (s Workflow_getLatestEventID_Params) FlowID() ([]byte, error)

func (Workflow_getLatestEventID_Params) HasFlowID 

func (s Workflow_getLatestEventID_Params) HasFlowID() bool

func (Workflow_getLatestEventID_Params) SetFlowID 

func (s Workflow_getLatestEventID_Params) SetFlowID(v []byte) error

func (Workflow_getLatestEventID_Params) String 

func (s Workflow_getLatestEventID_Params) String() string

type Workflow_getLatestEventID_Params_List 

type Workflow_getLatestEventID_Params_List struct{ capnp.List }

Workflow_getLatestEventID_Params_List is a list of Workflow_getLatestEventID_Params.

func NewWorkflow_getLatestEventID_Params_List 

func NewWorkflow_getLatestEventID_Params_List(s *capnp.Segment, sz int32) (Workflow_getLatestEventID_Params_List, error)

NewWorkflow_getLatestEventID_Params creates a new list of Workflow_getLatestEventID_Params.

func (Workflow_getLatestEventID_Params_List) At 

func (s Workflow_getLatestEventID_Params_List) At(i int) Workflow_getLatestEventID_Params

func (Workflow_getLatestEventID_Params_List) Set 

func (s Workflow_getLatestEventID_Params_List) Set(i int, v Workflow_getLatestEventID_Params) error

func (Workflow_getLatestEventID_Params_List) String 

func (s Workflow_getLatestEventID_Params_List) String() string

type Workflow_getLatestEventID_Params_Promise 

type Workflow_getLatestEventID_Params_Promise struct{ *capnp.Pipeline }

Workflow_getLatestEventID_Params_Promise is a wrapper for a Workflow_getLatestEventID_Params promised by a client call.

func (Workflow_getLatestEventID_Params_Promise) Struct 

func (p Workflow_getLatestEventID_Params_Promise) Struct() (Workflow_getLatestEventID_Params, error)

type Workflow_getLatestEventID_Results 

type Workflow_getLatestEventID_Results struct{ capnp.Struct }

func NewRootWorkflow_getLatestEventID_Results 

func NewRootWorkflow_getLatestEventID_Results(s *capnp.Segment) (Workflow_getLatestEventID_Results, error)

func NewWorkflow_getLatestEventID_Results 

func NewWorkflow_getLatestEventID_Results(s *capnp.Segment) (Workflow_getLatestEventID_Results, error)

func ReadRootWorkflow_getLatestEventID_Results 

func ReadRootWorkflow_getLatestEventID_Results(msg *capnp.Message) (Workflow_getLatestEventID_Results, error)

func (Workflow_getLatestEventID_Results) EventID 

func (s Workflow_getLatestEventID_Results) EventID() ([]byte, error)

func (Workflow_getLatestEventID_Results) HasEventID 

func (s Workflow_getLatestEventID_Results) HasEventID() bool

func (Workflow_getLatestEventID_Results) SetEventID 

func (s Workflow_getLatestEventID_Results) SetEventID(v []byte) error

func (Workflow_getLatestEventID_Results) String 

func (s Workflow_getLatestEventID_Results) String() string

type Workflow_getLatestEventID_Results_List 

type Workflow_getLatestEventID_Results_List struct{ capnp.List }

Workflow_getLatestEventID_Results_List is a list of Workflow_getLatestEventID_Results.

func NewWorkflow_getLatestEventID_Results_List 

func NewWorkflow_getLatestEventID_Results_List(s *capnp.Segment, sz int32) (Workflow_getLatestEventID_Results_List, error)

NewWorkflow_getLatestEventID_Results creates a new list of Workflow_getLatestEventID_Results.

func (Workflow_getLatestEventID_Results_List) At 

func (s Workflow_getLatestEventID_Results_List) At(i int) Workflow_getLatestEventID_Results

func (Workflow_getLatestEventID_Results_List) Set 

func (s Workflow_getLatestEventID_Results_List) Set(i int, v Workflow_getLatestEventID_Results) error

func (Workflow_getLatestEventID_Results_List) String 

func (s Workflow_getLatestEventID_Results_List) String() string

type Workflow_getLatestEventID_Results_Promise 

type Workflow_getLatestEventID_Results_Promise struct{ *capnp.Pipeline }

Workflow_getLatestEventID_Results_Promise is a wrapper for a Workflow_getLatestEventID_Results promised by a client call.

func (Workflow_getLatestEventID_Results_Promise) Struct 

func (p Workflow_getLatestEventID_Results_Promise) Struct() (Workflow_getLatestEventID_Results, error)

type Workflow_getQueue added in v0.2.3 

type Workflow_getQueue struct {
	Ctx     context.Context
	Options capnp.CallOptions
	Params  Workflow_getQueue_Params
	Results Workflow_getQueue_Results
}

Workflow_getQueue holds the arguments for a server call to Workflow.getQueue.

type Workflow_getQueue_Params added in v0.2.3 

type Workflow_getQueue_Params struct{ capnp.Struct }

func NewRootWorkflow_getQueue_Params added in v0.2.3 

func NewRootWorkflow_getQueue_Params(s *capnp.Segment) (Workflow_getQueue_Params, error)

func NewWorkflow_getQueue_Params added in v0.2.3 

func NewWorkflow_getQueue_Params(s *capnp.Segment) (Workflow_getQueue_Params, error)

func ReadRootWorkflow_getQueue_Params added in v0.2.3 

func ReadRootWorkflow_getQueue_Params(msg *capnp.Message) (Workflow_getQueue_Params, error)

func (Workflow_getQueue_Params) HasWorkerID added in v0.2.3 

func (s Workflow_getQueue_Params) HasWorkerID() bool

func (Workflow_getQueue_Params) SetWorkerID added in v0.2.3 

func (s Workflow_getQueue_Params) SetWorkerID(v []byte) error

func (Workflow_getQueue_Params) String added in v0.2.3 

func (s Workflow_getQueue_Params) String() string

func (Workflow_getQueue_Params) WorkerID added in v0.2.3 

func (s Workflow_getQueue_Params) WorkerID() ([]byte, error)

type Workflow_getQueue_Params_List added in v0.2.3 

type Workflow_getQueue_Params_List struct{ capnp.List }

Workflow_getQueue_Params_List is a list of Workflow_getQueue_Params.

func NewWorkflow_getQueue_Params_List added in v0.2.3 

func NewWorkflow_getQueue_Params_List(s *capnp.Segment, sz int32) (Workflow_getQueue_Params_List, error)

NewWorkflow_getQueue_Params creates a new list of Workflow_getQueue_Params.

func (Workflow_getQueue_Params_List) At added in v0.2.3 

func (s Workflow_getQueue_Params_List) At(i int) Workflow_getQueue_Params

func (Workflow_getQueue_Params_List) Set added in v0.2.3 

func (s Workflow_getQueue_Params_List) Set(i int, v Workflow_getQueue_Params) error

func (Workflow_getQueue_Params_List) String added in v0.2.3 

func (s Workflow_getQueue_Params_List) String() string

type Workflow_getQueue_Params_Promise added in v0.2.3 

type Workflow_getQueue_Params_Promise struct{ *capnp.Pipeline }

Workflow_getQueue_Params_Promise is a wrapper for a Workflow_getQueue_Params promised by a client call.

func (Workflow_getQueue_Params_Promise) Struct added in v0.2.3 

func (p Workflow_getQueue_Params_Promise) Struct() (Workflow_getQueue_Params, error)

type Workflow_getQueue_Results added in v0.2.3 

type Workflow_getQueue_Results struct{ capnp.Struct }

func NewRootWorkflow_getQueue_Results added in v0.2.3 

func NewRootWorkflow_getQueue_Results(s *capnp.Segment) (Workflow_getQueue_Results, error)

func NewWorkflow_getQueue_Results added in v0.2.3 

func NewWorkflow_getQueue_Results(s *capnp.Segment) (Workflow_getQueue_Results, error)

func ReadRootWorkflow_getQueue_Results added in v0.2.3 

func ReadRootWorkflow_getQueue_Results(msg *capnp.Message) (Workflow_getQueue_Results, error)

func (Workflow_getQueue_Results) HasQueue added in v0.2.3 

func (s Workflow_getQueue_Results) HasQueue() bool

func (Workflow_getQueue_Results) NewQueue added in v0.2.3 

func (s Workflow_getQueue_Results) NewQueue() (Queue, error)

NewQueue sets the queue field to a newly allocated Queue struct, preferring placement in s's segment.

func (Workflow_getQueue_Results) Queue added in v0.2.3 

func (s Workflow_getQueue_Results) Queue() (Queue, error)

func (Workflow_getQueue_Results) SetQueue added in v0.2.3 

func (s Workflow_getQueue_Results) SetQueue(v Queue) error

func (Workflow_getQueue_Results) String added in v0.2.3 

func (s Workflow_getQueue_Results) String() string

type Workflow_getQueue_Results_List added in v0.2.3 

type Workflow_getQueue_Results_List struct{ capnp.List }

Workflow_getQueue_Results_List is a list of Workflow_getQueue_Results.

func NewWorkflow_getQueue_Results_List added in v0.2.3 

func NewWorkflow_getQueue_Results_List(s *capnp.Segment, sz int32) (Workflow_getQueue_Results_List, error)

NewWorkflow_getQueue_Results creates a new list of Workflow_getQueue_Results.

func (Workflow_getQueue_Results_List) At added in v0.2.3 

func (s Workflow_getQueue_Results_List) At(i int) Workflow_getQueue_Results

func (Workflow_getQueue_Results_List) Set added in v0.2.3 

func (s Workflow_getQueue_Results_List) Set(i int, v Workflow_getQueue_Results) error

func (Workflow_getQueue_Results_List) String added in v0.2.3 

func (s Workflow_getQueue_Results_List) String() string

type Workflow_getQueue_Results_Promise added in v0.2.3 

type Workflow_getQueue_Results_Promise struct{ *capnp.Pipeline }

Workflow_getQueue_Results_Promise is a wrapper for a Workflow_getQueue_Results promised by a client call.

func (Workflow_getQueue_Results_Promise) Queue added in v0.2.3 

func (p Workflow_getQueue_Results_Promise) Queue() Queue_Promise

func (Workflow_getQueue_Results_Promise) Struct added in v0.2.3 

func (p Workflow_getQueue_Results_Promise) Struct() (Workflow_getQueue_Results, error)

type Workflow_getQueues added in v0.2.3 

type Workflow_getQueues struct {
	Ctx     context.Context
	Options capnp.CallOptions
	Params  Workflow_getQueues_Params
	Results Workflow_getQueues_Results
}

Workflow_getQueues holds the arguments for a server call to Workflow.getQueues.

type Workflow_getQueues_Params added in v0.2.3 

type Workflow_getQueues_Params struct{ capnp.Struct }

func NewRootWorkflow_getQueues_Params added in v0.2.3 

func NewRootWorkflow_getQueues_Params(s *capnp.Segment) (Workflow_getQueues_Params, error)

func NewWorkflow_getQueues_Params added in v0.2.3 

func NewWorkflow_getQueues_Params(s *capnp.Segment) (Workflow_getQueues_Params, error)

func ReadRootWorkflow_getQueues_Params added in v0.2.3 

func ReadRootWorkflow_getQueues_Params(msg *capnp.Message) (Workflow_getQueues_Params, error)

func (Workflow_getQueues_Params) String added in v0.2.3 

func (s Workflow_getQueues_Params) String() string

type Workflow_getQueues_Params_List added in v0.2.3 

type Workflow_getQueues_Params_List struct{ capnp.List }

Workflow_getQueues_Params_List is a list of Workflow_getQueues_Params.

func NewWorkflow_getQueues_Params_List added in v0.2.3 

func NewWorkflow_getQueues_Params_List(s *capnp.Segment, sz int32) (Workflow_getQueues_Params_List, error)

NewWorkflow_getQueues_Params creates a new list of Workflow_getQueues_Params.

func (Workflow_getQueues_Params_List) At added in v0.2.3 

func (s Workflow_getQueues_Params_List) At(i int) Workflow_getQueues_Params

func (Workflow_getQueues_Params_List) Set added in v0.2.3 

func (s Workflow_getQueues_Params_List) Set(i int, v Workflow_getQueues_Params) error

func (Workflow_getQueues_Params_List) String added in v0.2.3 

func (s Workflow_getQueues_Params_List) String() string

type Workflow_getQueues_Params_Promise added in v0.2.3 

type Workflow_getQueues_Params_Promise struct{ *capnp.Pipeline }

Workflow_getQueues_Params_Promise is a wrapper for a Workflow_getQueues_Params promised by a client call.

func (Workflow_getQueues_Params_Promise) Struct added in v0.2.3 

func (p Workflow_getQueues_Params_Promise) Struct() (Workflow_getQueues_Params, error)

type Workflow_getQueues_Results added in v0.2.3 

type Workflow_getQueues_Results struct{ capnp.Struct }

func NewRootWorkflow_getQueues_Results added in v0.2.3 

func NewRootWorkflow_getQueues_Results(s *capnp.Segment) (Workflow_getQueues_Results, error)

func NewWorkflow_getQueues_Results added in v0.2.3 

func NewWorkflow_getQueues_Results(s *capnp.Segment) (Workflow_getQueues_Results, error)

func ReadRootWorkflow_getQueues_Results added in v0.2.3 

func ReadRootWorkflow_getQueues_Results(msg *capnp.Message) (Workflow_getQueues_Results, error)

func (Workflow_getQueues_Results) HasQueues added in v0.2.3 

func (s Workflow_getQueues_Results) HasQueues() bool

func (Workflow_getQueues_Results) NewQueues added in v0.2.3 

func (s Workflow_getQueues_Results) NewQueues(n int32) (Queue_List, error)

NewQueues sets the queues field to a newly allocated Queue_List, preferring placement in s's segment.

func (Workflow_getQueues_Results) Queues added in v0.2.3 

func (s Workflow_getQueues_Results) Queues() (Queue_List, error)

func (Workflow_getQueues_Results) SetQueues added in v0.2.3 

func (s Workflow_getQueues_Results) SetQueues(v Queue_List) error

func (Workflow_getQueues_Results) String added in v0.2.3 

func (s Workflow_getQueues_Results) String() string

type Workflow_getQueues_Results_List added in v0.2.3 

type Workflow_getQueues_Results_List struct{ capnp.List }

Workflow_getQueues_Results_List is a list of Workflow_getQueues_Results.

func NewWorkflow_getQueues_Results_List added in v0.2.3 

func NewWorkflow_getQueues_Results_List(s *capnp.Segment, sz int32) (Workflow_getQueues_Results_List, error)

NewWorkflow_getQueues_Results creates a new list of Workflow_getQueues_Results.

func (Workflow_getQueues_Results_List) At added in v0.2.3 

func (s Workflow_getQueues_Results_List) At(i int) Workflow_getQueues_Results

func (Workflow_getQueues_Results_List) Set added in v0.2.3 

func (s Workflow_getQueues_Results_List) Set(i int, v Workflow_getQueues_Results) error

func (Workflow_getQueues_Results_List) String added in v0.2.3 

func (s Workflow_getQueues_Results_List) String() string

type Workflow_getQueues_Results_Promise added in v0.2.3 

type Workflow_getQueues_Results_Promise struct{ *capnp.Pipeline }

Workflow_getQueues_Results_Promise is a wrapper for a Workflow_getQueues_Results promised by a client call.

func (Workflow_getQueues_Results_Promise) Struct added in v0.2.3 

func (p Workflow_getQueues_Results_Promise) Struct() (Workflow_getQueues_Results, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.