Documentation
¶
Index ¶
- Constants
- func RegisterSchema(reg *schemas.Registry)
- type Message
- func (s Message) Content() Message_content
- func (Message) DecodeFromPtr(p capnp.Ptr) Message
- func (s Message) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Message) IsValid() bool
- func (s Message) Message() *capnp.Message
- func (s Message) Segment() *capnp.Segment
- func (s Message) String() string
- func (s Message) ToPtr() capnp.Ptr
- type Message_Future
- type Message_List
- type Message_content
- func (s Message_content) HasStartWorkerRequest() bool
- func (s Message_content) HasStartWorkerResponse() bool
- func (s Message_content) HasStopWorkerRequest() bool
- func (s Message_content) HasStopWorkerResponse() bool
- func (s Message_content) HasUpdateClientInfo() bool
- func (s Message_content) HasUpdateWorkerStatus() bool
- func (s Message_content) HasUpdateWorkerStdio() bool
- func (s Message_content) IsValid() bool
- func (s Message_content) Message() *capnp.Message
- func (s Message_content) NewStartWorkerRequest() (StartWorkerRequest, error)
- func (s Message_content) NewStartWorkerResponse() (StartWorkerResponse, error)
- func (s Message_content) NewStopWorkerRequest() (StopWorkerRequest, error)
- func (s Message_content) NewStopWorkerResponse() (StopWorkerResponse, error)
- func (s Message_content) NewUpdateClientInfo() (UpdateClientInfo, error)
- func (s Message_content) NewUpdateWorkerStatus() (UpdateWorkerStatus, error)
- func (s Message_content) NewUpdateWorkerStdio() (UpdateWorkerStdio, error)
- func (s Message_content) Segment() *capnp.Segment
- func (s Message_content) SetStartWorkerRequest(v StartWorkerRequest) error
- func (s Message_content) SetStartWorkerResponse(v StartWorkerResponse) error
- func (s Message_content) SetStopWorkerRequest(v StopWorkerRequest) error
- func (s Message_content) SetStopWorkerResponse(v StopWorkerResponse) error
- func (s Message_content) SetUpdateClientInfo(v UpdateClientInfo) error
- func (s Message_content) SetUpdateWorkerStatus(v UpdateWorkerStatus) error
- func (s Message_content) SetUpdateWorkerStdio(v UpdateWorkerStdio) error
- func (s Message_content) StartWorkerRequest() (StartWorkerRequest, error)
- func (s Message_content) StartWorkerResponse() (StartWorkerResponse, error)
- func (s Message_content) StopWorkerRequest() (StopWorkerRequest, error)
- func (s Message_content) StopWorkerResponse() (StopWorkerResponse, error)
- func (s Message_content) UpdateClientInfo() (UpdateClientInfo, error)
- func (s Message_content) UpdateWorkerStatus() (UpdateWorkerStatus, error)
- func (s Message_content) UpdateWorkerStdio() (UpdateWorkerStdio, error)
- func (s Message_content) Which() Message_content_Which
- type Message_content_Future
- func (p Message_content_Future) StartWorkerRequest() StartWorkerRequest_Future
- func (p Message_content_Future) StartWorkerResponse() StartWorkerResponse_Future
- func (p Message_content_Future) StopWorkerRequest() StopWorkerRequest_Future
- func (p Message_content_Future) StopWorkerResponse() StopWorkerResponse_Future
- func (f Message_content_Future) Struct() (Message_content, error)
- func (p Message_content_Future) UpdateClientInfo() UpdateClientInfo_Future
- func (p Message_content_Future) UpdateWorkerStatus() UpdateWorkerStatus_Future
- func (p Message_content_Future) UpdateWorkerStdio() UpdateWorkerStdio_Future
- type Message_content_Which
- type StartWorkerRequest
- func (s StartWorkerRequest) Args() (capnp.TextList, error)
- func (s StartWorkerRequest) Command() (string, error)
- func (s StartWorkerRequest) CommandBytes() ([]byte, error)
- func (StartWorkerRequest) DecodeFromPtr(p capnp.Ptr) StartWorkerRequest
- func (s StartWorkerRequest) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s StartWorkerRequest) Env() (capnp.TextList, error)
- func (s StartWorkerRequest) HasArgs() bool
- func (s StartWorkerRequest) HasCommand() bool
- func (s StartWorkerRequest) HasEnv() bool
- func (s StartWorkerRequest) IsValid() bool
- func (s StartWorkerRequest) Message() *capnp.Message
- func (s StartWorkerRequest) NewArgs(n int32) (capnp.TextList, error)
- func (s StartWorkerRequest) NewEnv(n int32) (capnp.TextList, error)
- func (s StartWorkerRequest) Segment() *capnp.Segment
- func (s StartWorkerRequest) SetArgs(v capnp.TextList) error
- func (s StartWorkerRequest) SetCommand(v string) error
- func (s StartWorkerRequest) SetEnv(v capnp.TextList) error
- func (s StartWorkerRequest) String() string
- func (s StartWorkerRequest) ToPtr() capnp.Ptr
- type StartWorkerRequest_Future
- type StartWorkerRequest_List
- type StartWorkerResponse
- func (StartWorkerResponse) DecodeFromPtr(p capnp.Ptr) StartWorkerResponse
- func (s StartWorkerResponse) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s StartWorkerResponse) Error() (string, error)
- func (s StartWorkerResponse) ErrorBytes() ([]byte, error)
- func (s StartWorkerResponse) HasError() bool
- func (s StartWorkerResponse) IsValid() bool
- func (s StartWorkerResponse) Message() *capnp.Message
- func (s StartWorkerResponse) Segment() *capnp.Segment
- func (s StartWorkerResponse) SetError(v string) error
- func (s StartWorkerResponse) String() string
- func (s StartWorkerResponse) ToPtr() capnp.Ptr
- type StartWorkerResponse_Future
- type StartWorkerResponse_List
- type StopWorkerRequest
- func (StopWorkerRequest) DecodeFromPtr(p capnp.Ptr) StopWorkerRequest
- func (s StopWorkerRequest) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s StopWorkerRequest) IsValid() bool
- func (s StopWorkerRequest) Message() *capnp.Message
- func (s StopWorkerRequest) Segment() *capnp.Segment
- func (s StopWorkerRequest) String() string
- func (s StopWorkerRequest) ToPtr() capnp.Ptr
- type StopWorkerRequest_Future
- type StopWorkerRequest_List
- type StopWorkerResponse
- func (StopWorkerResponse) DecodeFromPtr(p capnp.Ptr) StopWorkerResponse
- func (s StopWorkerResponse) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s StopWorkerResponse) Error() (string, error)
- func (s StopWorkerResponse) ErrorBytes() ([]byte, error)
- func (s StopWorkerResponse) HasError() bool
- func (s StopWorkerResponse) IsValid() bool
- func (s StopWorkerResponse) Message() *capnp.Message
- func (s StopWorkerResponse) Segment() *capnp.Segment
- func (s StopWorkerResponse) SetError(v string) error
- func (s StopWorkerResponse) String() string
- func (s StopWorkerResponse) ToPtr() capnp.Ptr
- type StopWorkerResponse_Future
- type StopWorkerResponse_List
- type UpdateClientInfo
- func (s UpdateClientInfo) Address() (string, error)
- func (s UpdateClientInfo) AddressBytes() ([]byte, error)
- func (UpdateClientInfo) DecodeFromPtr(p capnp.Ptr) UpdateClientInfo
- func (s UpdateClientInfo) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s UpdateClientInfo) HasAddress() bool
- func (s UpdateClientInfo) HasHostname() bool
- func (s UpdateClientInfo) HasSystem() bool
- func (s UpdateClientInfo) HasUsername() bool
- func (s UpdateClientInfo) Hostname() (string, error)
- func (s UpdateClientInfo) HostnameBytes() ([]byte, error)
- func (s UpdateClientInfo) IsValid() bool
- func (s UpdateClientInfo) Message() *capnp.Message
- func (s UpdateClientInfo) Segment() *capnp.Segment
- func (s UpdateClientInfo) SetAddress(v string) error
- func (s UpdateClientInfo) SetHostname(v string) error
- func (s UpdateClientInfo) SetSystem(v string) error
- func (s UpdateClientInfo) SetUsername(v string) error
- func (s UpdateClientInfo) String() string
- func (s UpdateClientInfo) System() (string, error)
- func (s UpdateClientInfo) SystemBytes() ([]byte, error)
- func (s UpdateClientInfo) ToPtr() capnp.Ptr
- func (s UpdateClientInfo) Username() (string, error)
- func (s UpdateClientInfo) UsernameBytes() ([]byte, error)
- type UpdateClientInfo_Future
- type UpdateClientInfo_List
- type UpdateWorkerStatus
- func (UpdateWorkerStatus) DecodeFromPtr(p capnp.Ptr) UpdateWorkerStatus
- func (s UpdateWorkerStatus) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s UpdateWorkerStatus) IsValid() bool
- func (s UpdateWorkerStatus) Message() *capnp.Message
- func (s UpdateWorkerStatus) Segment() *capnp.Segment
- func (s UpdateWorkerStatus) SetStatus(v int64)
- func (s UpdateWorkerStatus) Status() int64
- func (s UpdateWorkerStatus) String() string
- func (s UpdateWorkerStatus) ToPtr() capnp.Ptr
- type UpdateWorkerStatus_Future
- type UpdateWorkerStatus_List
- type UpdateWorkerStdio
- func (s UpdateWorkerStdio) Data() ([]byte, error)
- func (UpdateWorkerStdio) DecodeFromPtr(p capnp.Ptr) UpdateWorkerStdio
- func (s UpdateWorkerStdio) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s UpdateWorkerStdio) HasData() bool
- func (s UpdateWorkerStdio) IsValid() bool
- func (s UpdateWorkerStdio) Message() *capnp.Message
- func (s UpdateWorkerStdio) Segment() *capnp.Segment
- func (s UpdateWorkerStdio) SetData(v []byte) error
- func (s UpdateWorkerStdio) String() string
- func (s UpdateWorkerStdio) ToPtr() capnp.Ptr
- type UpdateWorkerStdio_Future
- type UpdateWorkerStdio_List
Constants ¶
const ( StartWorkerT = "FJ.API.WORKER.START.%s.%s" StopWorkerT = "FJ.API.WORKER.STOP.%s.%s" WriteWorkerStdinT = "FJ.API.WORKER.WRITE.STDIN.%s.%s" WriteWorkerStdoutT = "FJ.API.WORKER.WRITE.STDOUT.%s.%s" UpdateWorkerStatusT = "FJ.API.WORKER.UPDATE.STATUS.%s.%s" UpdateClientInfoT = "FJ.API.CLIENT.UPDATE.INFO.%s" ReplyMessageT = "FJ.API.MESSAGE.REPLY.%s.%s" )
Constants defined in proto.capnp.
const Message_TypeID = 0xd270ea7f372f79cd
Message_TypeID is the unique identifier for the type Message.
const StartWorkerRequest_TypeID = 0x9892032ea4e69c6b
StartWorkerRequest_TypeID is the unique identifier for the type StartWorkerRequest.
const StartWorkerResponse_TypeID = 0xc5f4047bf39fa88d
StartWorkerResponse_TypeID is the unique identifier for the type StartWorkerResponse.
const StopWorkerRequest_TypeID = 0xb15c44a86e45d3b0
StopWorkerRequest_TypeID is the unique identifier for the type StopWorkerRequest.
const StopWorkerResponse_TypeID = 0xdea9ade321ec73b3
StopWorkerResponse_TypeID is the unique identifier for the type StopWorkerResponse.
const UpdateClientInfo_TypeID = 0xa073b10fb899cbb0
UpdateClientInfo_TypeID is the unique identifier for the type UpdateClientInfo.
const UpdateWorkerStatus_TypeID = 0xa62a70011c9fd5df
UpdateWorkerStatus_TypeID is the unique identifier for the type UpdateWorkerStatus.
const UpdateWorkerStdio_TypeID = 0xa76a3a9604a9e962
UpdateWorkerStdio_TypeID is the unique identifier for the type UpdateWorkerStdio.
Variables ¶
This section is empty.
Functions ¶
func RegisterSchema ¶
Types ¶
type Message_Future ¶
Message_Future is a wrapper for a Message promised by a client call.
func (Message_Future) Content ¶ added in v0.4.0
func (p Message_Future) Content() Message_content_Future
func (Message_Future) Struct ¶
func (f Message_Future) Struct() (Message, error)
type Message_List ¶
type Message_List = capnp.StructList[Message]
Message_List is a list of Message.
func NewMessage_List ¶
func NewMessage_List(s *capnp.Segment, sz int32) (Message_List, error)
NewMessage creates a new list of Message.
type Message_content ¶ added in v0.4.0
type Message_content Message
func (Message_content) HasStartWorkerRequest ¶ added in v0.4.0
func (s Message_content) HasStartWorkerRequest() bool
func (Message_content) HasStartWorkerResponse ¶ added in v0.4.0
func (s Message_content) HasStartWorkerResponse() bool
func (Message_content) HasStopWorkerRequest ¶ added in v0.4.0
func (s Message_content) HasStopWorkerRequest() bool
func (Message_content) HasStopWorkerResponse ¶ added in v0.4.0
func (s Message_content) HasStopWorkerResponse() bool
func (Message_content) HasUpdateClientInfo ¶ added in v0.4.0
func (s Message_content) HasUpdateClientInfo() bool
func (Message_content) HasUpdateWorkerStatus ¶ added in v0.4.0
func (s Message_content) HasUpdateWorkerStatus() bool
func (Message_content) HasUpdateWorkerStdio ¶ added in v0.4.0
func (s Message_content) HasUpdateWorkerStdio() bool
func (Message_content) IsValid ¶ added in v0.4.0
func (s Message_content) IsValid() bool
func (Message_content) Message ¶ added in v0.4.0
func (s Message_content) Message() *capnp.Message
func (Message_content) NewStartWorkerRequest ¶ added in v0.4.0
func (s Message_content) NewStartWorkerRequest() (StartWorkerRequest, error)
NewStartWorkerRequest sets the startWorkerRequest field to a newly allocated StartWorkerRequest struct, preferring placement in s's segment.
func (Message_content) NewStartWorkerResponse ¶ added in v0.4.0
func (s Message_content) NewStartWorkerResponse() (StartWorkerResponse, error)
NewStartWorkerResponse sets the startWorkerResponse field to a newly allocated StartWorkerResponse struct, preferring placement in s's segment.
func (Message_content) NewStopWorkerRequest ¶ added in v0.4.0
func (s Message_content) NewStopWorkerRequest() (StopWorkerRequest, error)
NewStopWorkerRequest sets the stopWorkerRequest field to a newly allocated StopWorkerRequest struct, preferring placement in s's segment.
func (Message_content) NewStopWorkerResponse ¶ added in v0.4.0
func (s Message_content) NewStopWorkerResponse() (StopWorkerResponse, error)
NewStopWorkerResponse sets the stopWorkerResponse field to a newly allocated StopWorkerResponse struct, preferring placement in s's segment.
func (Message_content) NewUpdateClientInfo ¶ added in v0.4.0
func (s Message_content) NewUpdateClientInfo() (UpdateClientInfo, error)
NewUpdateClientInfo sets the updateClientInfo field to a newly allocated UpdateClientInfo struct, preferring placement in s's segment.
func (Message_content) NewUpdateWorkerStatus ¶ added in v0.4.0
func (s Message_content) NewUpdateWorkerStatus() (UpdateWorkerStatus, error)
NewUpdateWorkerStatus sets the updateWorkerStatus field to a newly allocated UpdateWorkerStatus struct, preferring placement in s's segment.
func (Message_content) NewUpdateWorkerStdio ¶ added in v0.4.0
func (s Message_content) NewUpdateWorkerStdio() (UpdateWorkerStdio, error)
NewUpdateWorkerStdio sets the updateWorkerStdio field to a newly allocated UpdateWorkerStdio struct, preferring placement in s's segment.
func (Message_content) Segment ¶ added in v0.4.0
func (s Message_content) Segment() *capnp.Segment
func (Message_content) SetStartWorkerRequest ¶ added in v0.4.0
func (s Message_content) SetStartWorkerRequest(v StartWorkerRequest) error
func (Message_content) SetStartWorkerResponse ¶ added in v0.4.0
func (s Message_content) SetStartWorkerResponse(v StartWorkerResponse) error
func (Message_content) SetStopWorkerRequest ¶ added in v0.4.0
func (s Message_content) SetStopWorkerRequest(v StopWorkerRequest) error
func (Message_content) SetStopWorkerResponse ¶ added in v0.4.0
func (s Message_content) SetStopWorkerResponse(v StopWorkerResponse) error
func (Message_content) SetUpdateClientInfo ¶ added in v0.4.0
func (s Message_content) SetUpdateClientInfo(v UpdateClientInfo) error
func (Message_content) SetUpdateWorkerStatus ¶ added in v0.4.0
func (s Message_content) SetUpdateWorkerStatus(v UpdateWorkerStatus) error
func (Message_content) SetUpdateWorkerStdio ¶ added in v0.4.0
func (s Message_content) SetUpdateWorkerStdio(v UpdateWorkerStdio) error
func (Message_content) StartWorkerRequest ¶ added in v0.4.0
func (s Message_content) StartWorkerRequest() (StartWorkerRequest, error)
func (Message_content) StartWorkerResponse ¶ added in v0.4.0
func (s Message_content) StartWorkerResponse() (StartWorkerResponse, error)
func (Message_content) StopWorkerRequest ¶ added in v0.4.0
func (s Message_content) StopWorkerRequest() (StopWorkerRequest, error)
func (Message_content) StopWorkerResponse ¶ added in v0.4.0
func (s Message_content) StopWorkerResponse() (StopWorkerResponse, error)
func (Message_content) UpdateClientInfo ¶ added in v0.4.0
func (s Message_content) UpdateClientInfo() (UpdateClientInfo, error)
func (Message_content) UpdateWorkerStatus ¶ added in v0.4.0
func (s Message_content) UpdateWorkerStatus() (UpdateWorkerStatus, error)
func (Message_content) UpdateWorkerStdio ¶ added in v0.4.0
func (s Message_content) UpdateWorkerStdio() (UpdateWorkerStdio, error)
func (Message_content) Which ¶ added in v0.4.0
func (s Message_content) Which() Message_content_Which
type Message_content_Future ¶ added in v0.4.0
Message_content_Future is a wrapper for a Message_content promised by a client call.
func (Message_content_Future) StartWorkerRequest ¶ added in v0.4.0
func (p Message_content_Future) StartWorkerRequest() StartWorkerRequest_Future
func (Message_content_Future) StartWorkerResponse ¶ added in v0.4.0
func (p Message_content_Future) StartWorkerResponse() StartWorkerResponse_Future
func (Message_content_Future) StopWorkerRequest ¶ added in v0.4.0
func (p Message_content_Future) StopWorkerRequest() StopWorkerRequest_Future
func (Message_content_Future) StopWorkerResponse ¶ added in v0.4.0
func (p Message_content_Future) StopWorkerResponse() StopWorkerResponse_Future
func (Message_content_Future) Struct ¶ added in v0.4.0
func (f Message_content_Future) Struct() (Message_content, error)
func (Message_content_Future) UpdateClientInfo ¶ added in v0.4.0
func (p Message_content_Future) UpdateClientInfo() UpdateClientInfo_Future
func (Message_content_Future) UpdateWorkerStatus ¶ added in v0.4.0
func (p Message_content_Future) UpdateWorkerStatus() UpdateWorkerStatus_Future
func (Message_content_Future) UpdateWorkerStdio ¶ added in v0.4.0
func (p Message_content_Future) UpdateWorkerStdio() UpdateWorkerStdio_Future
type Message_content_Which ¶ added in v0.4.0
type Message_content_Which uint16
const ( Message_content_Which_startWorkerRequest Message_content_Which = 0 Message_content_Which_startWorkerResponse Message_content_Which = 1 Message_content_Which_stopWorkerRequest Message_content_Which = 2 Message_content_Which_stopWorkerResponse Message_content_Which = 3 Message_content_Which_updateWorkerStatus Message_content_Which = 4 Message_content_Which_updateWorkerStdio Message_content_Which = 5 Message_content_Which_updateClientInfo Message_content_Which = 6 )
func (Message_content_Which) String ¶ added in v0.4.0
func (w Message_content_Which) String() string
type StartWorkerRequest ¶ added in v0.4.0
func NewRootStartWorkerRequest ¶ added in v0.4.0
func NewRootStartWorkerRequest(s *capnp.Segment) (StartWorkerRequest, error)
func NewStartWorkerRequest ¶ added in v0.4.0
func NewStartWorkerRequest(s *capnp.Segment) (StartWorkerRequest, error)
func ReadRootStartWorkerRequest ¶ added in v0.4.0
func ReadRootStartWorkerRequest(msg *capnp.Message) (StartWorkerRequest, error)
func (StartWorkerRequest) Args ¶ added in v0.4.0
func (s StartWorkerRequest) Args() (capnp.TextList, error)
func (StartWorkerRequest) Command ¶ added in v0.4.0
func (s StartWorkerRequest) Command() (string, error)
func (StartWorkerRequest) CommandBytes ¶ added in v0.4.0
func (s StartWorkerRequest) CommandBytes() ([]byte, error)
func (StartWorkerRequest) DecodeFromPtr ¶ added in v0.4.0
func (StartWorkerRequest) DecodeFromPtr(p capnp.Ptr) StartWorkerRequest
func (StartWorkerRequest) EncodeAsPtr ¶ added in v0.4.0
func (s StartWorkerRequest) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (StartWorkerRequest) Env ¶ added in v0.4.0
func (s StartWorkerRequest) Env() (capnp.TextList, error)
func (StartWorkerRequest) HasArgs ¶ added in v0.4.0
func (s StartWorkerRequest) HasArgs() bool
func (StartWorkerRequest) HasCommand ¶ added in v0.4.0
func (s StartWorkerRequest) HasCommand() bool
func (StartWorkerRequest) HasEnv ¶ added in v0.4.0
func (s StartWorkerRequest) HasEnv() bool
func (StartWorkerRequest) IsValid ¶ added in v0.4.0
func (s StartWorkerRequest) IsValid() bool
func (StartWorkerRequest) Message ¶ added in v0.4.0
func (s StartWorkerRequest) Message() *capnp.Message
func (StartWorkerRequest) NewArgs ¶ added in v0.4.0
func (s StartWorkerRequest) NewArgs(n int32) (capnp.TextList, error)
NewArgs sets the args field to a newly allocated capnp.TextList, preferring placement in s's segment.
func (StartWorkerRequest) NewEnv ¶ added in v0.4.0
func (s StartWorkerRequest) NewEnv(n int32) (capnp.TextList, error)
NewEnv sets the env field to a newly allocated capnp.TextList, preferring placement in s's segment.
func (StartWorkerRequest) Segment ¶ added in v0.4.0
func (s StartWorkerRequest) Segment() *capnp.Segment
func (StartWorkerRequest) SetArgs ¶ added in v0.4.0
func (s StartWorkerRequest) SetArgs(v capnp.TextList) error
func (StartWorkerRequest) SetCommand ¶ added in v0.4.0
func (s StartWorkerRequest) SetCommand(v string) error
func (StartWorkerRequest) SetEnv ¶ added in v0.4.0
func (s StartWorkerRequest) SetEnv(v capnp.TextList) error
func (StartWorkerRequest) String ¶ added in v0.4.0
func (s StartWorkerRequest) String() string
func (StartWorkerRequest) ToPtr ¶ added in v0.4.0
func (s StartWorkerRequest) ToPtr() capnp.Ptr
type StartWorkerRequest_Future ¶ added in v0.4.0
StartWorkerRequest_Future is a wrapper for a StartWorkerRequest promised by a client call.
func (StartWorkerRequest_Future) Struct ¶ added in v0.4.0
func (f StartWorkerRequest_Future) Struct() (StartWorkerRequest, error)
type StartWorkerRequest_List ¶ added in v0.4.0
type StartWorkerRequest_List = capnp.StructList[StartWorkerRequest]
StartWorkerRequest_List is a list of StartWorkerRequest.
func NewStartWorkerRequest_List ¶ added in v0.4.0
func NewStartWorkerRequest_List(s *capnp.Segment, sz int32) (StartWorkerRequest_List, error)
NewStartWorkerRequest creates a new list of StartWorkerRequest.
type StartWorkerResponse ¶ added in v0.4.0
func NewRootStartWorkerResponse ¶ added in v0.4.0
func NewRootStartWorkerResponse(s *capnp.Segment) (StartWorkerResponse, error)
func NewStartWorkerResponse ¶ added in v0.4.0
func NewStartWorkerResponse(s *capnp.Segment) (StartWorkerResponse, error)
func ReadRootStartWorkerResponse ¶ added in v0.4.0
func ReadRootStartWorkerResponse(msg *capnp.Message) (StartWorkerResponse, error)
func (StartWorkerResponse) DecodeFromPtr ¶ added in v0.4.0
func (StartWorkerResponse) DecodeFromPtr(p capnp.Ptr) StartWorkerResponse
func (StartWorkerResponse) EncodeAsPtr ¶ added in v0.4.0
func (s StartWorkerResponse) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (StartWorkerResponse) Error ¶ added in v0.4.0
func (s StartWorkerResponse) Error() (string, error)
func (StartWorkerResponse) ErrorBytes ¶ added in v0.4.0
func (s StartWorkerResponse) ErrorBytes() ([]byte, error)
func (StartWorkerResponse) HasError ¶ added in v0.4.0
func (s StartWorkerResponse) HasError() bool
func (StartWorkerResponse) IsValid ¶ added in v0.4.0
func (s StartWorkerResponse) IsValid() bool
func (StartWorkerResponse) Message ¶ added in v0.4.0
func (s StartWorkerResponse) Message() *capnp.Message
func (StartWorkerResponse) Segment ¶ added in v0.4.0
func (s StartWorkerResponse) Segment() *capnp.Segment
func (StartWorkerResponse) SetError ¶ added in v0.4.0
func (s StartWorkerResponse) SetError(v string) error
func (StartWorkerResponse) String ¶ added in v0.4.0
func (s StartWorkerResponse) String() string
func (StartWorkerResponse) ToPtr ¶ added in v0.4.0
func (s StartWorkerResponse) ToPtr() capnp.Ptr
type StartWorkerResponse_Future ¶ added in v0.4.0
StartWorkerResponse_Future is a wrapper for a StartWorkerResponse promised by a client call.
func (StartWorkerResponse_Future) Struct ¶ added in v0.4.0
func (f StartWorkerResponse_Future) Struct() (StartWorkerResponse, error)
type StartWorkerResponse_List ¶ added in v0.4.0
type StartWorkerResponse_List = capnp.StructList[StartWorkerResponse]
StartWorkerResponse_List is a list of StartWorkerResponse.
func NewStartWorkerResponse_List ¶ added in v0.4.0
func NewStartWorkerResponse_List(s *capnp.Segment, sz int32) (StartWorkerResponse_List, error)
NewStartWorkerResponse creates a new list of StartWorkerResponse.
type StopWorkerRequest ¶ added in v0.4.0
func NewRootStopWorkerRequest ¶ added in v0.4.0
func NewRootStopWorkerRequest(s *capnp.Segment) (StopWorkerRequest, error)
func NewStopWorkerRequest ¶ added in v0.4.0
func NewStopWorkerRequest(s *capnp.Segment) (StopWorkerRequest, error)
func ReadRootStopWorkerRequest ¶ added in v0.4.0
func ReadRootStopWorkerRequest(msg *capnp.Message) (StopWorkerRequest, error)
func (StopWorkerRequest) DecodeFromPtr ¶ added in v0.4.0
func (StopWorkerRequest) DecodeFromPtr(p capnp.Ptr) StopWorkerRequest
func (StopWorkerRequest) EncodeAsPtr ¶ added in v0.4.0
func (s StopWorkerRequest) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (StopWorkerRequest) IsValid ¶ added in v0.4.0
func (s StopWorkerRequest) IsValid() bool
func (StopWorkerRequest) Message ¶ added in v0.4.0
func (s StopWorkerRequest) Message() *capnp.Message
func (StopWorkerRequest) Segment ¶ added in v0.4.0
func (s StopWorkerRequest) Segment() *capnp.Segment
func (StopWorkerRequest) String ¶ added in v0.4.0
func (s StopWorkerRequest) String() string
func (StopWorkerRequest) ToPtr ¶ added in v0.4.0
func (s StopWorkerRequest) ToPtr() capnp.Ptr
type StopWorkerRequest_Future ¶ added in v0.4.0
StopWorkerRequest_Future is a wrapper for a StopWorkerRequest promised by a client call.
func (StopWorkerRequest_Future) Struct ¶ added in v0.4.0
func (f StopWorkerRequest_Future) Struct() (StopWorkerRequest, error)
type StopWorkerRequest_List ¶ added in v0.4.0
type StopWorkerRequest_List = capnp.StructList[StopWorkerRequest]
StopWorkerRequest_List is a list of StopWorkerRequest.
func NewStopWorkerRequest_List ¶ added in v0.4.0
func NewStopWorkerRequest_List(s *capnp.Segment, sz int32) (StopWorkerRequest_List, error)
NewStopWorkerRequest creates a new list of StopWorkerRequest.
type StopWorkerResponse ¶ added in v0.4.0
func NewRootStopWorkerResponse ¶ added in v0.4.0
func NewRootStopWorkerResponse(s *capnp.Segment) (StopWorkerResponse, error)
func NewStopWorkerResponse ¶ added in v0.4.0
func NewStopWorkerResponse(s *capnp.Segment) (StopWorkerResponse, error)
func ReadRootStopWorkerResponse ¶ added in v0.4.0
func ReadRootStopWorkerResponse(msg *capnp.Message) (StopWorkerResponse, error)
func (StopWorkerResponse) DecodeFromPtr ¶ added in v0.4.0
func (StopWorkerResponse) DecodeFromPtr(p capnp.Ptr) StopWorkerResponse
func (StopWorkerResponse) EncodeAsPtr ¶ added in v0.4.0
func (s StopWorkerResponse) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (StopWorkerResponse) Error ¶ added in v0.4.0
func (s StopWorkerResponse) Error() (string, error)
func (StopWorkerResponse) ErrorBytes ¶ added in v0.4.0
func (s StopWorkerResponse) ErrorBytes() ([]byte, error)
func (StopWorkerResponse) HasError ¶ added in v0.4.0
func (s StopWorkerResponse) HasError() bool
func (StopWorkerResponse) IsValid ¶ added in v0.4.0
func (s StopWorkerResponse) IsValid() bool
func (StopWorkerResponse) Message ¶ added in v0.4.0
func (s StopWorkerResponse) Message() *capnp.Message
func (StopWorkerResponse) Segment ¶ added in v0.4.0
func (s StopWorkerResponse) Segment() *capnp.Segment
func (StopWorkerResponse) SetError ¶ added in v0.4.0
func (s StopWorkerResponse) SetError(v string) error
func (StopWorkerResponse) String ¶ added in v0.4.0
func (s StopWorkerResponse) String() string
func (StopWorkerResponse) ToPtr ¶ added in v0.4.0
func (s StopWorkerResponse) ToPtr() capnp.Ptr
type StopWorkerResponse_Future ¶ added in v0.4.0
StopWorkerResponse_Future is a wrapper for a StopWorkerResponse promised by a client call.
func (StopWorkerResponse_Future) Struct ¶ added in v0.4.0
func (f StopWorkerResponse_Future) Struct() (StopWorkerResponse, error)
type StopWorkerResponse_List ¶ added in v0.4.0
type StopWorkerResponse_List = capnp.StructList[StopWorkerResponse]
StopWorkerResponse_List is a list of StopWorkerResponse.
func NewStopWorkerResponse_List ¶ added in v0.4.0
func NewStopWorkerResponse_List(s *capnp.Segment, sz int32) (StopWorkerResponse_List, error)
NewStopWorkerResponse creates a new list of StopWorkerResponse.
type UpdateClientInfo ¶ added in v0.4.0
func NewRootUpdateClientInfo ¶ added in v0.4.0
func NewRootUpdateClientInfo(s *capnp.Segment) (UpdateClientInfo, error)
func NewUpdateClientInfo ¶ added in v0.4.0
func NewUpdateClientInfo(s *capnp.Segment) (UpdateClientInfo, error)
func ReadRootUpdateClientInfo ¶ added in v0.4.0
func ReadRootUpdateClientInfo(msg *capnp.Message) (UpdateClientInfo, error)
func (UpdateClientInfo) Address ¶ added in v0.4.0
func (s UpdateClientInfo) Address() (string, error)
func (UpdateClientInfo) AddressBytes ¶ added in v0.4.0
func (s UpdateClientInfo) AddressBytes() ([]byte, error)
func (UpdateClientInfo) DecodeFromPtr ¶ added in v0.4.0
func (UpdateClientInfo) DecodeFromPtr(p capnp.Ptr) UpdateClientInfo
func (UpdateClientInfo) EncodeAsPtr ¶ added in v0.4.0
func (s UpdateClientInfo) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (UpdateClientInfo) HasAddress ¶ added in v0.4.0
func (s UpdateClientInfo) HasAddress() bool
func (UpdateClientInfo) HasHostname ¶ added in v0.4.0
func (s UpdateClientInfo) HasHostname() bool
func (UpdateClientInfo) HasSystem ¶ added in v0.4.0
func (s UpdateClientInfo) HasSystem() bool
func (UpdateClientInfo) HasUsername ¶ added in v0.4.0
func (s UpdateClientInfo) HasUsername() bool
func (UpdateClientInfo) Hostname ¶ added in v0.4.0
func (s UpdateClientInfo) Hostname() (string, error)
func (UpdateClientInfo) HostnameBytes ¶ added in v0.4.0
func (s UpdateClientInfo) HostnameBytes() ([]byte, error)
func (UpdateClientInfo) IsValid ¶ added in v0.4.0
func (s UpdateClientInfo) IsValid() bool
func (UpdateClientInfo) Message ¶ added in v0.4.0
func (s UpdateClientInfo) Message() *capnp.Message
func (UpdateClientInfo) Segment ¶ added in v0.4.0
func (s UpdateClientInfo) Segment() *capnp.Segment
func (UpdateClientInfo) SetAddress ¶ added in v0.4.0
func (s UpdateClientInfo) SetAddress(v string) error
func (UpdateClientInfo) SetHostname ¶ added in v0.4.0
func (s UpdateClientInfo) SetHostname(v string) error
func (UpdateClientInfo) SetSystem ¶ added in v0.4.0
func (s UpdateClientInfo) SetSystem(v string) error
func (UpdateClientInfo) SetUsername ¶ added in v0.4.0
func (s UpdateClientInfo) SetUsername(v string) error
func (UpdateClientInfo) String ¶ added in v0.4.0
func (s UpdateClientInfo) String() string
func (UpdateClientInfo) System ¶ added in v0.4.0
func (s UpdateClientInfo) System() (string, error)
func (UpdateClientInfo) SystemBytes ¶ added in v0.4.0
func (s UpdateClientInfo) SystemBytes() ([]byte, error)
func (UpdateClientInfo) ToPtr ¶ added in v0.4.0
func (s UpdateClientInfo) ToPtr() capnp.Ptr
func (UpdateClientInfo) Username ¶ added in v0.4.0
func (s UpdateClientInfo) Username() (string, error)
func (UpdateClientInfo) UsernameBytes ¶ added in v0.4.0
func (s UpdateClientInfo) UsernameBytes() ([]byte, error)
type UpdateClientInfo_Future ¶ added in v0.4.0
UpdateClientInfo_Future is a wrapper for a UpdateClientInfo promised by a client call.
func (UpdateClientInfo_Future) Struct ¶ added in v0.4.0
func (f UpdateClientInfo_Future) Struct() (UpdateClientInfo, error)
type UpdateClientInfo_List ¶ added in v0.4.0
type UpdateClientInfo_List = capnp.StructList[UpdateClientInfo]
UpdateClientInfo_List is a list of UpdateClientInfo.
func NewUpdateClientInfo_List ¶ added in v0.4.0
func NewUpdateClientInfo_List(s *capnp.Segment, sz int32) (UpdateClientInfo_List, error)
NewUpdateClientInfo creates a new list of UpdateClientInfo.
type UpdateWorkerStatus ¶ added in v0.4.0
func NewRootUpdateWorkerStatus ¶ added in v0.4.0
func NewRootUpdateWorkerStatus(s *capnp.Segment) (UpdateWorkerStatus, error)
func NewUpdateWorkerStatus ¶ added in v0.4.0
func NewUpdateWorkerStatus(s *capnp.Segment) (UpdateWorkerStatus, error)
func ReadRootUpdateWorkerStatus ¶ added in v0.4.0
func ReadRootUpdateWorkerStatus(msg *capnp.Message) (UpdateWorkerStatus, error)
func (UpdateWorkerStatus) DecodeFromPtr ¶ added in v0.4.0
func (UpdateWorkerStatus) DecodeFromPtr(p capnp.Ptr) UpdateWorkerStatus
func (UpdateWorkerStatus) EncodeAsPtr ¶ added in v0.4.0
func (s UpdateWorkerStatus) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (UpdateWorkerStatus) IsValid ¶ added in v0.4.0
func (s UpdateWorkerStatus) IsValid() bool
func (UpdateWorkerStatus) Message ¶ added in v0.4.0
func (s UpdateWorkerStatus) Message() *capnp.Message
func (UpdateWorkerStatus) Segment ¶ added in v0.4.0
func (s UpdateWorkerStatus) Segment() *capnp.Segment
func (UpdateWorkerStatus) SetStatus ¶ added in v0.4.0
func (s UpdateWorkerStatus) SetStatus(v int64)
func (UpdateWorkerStatus) Status ¶ added in v0.4.0
func (s UpdateWorkerStatus) Status() int64
func (UpdateWorkerStatus) String ¶ added in v0.4.0
func (s UpdateWorkerStatus) String() string
func (UpdateWorkerStatus) ToPtr ¶ added in v0.4.0
func (s UpdateWorkerStatus) ToPtr() capnp.Ptr
type UpdateWorkerStatus_Future ¶ added in v0.4.0
UpdateWorkerStatus_Future is a wrapper for a UpdateWorkerStatus promised by a client call.
func (UpdateWorkerStatus_Future) Struct ¶ added in v0.4.0
func (f UpdateWorkerStatus_Future) Struct() (UpdateWorkerStatus, error)
type UpdateWorkerStatus_List ¶ added in v0.4.0
type UpdateWorkerStatus_List = capnp.StructList[UpdateWorkerStatus]
UpdateWorkerStatus_List is a list of UpdateWorkerStatus.
func NewUpdateWorkerStatus_List ¶ added in v0.4.0
func NewUpdateWorkerStatus_List(s *capnp.Segment, sz int32) (UpdateWorkerStatus_List, error)
NewUpdateWorkerStatus creates a new list of UpdateWorkerStatus.
type UpdateWorkerStdio ¶ added in v0.4.0
func NewRootUpdateWorkerStdio ¶ added in v0.4.0
func NewRootUpdateWorkerStdio(s *capnp.Segment) (UpdateWorkerStdio, error)
func NewUpdateWorkerStdio ¶ added in v0.4.0
func NewUpdateWorkerStdio(s *capnp.Segment) (UpdateWorkerStdio, error)
func ReadRootUpdateWorkerStdio ¶ added in v0.4.0
func ReadRootUpdateWorkerStdio(msg *capnp.Message) (UpdateWorkerStdio, error)
func (UpdateWorkerStdio) Data ¶ added in v0.4.0
func (s UpdateWorkerStdio) Data() ([]byte, error)
func (UpdateWorkerStdio) DecodeFromPtr ¶ added in v0.4.0
func (UpdateWorkerStdio) DecodeFromPtr(p capnp.Ptr) UpdateWorkerStdio
func (UpdateWorkerStdio) EncodeAsPtr ¶ added in v0.4.0
func (s UpdateWorkerStdio) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (UpdateWorkerStdio) HasData ¶ added in v0.4.0
func (s UpdateWorkerStdio) HasData() bool
func (UpdateWorkerStdio) IsValid ¶ added in v0.4.0
func (s UpdateWorkerStdio) IsValid() bool
func (UpdateWorkerStdio) Message ¶ added in v0.4.0
func (s UpdateWorkerStdio) Message() *capnp.Message
func (UpdateWorkerStdio) Segment ¶ added in v0.4.0
func (s UpdateWorkerStdio) Segment() *capnp.Segment
func (UpdateWorkerStdio) SetData ¶ added in v0.4.0
func (s UpdateWorkerStdio) SetData(v []byte) error
func (UpdateWorkerStdio) String ¶ added in v0.4.0
func (s UpdateWorkerStdio) String() string
func (UpdateWorkerStdio) ToPtr ¶ added in v0.4.0
func (s UpdateWorkerStdio) ToPtr() capnp.Ptr
type UpdateWorkerStdio_Future ¶ added in v0.4.0
UpdateWorkerStdio_Future is a wrapper for a UpdateWorkerStdio promised by a client call.
func (UpdateWorkerStdio_Future) Struct ¶ added in v0.4.0
func (f UpdateWorkerStdio_Future) Struct() (UpdateWorkerStdio, error)
type UpdateWorkerStdio_List ¶ added in v0.4.0
type UpdateWorkerStdio_List = capnp.StructList[UpdateWorkerStdio]
UpdateWorkerStdio_List is a list of UpdateWorkerStdio.
func NewUpdateWorkerStdio_List ¶ added in v0.4.0
func NewUpdateWorkerStdio_List(s *capnp.Segment, sz int32) (UpdateWorkerStdio_List, error)
NewUpdateWorkerStdio creates a new list of UpdateWorkerStdio.