cluster

package module
v0.0.0-...-7d73fae Latest Latest
Warning

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

 Go to latest Published: Jun 6, 2024 License: MPL-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const Cluster_AdminMaster_TypeID = 0xbf24278c65f633ce

Cluster_AdminMaster_TypeID is the unique identifier for the type Cluster_AdminMaster.

View Source 
const Cluster_AdminMaster_availableModels_Params_TypeID = 0xa0669b656ba6cc8e

Cluster_AdminMaster_availableModels_Params_TypeID is the unique identifier for the type Cluster_AdminMaster_availableModels_Params.

View Source 
const Cluster_AdminMaster_availableModels_Results_TypeID = 0xd4bece01a7c4008f

Cluster_AdminMaster_availableModels_Results_TypeID is the unique identifier for the type Cluster_AdminMaster_availableModels_Results.

View Source 
const Cluster_AdminMaster_registerModelInstanceFactory_Params_TypeID = 0x943b54ee6f4de610

Cluster_AdminMaster_registerModelInstanceFactory_Params_TypeID is the unique identifier for the type Cluster_AdminMaster_registerModelInstanceFactory_Params.

View Source 
const Cluster_AdminMaster_registerModelInstanceFactory_Results_TypeID = 0xe7434f81e2b1e3de

Cluster_AdminMaster_registerModelInstanceFactory_Results_TypeID is the unique identifier for the type Cluster_AdminMaster_registerModelInstanceFactory_Results.

View Source 
const Cluster_ModelInstanceFactory_TypeID = 0xfd9959998f9f0ebe

Cluster_ModelInstanceFactory_TypeID is the unique identifier for the type Cluster_ModelInstanceFactory.

View Source 
const Cluster_ModelInstanceFactory_modelId_Params_TypeID = 0xe4b6ea2bfbc474d8

Cluster_ModelInstanceFactory_modelId_Params_TypeID is the unique identifier for the type Cluster_ModelInstanceFactory_modelId_Params.

View Source 
const Cluster_ModelInstanceFactory_modelId_Results_TypeID = 0xe3cf5a40e703e6da

Cluster_ModelInstanceFactory_modelId_Results_TypeID is the unique identifier for the type Cluster_ModelInstanceFactory_modelId_Results.

View Source 
const Cluster_ModelInstanceFactory_newCloudViaProxy_Params_TypeID = 0xfea4c3f998b67621

Cluster_ModelInstanceFactory_newCloudViaProxy_Params_TypeID is the unique identifier for the type Cluster_ModelInstanceFactory_newCloudViaProxy_Params.

View Source 
const Cluster_ModelInstanceFactory_newCloudViaProxy_Results_TypeID = 0xbaf979a1f5673019

Cluster_ModelInstanceFactory_newCloudViaProxy_Results_TypeID is the unique identifier for the type Cluster_ModelInstanceFactory_newCloudViaProxy_Results.

View Source 
const Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params_TypeID = 0x8b5d8251cf57c316

Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params_TypeID is the unique identifier for the type Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params.

View Source 
const Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results_TypeID = 0xa81053c61d4d995c

Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results_TypeID is the unique identifier for the type Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results.

View Source 
const Cluster_ModelInstanceFactory_newInstance_Params_TypeID = 0x8bf81264d2f11274

Cluster_ModelInstanceFactory_newInstance_Params_TypeID is the unique identifier for the type Cluster_ModelInstanceFactory_newInstance_Params.

View Source 
const Cluster_ModelInstanceFactory_newInstance_Results_TypeID = 0xf468b1dc515f841c

Cluster_ModelInstanceFactory_newInstance_Results_TypeID is the unique identifier for the type Cluster_ModelInstanceFactory_newInstance_Results.

View Source 
const Cluster_ModelInstanceFactory_newInstances_Params_TypeID = 0x985d83a2e2d7e204

Cluster_ModelInstanceFactory_newInstances_Params_TypeID is the unique identifier for the type Cluster_ModelInstanceFactory_newInstances_Params.

View Source 
const Cluster_ModelInstanceFactory_newInstances_Results_TypeID = 0xbcacf6dde70da193

Cluster_ModelInstanceFactory_newInstances_Results_TypeID is the unique identifier for the type Cluster_ModelInstanceFactory_newInstances_Results.

View Source 
const Cluster_ModelInstanceFactory_registerModelInstance_Params_TypeID = 0xbea41d4487c101c4

Cluster_ModelInstanceFactory_registerModelInstance_Params_TypeID is the unique identifier for the type Cluster_ModelInstanceFactory_registerModelInstance_Params.

View Source 
const Cluster_ModelInstanceFactory_registerModelInstance_Results_TypeID = 0xca8fb2a4c16e5f08

Cluster_ModelInstanceFactory_registerModelInstance_Results_TypeID is the unique identifier for the type Cluster_ModelInstanceFactory_registerModelInstance_Results.

View Source 
const Cluster_ModelInstanceFactory_restoreSturdyRef_Params_TypeID = 0xd88a3f78cce2bc7d

Cluster_ModelInstanceFactory_restoreSturdyRef_Params_TypeID is the unique identifier for the type Cluster_ModelInstanceFactory_restoreSturdyRef_Params.

View Source 
const Cluster_ModelInstanceFactory_restoreSturdyRef_Results_TypeID = 0xe5cdfbf0462c5cfd

Cluster_ModelInstanceFactory_restoreSturdyRef_Results_TypeID is the unique identifier for the type Cluster_ModelInstanceFactory_restoreSturdyRef_Results.

View Source 
const Cluster_Runtime_TypeID = 0xf849848fea5c4776

Cluster_Runtime_TypeID is the unique identifier for the type Cluster_Runtime.

View Source 
const Cluster_Runtime_availableModels_Params_TypeID = 0xfe35aabe121add1a

Cluster_Runtime_availableModels_Params_TypeID is the unique identifier for the type Cluster_Runtime_availableModels_Params.

View Source 
const Cluster_Runtime_availableModels_Results_TypeID = 0x93bdb3f5b6eecd29

Cluster_Runtime_availableModels_Results_TypeID is the unique identifier for the type Cluster_Runtime_availableModels_Results.

View Source 
const Cluster_Runtime_freeNumberOfCores_Params_TypeID = 0xc224b7ff6089b64e

Cluster_Runtime_freeNumberOfCores_Params_TypeID is the unique identifier for the type Cluster_Runtime_freeNumberOfCores_Params.

View Source 
const Cluster_Runtime_freeNumberOfCores_Results_TypeID = 0xf004ae32302172c6

Cluster_Runtime_freeNumberOfCores_Results_TypeID is the unique identifier for the type Cluster_Runtime_freeNumberOfCores_Results.

View Source 
const Cluster_Runtime_numberOfCores_Params_TypeID = 0x9b3d2c0c5054766c

Cluster_Runtime_numberOfCores_Params_TypeID is the unique identifier for the type Cluster_Runtime_numberOfCores_Params.

View Source 
const Cluster_Runtime_numberOfCores_Results_TypeID = 0xe6b2589f9a250d7f

Cluster_Runtime_numberOfCores_Results_TypeID is the unique identifier for the type Cluster_Runtime_numberOfCores_Results.

View Source 
const Cluster_Runtime_registerModelInstanceFactory_Params_TypeID = 0xc3668a8f7946ce88

Cluster_Runtime_registerModelInstanceFactory_Params_TypeID is the unique identifier for the type Cluster_Runtime_registerModelInstanceFactory_Params.

View Source 
const Cluster_Runtime_registerModelInstanceFactory_Results_TypeID = 0xa8dfab7b88664bd4

Cluster_Runtime_registerModelInstanceFactory_Results_TypeID is the unique identifier for the type Cluster_Runtime_registerModelInstanceFactory_Results.

View Source 
const Cluster_Runtime_reserveNumberOfCores_Params_TypeID = 0xb4d00b302a119de9

Cluster_Runtime_reserveNumberOfCores_Params_TypeID is the unique identifier for the type Cluster_Runtime_reserveNumberOfCores_Params.

View Source 
const Cluster_Runtime_reserveNumberOfCores_Results_TypeID = 0xbcd8dd8cea624cbb

Cluster_Runtime_reserveNumberOfCores_Results_TypeID is the unique identifier for the type Cluster_Runtime_reserveNumberOfCores_Results.

View Source 
const Cluster_TypeID = 0xf7485d56d6f20e7d

Cluster_TypeID is the unique identifier for the type Cluster.

View Source 
const Cluster_Unregister_TypeID = 0xe8b1f7a192651bbe

Cluster_Unregister_TypeID is the unique identifier for the type Cluster_Unregister.

View Source 
const Cluster_Unregister_unregister_Params_TypeID = 0xe1b78932a9f7aea3

Cluster_Unregister_unregister_Params_TypeID is the unique identifier for the type Cluster_Unregister_unregister_Params.

View Source 
const Cluster_Unregister_unregister_Results_TypeID = 0xbba96ef3714f338f

Cluster_Unregister_unregister_Results_TypeID is the unique identifier for the type Cluster_Unregister_unregister_Results.

View Source 
const Cluster_UserMaster_TypeID = 0xec42c6df28354b60

Cluster_UserMaster_TypeID is the unique identifier for the type Cluster_UserMaster.

View Source 
const Cluster_UserMaster_availableModels_Params_TypeID = 0x9a80efc085eae065

Cluster_UserMaster_availableModels_Params_TypeID is the unique identifier for the type Cluster_UserMaster_availableModels_Params.

View Source 
const Cluster_UserMaster_availableModels_Results_TypeID = 0xb147e4fbf7081bda

Cluster_UserMaster_availableModels_Results_TypeID is the unique identifier for the type Cluster_UserMaster_availableModels_Results.

View Source 
const Cluster_ValueHolder_TypeID = 0xd6acf080dcf2b4c8

Cluster_ValueHolder_TypeID is the unique identifier for the type Cluster_ValueHolder.

View Source 
const Cluster_ValueHolder_releaseValue_Params_TypeID = 0xa967c8b00a278896

Cluster_ValueHolder_releaseValue_Params_TypeID is the unique identifier for the type Cluster_ValueHolder_releaseValue_Params.

View Source 
const Cluster_ValueHolder_releaseValue_Results_TypeID = 0xddbd9a18593be0c5

Cluster_ValueHolder_releaseValue_Results_TypeID is the unique identifier for the type Cluster_ValueHolder_releaseValue_Results.

View Source 
const Cluster_ValueHolder_value_Params_TypeID = 0x8ba6569cca01e84f

Cluster_ValueHolder_value_Params_TypeID is the unique identifier for the type Cluster_ValueHolder_value_Params.

View Source 
const Cluster_ValueHolder_value_Results_TypeID = 0x815e89f778f1da6c

Cluster_ValueHolder_value_Results_TypeID is the unique identifier for the type Cluster_ValueHolder_value_Results.

View Source 
const Cluster_ZmqPipelineAddresses_TypeID = 0xc9034ba2becc2a64

Cluster_ZmqPipelineAddresses_TypeID is the unique identifier for the type Cluster_ZmqPipelineAddresses.

Variables

This section is empty.

Functions

func Cluster_AdminMaster_Methods 

func Cluster_AdminMaster_Methods(methods []server.Method, s Cluster_AdminMaster_Server) []server.Method

Cluster_AdminMaster_Methods appends Methods to a slice that invoke the methods on s. This can be used to create a more complicated Server.

func Cluster_AdminMaster_NewServer 

func Cluster_AdminMaster_NewServer(s Cluster_AdminMaster_Server) *server.Server

Cluster_AdminMaster_NewServer creates a new Server from an implementation of Cluster_AdminMaster_Server.

func Cluster_ModelInstanceFactory_Methods 

func Cluster_ModelInstanceFactory_Methods(methods []server.Method, s Cluster_ModelInstanceFactory_Server) []server.Method

Cluster_ModelInstanceFactory_Methods appends Methods to a slice that invoke the methods on s. This can be used to create a more complicated Server.

func Cluster_ModelInstanceFactory_NewServer 

func Cluster_ModelInstanceFactory_NewServer(s Cluster_ModelInstanceFactory_Server) *server.Server

Cluster_ModelInstanceFactory_NewServer creates a new Server from an implementation of Cluster_ModelInstanceFactory_Server.

func Cluster_Runtime_Methods 

func Cluster_Runtime_Methods(methods []server.Method, s Cluster_Runtime_Server) []server.Method

Cluster_Runtime_Methods appends Methods to a slice that invoke the methods on s. This can be used to create a more complicated Server.

func Cluster_Runtime_NewServer 

func Cluster_Runtime_NewServer(s Cluster_Runtime_Server) *server.Server

Cluster_Runtime_NewServer creates a new Server from an implementation of Cluster_Runtime_Server.

func Cluster_Unregister_Methods 

func Cluster_Unregister_Methods(methods []server.Method, s Cluster_Unregister_Server) []server.Method

Cluster_Unregister_Methods appends Methods to a slice that invoke the methods on s. This can be used to create a more complicated Server.

func Cluster_Unregister_NewServer 

func Cluster_Unregister_NewServer(s Cluster_Unregister_Server) *server.Server

Cluster_Unregister_NewServer creates a new Server from an implementation of Cluster_Unregister_Server.

func Cluster_UserMaster_Methods 

func Cluster_UserMaster_Methods(methods []server.Method, s Cluster_UserMaster_Server) []server.Method

Cluster_UserMaster_Methods appends Methods to a slice that invoke the methods on s. This can be used to create a more complicated Server.

func Cluster_UserMaster_NewServer 

func Cluster_UserMaster_NewServer(s Cluster_UserMaster_Server) *server.Server

Cluster_UserMaster_NewServer creates a new Server from an implementation of Cluster_UserMaster_Server.

func Cluster_ValueHolder_Methods 

func Cluster_ValueHolder_Methods(methods []server.Method, s Cluster_ValueHolder_Server) []server.Method

Cluster_ValueHolder_Methods appends Methods to a slice that invoke the methods on s. This can be used to create a more complicated Server.

func Cluster_ValueHolder_NewServer 

func Cluster_ValueHolder_NewServer(s Cluster_ValueHolder_Server) *server.Server

Cluster_ValueHolder_NewServer creates a new Server from an implementation of Cluster_ValueHolder_Server.

func RegisterSchema 

func RegisterSchema(reg *schemas.Registry)

Types

type Cluster 

type Cluster capnp.Struct

func NewCluster 

func NewCluster(s *capnp.Segment) (Cluster, error)

func NewRootCluster 

func NewRootCluster(s *capnp.Segment) (Cluster, error)

func ReadRootCluster 

func ReadRootCluster(msg *capnp.Message) (Cluster, error)

func (Cluster) DecodeFromPtr 

func (Cluster) DecodeFromPtr(p capnp.Ptr) Cluster

func (Cluster) EncodeAsPtr 

func (s Cluster) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster) IsValid 

func (s Cluster) IsValid() bool

func (Cluster) Message 

func (s Cluster) Message() *capnp.Message

func (Cluster) Segment 

func (s Cluster) Segment() *capnp.Segment

func (Cluster) String 

func (s Cluster) String() string

func (Cluster) ToPtr 

func (s Cluster) ToPtr() capnp.Ptr

type Cluster_AdminMaster 

type Cluster_AdminMaster capnp.Client

func Cluster_AdminMaster_ServerToClient 

func Cluster_AdminMaster_ServerToClient(s Cluster_AdminMaster_Server) Cluster_AdminMaster

Cluster_AdminMaster_ServerToClient creates a new Client from an implementation of Cluster_AdminMaster_Server. The caller is responsible for calling Release on the returned Client.

func (Cluster_AdminMaster) AddRef 

func (c Cluster_AdminMaster) AddRef() Cluster_AdminMaster

AddRef creates a new Client that refers to the same capability as c. If c is nil or has resolved to null, then AddRef returns nil.

func (Cluster_AdminMaster) AvailableModels 

func (c Cluster_AdminMaster) AvailableModels(ctx context.Context, params func(Cluster_AdminMaster_availableModels_Params) error) (Cluster_AdminMaster_availableModels_Results_Future, capnp.ReleaseFunc)

func (Cluster_AdminMaster) DecodeFromPtr 

func (Cluster_AdminMaster) DecodeFromPtr(p capnp.Ptr) Cluster_AdminMaster

func (Cluster_AdminMaster) EncodeAsPtr 

func (c Cluster_AdminMaster) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_AdminMaster) GetFlowLimiter 

func (c Cluster_AdminMaster) GetFlowLimiter() fc.FlowLimiter

Get the current flowcontrol.FlowLimiter used to manage flow control for this client.

func (Cluster_AdminMaster) Info 

func (c Cluster_AdminMaster) Info(ctx context.Context, params func(common.Identifiable_info_Params) error) (common.IdInformation_Future, capnp.ReleaseFunc)

func (Cluster_AdminMaster) IsSame 

func (c Cluster_AdminMaster) IsSame(other Cluster_AdminMaster) bool

IsSame reports whether c and other refer to a capability created by the same call to NewClient. This can return false negatives if c or other are not fully resolved: use Resolve if this is an issue. If either c or other are released, then IsSame panics.

func (Cluster_AdminMaster) IsValid 

func (c Cluster_AdminMaster) IsValid() bool

IsValid reports whether c is a valid reference to a capability. A reference is invalid if it is nil, has resolved to null, or has been released.

func (Cluster_AdminMaster) RegisterModelInstanceFactory 

func (c Cluster_AdminMaster) RegisterModelInstanceFactory(ctx context.Context, params func(Cluster_AdminMaster_registerModelInstanceFactory_Params) error) (Cluster_AdminMaster_registerModelInstanceFactory_Results_Future, capnp.ReleaseFunc)

func (Cluster_AdminMaster) Release 

func (c Cluster_AdminMaster) Release()

Release releases a capability reference. If this is the last reference to the capability, then the underlying resources associated with the capability will be released.

Release will panic if c has already been released, but not if c is nil or resolved to null.

func (Cluster_AdminMaster) Resolve 

func (c Cluster_AdminMaster) Resolve(ctx context.Context) error

Resolve blocks until the capability is fully resolved or the Context expires.

func (Cluster_AdminMaster) SetFlowLimiter 

func (c Cluster_AdminMaster) SetFlowLimiter(lim fc.FlowLimiter)

Update the flowcontrol.FlowLimiter used to manage flow control for this client. This affects all future calls, but not calls already waiting to send. Passing nil sets the value to flowcontrol.NopLimiter, which is also the default.

func (Cluster_AdminMaster) String 

func (c Cluster_AdminMaster) String() string

String returns a string that identifies this capability for debugging purposes. Its format should not be depended on: in particular, it should not be used to compare clients. Use IsSame to compare clients for equality.

func (Cluster_AdminMaster) WaitStreaming 

func (c Cluster_AdminMaster) WaitStreaming() error

type Cluster_AdminMaster_List 

type Cluster_AdminMaster_List = capnp.CapList[Cluster_AdminMaster]

Cluster_AdminMaster_List is a list of Cluster_AdminMaster.

func NewCluster_AdminMaster_List 

func NewCluster_AdminMaster_List(s *capnp.Segment, sz int32) (Cluster_AdminMaster_List, error)

NewCluster_AdminMaster creates a new list of Cluster_AdminMaster.

type Cluster_AdminMaster_Server 

type Cluster_AdminMaster_Server interface {
	RegisterModelInstanceFactory(context.Context, Cluster_AdminMaster_registerModelInstanceFactory) error

	AvailableModels(context.Context, Cluster_AdminMaster_availableModels) error

	Info(context.Context, common.Identifiable_info) error
}

A Cluster_AdminMaster_Server is a Cluster_AdminMaster with a local implementation.

type Cluster_AdminMaster_availableModels 

type Cluster_AdminMaster_availableModels struct {
	*server.Call
}

Cluster_AdminMaster_availableModels holds the state for a server call to Cluster_AdminMaster.availableModels. See server.Call for documentation.

func (Cluster_AdminMaster_availableModels) AllocResults 

func (c Cluster_AdminMaster_availableModels) AllocResults() (Cluster_AdminMaster_availableModels_Results, error)

AllocResults allocates the results struct.

func (Cluster_AdminMaster_availableModels) Args 

func (c Cluster_AdminMaster_availableModels) Args() Cluster_AdminMaster_availableModels_Params

Args returns the call's arguments.

type Cluster_AdminMaster_availableModels_Params 

type Cluster_AdminMaster_availableModels_Params capnp.Struct

func NewCluster_AdminMaster_availableModels_Params 

func NewCluster_AdminMaster_availableModels_Params(s *capnp.Segment) (Cluster_AdminMaster_availableModels_Params, error)

func NewRootCluster_AdminMaster_availableModels_Params 

func NewRootCluster_AdminMaster_availableModels_Params(s *capnp.Segment) (Cluster_AdminMaster_availableModels_Params, error)

func ReadRootCluster_AdminMaster_availableModels_Params 

func ReadRootCluster_AdminMaster_availableModels_Params(msg *capnp.Message) (Cluster_AdminMaster_availableModels_Params, error)

func (Cluster_AdminMaster_availableModels_Params) DecodeFromPtr 

func (Cluster_AdminMaster_availableModels_Params) DecodeFromPtr(p capnp.Ptr) Cluster_AdminMaster_availableModels_Params

func (Cluster_AdminMaster_availableModels_Params) EncodeAsPtr 

func (s Cluster_AdminMaster_availableModels_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_AdminMaster_availableModels_Params) IsValid 

func (s Cluster_AdminMaster_availableModels_Params) IsValid() bool

func (Cluster_AdminMaster_availableModels_Params) Message 

func (s Cluster_AdminMaster_availableModels_Params) Message() *capnp.Message

func (Cluster_AdminMaster_availableModels_Params) Segment 

func (s Cluster_AdminMaster_availableModels_Params) Segment() *capnp.Segment

func (Cluster_AdminMaster_availableModels_Params) String 

func (s Cluster_AdminMaster_availableModels_Params) String() string

func (Cluster_AdminMaster_availableModels_Params) ToPtr 

func (s Cluster_AdminMaster_availableModels_Params) ToPtr() capnp.Ptr

type Cluster_AdminMaster_availableModels_Params_Future 

type Cluster_AdminMaster_availableModels_Params_Future struct{ *capnp.Future }

Cluster_AdminMaster_availableModels_Params_Future is a wrapper for a Cluster_AdminMaster_availableModels_Params promised by a client call.

func (Cluster_AdminMaster_availableModels_Params_Future) Struct 

func (f Cluster_AdminMaster_availableModels_Params_Future) Struct() (Cluster_AdminMaster_availableModels_Params, error)

type Cluster_AdminMaster_availableModels_Params_List 

type Cluster_AdminMaster_availableModels_Params_List = capnp.StructList[Cluster_AdminMaster_availableModels_Params]

Cluster_AdminMaster_availableModels_Params_List is a list of Cluster_AdminMaster_availableModels_Params.

func NewCluster_AdminMaster_availableModels_Params_List 

func NewCluster_AdminMaster_availableModels_Params_List(s *capnp.Segment, sz int32) (Cluster_AdminMaster_availableModels_Params_List, error)

NewCluster_AdminMaster_availableModels_Params creates a new list of Cluster_AdminMaster_availableModels_Params.

type Cluster_AdminMaster_availableModels_Results 

type Cluster_AdminMaster_availableModels_Results capnp.Struct

func NewCluster_AdminMaster_availableModels_Results 

func NewCluster_AdminMaster_availableModels_Results(s *capnp.Segment) (Cluster_AdminMaster_availableModels_Results, error)

func NewRootCluster_AdminMaster_availableModels_Results 

func NewRootCluster_AdminMaster_availableModels_Results(s *capnp.Segment) (Cluster_AdminMaster_availableModels_Results, error)

func ReadRootCluster_AdminMaster_availableModels_Results 

func ReadRootCluster_AdminMaster_availableModels_Results(msg *capnp.Message) (Cluster_AdminMaster_availableModels_Results, error)

func (Cluster_AdminMaster_availableModels_Results) DecodeFromPtr 

func (Cluster_AdminMaster_availableModels_Results) DecodeFromPtr(p capnp.Ptr) Cluster_AdminMaster_availableModels_Results

func (Cluster_AdminMaster_availableModels_Results) EncodeAsPtr 

func (s Cluster_AdminMaster_availableModels_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_AdminMaster_availableModels_Results) Factories 

func (s Cluster_AdminMaster_availableModels_Results) Factories() (Cluster_ModelInstanceFactory_List, error)

func (Cluster_AdminMaster_availableModels_Results) HasFactories 

func (s Cluster_AdminMaster_availableModels_Results) HasFactories() bool

func (Cluster_AdminMaster_availableModels_Results) IsValid 

func (s Cluster_AdminMaster_availableModels_Results) IsValid() bool

func (Cluster_AdminMaster_availableModels_Results) Message 

func (s Cluster_AdminMaster_availableModels_Results) Message() *capnp.Message

func (Cluster_AdminMaster_availableModels_Results) NewFactories 

func (s Cluster_AdminMaster_availableModels_Results) NewFactories(n int32) (Cluster_ModelInstanceFactory_List, error)

NewFactories sets the factories field to a newly allocated Cluster_ModelInstanceFactory_List, preferring placement in s's segment.

func (Cluster_AdminMaster_availableModels_Results) Segment 

func (s Cluster_AdminMaster_availableModels_Results) Segment() *capnp.Segment

func (Cluster_AdminMaster_availableModels_Results) SetFactories 

func (s Cluster_AdminMaster_availableModels_Results) SetFactories(v Cluster_ModelInstanceFactory_List) error

func (Cluster_AdminMaster_availableModels_Results) String 

func (s Cluster_AdminMaster_availableModels_Results) String() string

func (Cluster_AdminMaster_availableModels_Results) ToPtr 

func (s Cluster_AdminMaster_availableModels_Results) ToPtr() capnp.Ptr

type Cluster_AdminMaster_availableModels_Results_Future 

type Cluster_AdminMaster_availableModels_Results_Future struct{ *capnp.Future }

Cluster_AdminMaster_availableModels_Results_Future is a wrapper for a Cluster_AdminMaster_availableModels_Results promised by a client call.

func (Cluster_AdminMaster_availableModels_Results_Future) Struct 

func (f Cluster_AdminMaster_availableModels_Results_Future) Struct() (Cluster_AdminMaster_availableModels_Results, error)

type Cluster_AdminMaster_availableModels_Results_List 

type Cluster_AdminMaster_availableModels_Results_List = capnp.StructList[Cluster_AdminMaster_availableModels_Results]

Cluster_AdminMaster_availableModels_Results_List is a list of Cluster_AdminMaster_availableModels_Results.

func NewCluster_AdminMaster_availableModels_Results_List 

func NewCluster_AdminMaster_availableModels_Results_List(s *capnp.Segment, sz int32) (Cluster_AdminMaster_availableModels_Results_List, error)

NewCluster_AdminMaster_availableModels_Results creates a new list of Cluster_AdminMaster_availableModels_Results.

type Cluster_AdminMaster_registerModelInstanceFactory 

type Cluster_AdminMaster_registerModelInstanceFactory struct {
	*server.Call
}

Cluster_AdminMaster_registerModelInstanceFactory holds the state for a server call to Cluster_AdminMaster.registerModelInstanceFactory. See server.Call for documentation.

func (Cluster_AdminMaster_registerModelInstanceFactory) AllocResults 

func (c Cluster_AdminMaster_registerModelInstanceFactory) AllocResults() (Cluster_AdminMaster_registerModelInstanceFactory_Results, error)

AllocResults allocates the results struct.

func (Cluster_AdminMaster_registerModelInstanceFactory) Args 

func (c Cluster_AdminMaster_registerModelInstanceFactory) Args() Cluster_AdminMaster_registerModelInstanceFactory_Params

Args returns the call's arguments.

type Cluster_AdminMaster_registerModelInstanceFactory_Params 

type Cluster_AdminMaster_registerModelInstanceFactory_Params capnp.Struct

func NewCluster_AdminMaster_registerModelInstanceFactory_Params 

func NewCluster_AdminMaster_registerModelInstanceFactory_Params(s *capnp.Segment) (Cluster_AdminMaster_registerModelInstanceFactory_Params, error)

func NewRootCluster_AdminMaster_registerModelInstanceFactory_Params 

func NewRootCluster_AdminMaster_registerModelInstanceFactory_Params(s *capnp.Segment) (Cluster_AdminMaster_registerModelInstanceFactory_Params, error)

func ReadRootCluster_AdminMaster_registerModelInstanceFactory_Params 

func ReadRootCluster_AdminMaster_registerModelInstanceFactory_Params(msg *capnp.Message) (Cluster_AdminMaster_registerModelInstanceFactory_Params, error)

func (Cluster_AdminMaster_registerModelInstanceFactory_Params) AFactory 

func (s Cluster_AdminMaster_registerModelInstanceFactory_Params) AFactory() Cluster_ModelInstanceFactory

func (Cluster_AdminMaster_registerModelInstanceFactory_Params) AModelId 

func (s Cluster_AdminMaster_registerModelInstanceFactory_Params) AModelId() (string, error)

func (Cluster_AdminMaster_registerModelInstanceFactory_Params) AModelIdBytes 

func (s Cluster_AdminMaster_registerModelInstanceFactory_Params) AModelIdBytes() ([]byte, error)

func (Cluster_AdminMaster_registerModelInstanceFactory_Params) DecodeFromPtr 

func (Cluster_AdminMaster_registerModelInstanceFactory_Params) DecodeFromPtr(p capnp.Ptr) Cluster_AdminMaster_registerModelInstanceFactory_Params

func (Cluster_AdminMaster_registerModelInstanceFactory_Params) EncodeAsPtr 

func (s Cluster_AdminMaster_registerModelInstanceFactory_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_AdminMaster_registerModelInstanceFactory_Params) HasAFactory 

func (s Cluster_AdminMaster_registerModelInstanceFactory_Params) HasAFactory() bool

func (Cluster_AdminMaster_registerModelInstanceFactory_Params) HasAModelId 

func (s Cluster_AdminMaster_registerModelInstanceFactory_Params) HasAModelId() bool

func (Cluster_AdminMaster_registerModelInstanceFactory_Params) IsValid 

func (s Cluster_AdminMaster_registerModelInstanceFactory_Params) IsValid() bool

func (Cluster_AdminMaster_registerModelInstanceFactory_Params) Message 

func (s Cluster_AdminMaster_registerModelInstanceFactory_Params) Message() *capnp.Message

func (Cluster_AdminMaster_registerModelInstanceFactory_Params) Segment 

func (s Cluster_AdminMaster_registerModelInstanceFactory_Params) Segment() *capnp.Segment

func (Cluster_AdminMaster_registerModelInstanceFactory_Params) SetAFactory 

func (s Cluster_AdminMaster_registerModelInstanceFactory_Params) SetAFactory(v Cluster_ModelInstanceFactory) error

func (Cluster_AdminMaster_registerModelInstanceFactory_Params) SetAModelId 

func (s Cluster_AdminMaster_registerModelInstanceFactory_Params) SetAModelId(v string) error

func (Cluster_AdminMaster_registerModelInstanceFactory_Params) String 

func (s Cluster_AdminMaster_registerModelInstanceFactory_Params) String() string

func (Cluster_AdminMaster_registerModelInstanceFactory_Params) ToPtr 

func (s Cluster_AdminMaster_registerModelInstanceFactory_Params) ToPtr() capnp.Ptr

type Cluster_AdminMaster_registerModelInstanceFactory_Params_Future 

type Cluster_AdminMaster_registerModelInstanceFactory_Params_Future struct{ *capnp.Future }

Cluster_AdminMaster_registerModelInstanceFactory_Params_Future is a wrapper for a Cluster_AdminMaster_registerModelInstanceFactory_Params promised by a client call.

func (Cluster_AdminMaster_registerModelInstanceFactory_Params_Future) AFactory 

func (p Cluster_AdminMaster_registerModelInstanceFactory_Params_Future) AFactory() Cluster_ModelInstanceFactory

func (Cluster_AdminMaster_registerModelInstanceFactory_Params_Future) Struct 

func (f Cluster_AdminMaster_registerModelInstanceFactory_Params_Future) Struct() (Cluster_AdminMaster_registerModelInstanceFactory_Params, error)

type Cluster_AdminMaster_registerModelInstanceFactory_Params_List 

type Cluster_AdminMaster_registerModelInstanceFactory_Params_List = capnp.StructList[Cluster_AdminMaster_registerModelInstanceFactory_Params]

Cluster_AdminMaster_registerModelInstanceFactory_Params_List is a list of Cluster_AdminMaster_registerModelInstanceFactory_Params.

func NewCluster_AdminMaster_registerModelInstanceFactory_Params_List 

func NewCluster_AdminMaster_registerModelInstanceFactory_Params_List(s *capnp.Segment, sz int32) (Cluster_AdminMaster_registerModelInstanceFactory_Params_List, error)

NewCluster_AdminMaster_registerModelInstanceFactory_Params creates a new list of Cluster_AdminMaster_registerModelInstanceFactory_Params.

type Cluster_AdminMaster_registerModelInstanceFactory_Results 

type Cluster_AdminMaster_registerModelInstanceFactory_Results capnp.Struct

func NewCluster_AdminMaster_registerModelInstanceFactory_Results 

func NewCluster_AdminMaster_registerModelInstanceFactory_Results(s *capnp.Segment) (Cluster_AdminMaster_registerModelInstanceFactory_Results, error)

func NewRootCluster_AdminMaster_registerModelInstanceFactory_Results 

func NewRootCluster_AdminMaster_registerModelInstanceFactory_Results(s *capnp.Segment) (Cluster_AdminMaster_registerModelInstanceFactory_Results, error)

func ReadRootCluster_AdminMaster_registerModelInstanceFactory_Results 

func ReadRootCluster_AdminMaster_registerModelInstanceFactory_Results(msg *capnp.Message) (Cluster_AdminMaster_registerModelInstanceFactory_Results, error)

func (Cluster_AdminMaster_registerModelInstanceFactory_Results) DecodeFromPtr 

func (Cluster_AdminMaster_registerModelInstanceFactory_Results) DecodeFromPtr(p capnp.Ptr) Cluster_AdminMaster_registerModelInstanceFactory_Results

func (Cluster_AdminMaster_registerModelInstanceFactory_Results) EncodeAsPtr 

func (s Cluster_AdminMaster_registerModelInstanceFactory_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_AdminMaster_registerModelInstanceFactory_Results) HasUnregister 

func (s Cluster_AdminMaster_registerModelInstanceFactory_Results) HasUnregister() bool

func (Cluster_AdminMaster_registerModelInstanceFactory_Results) IsValid 

func (s Cluster_AdminMaster_registerModelInstanceFactory_Results) IsValid() bool

func (Cluster_AdminMaster_registerModelInstanceFactory_Results) Message 

func (s Cluster_AdminMaster_registerModelInstanceFactory_Results) Message() *capnp.Message

func (Cluster_AdminMaster_registerModelInstanceFactory_Results) Segment 

func (s Cluster_AdminMaster_registerModelInstanceFactory_Results) Segment() *capnp.Segment

func (Cluster_AdminMaster_registerModelInstanceFactory_Results) SetUnregister 

func (s Cluster_AdminMaster_registerModelInstanceFactory_Results) SetUnregister(v Cluster_Unregister) error

func (Cluster_AdminMaster_registerModelInstanceFactory_Results) String 

func (s Cluster_AdminMaster_registerModelInstanceFactory_Results) String() string

func (Cluster_AdminMaster_registerModelInstanceFactory_Results) ToPtr 

func (s Cluster_AdminMaster_registerModelInstanceFactory_Results) ToPtr() capnp.Ptr

func (Cluster_AdminMaster_registerModelInstanceFactory_Results) Unregister 

func (s Cluster_AdminMaster_registerModelInstanceFactory_Results) Unregister() Cluster_Unregister

type Cluster_AdminMaster_registerModelInstanceFactory_Results_Future 

type Cluster_AdminMaster_registerModelInstanceFactory_Results_Future struct{ *capnp.Future }

Cluster_AdminMaster_registerModelInstanceFactory_Results_Future is a wrapper for a Cluster_AdminMaster_registerModelInstanceFactory_Results promised by a client call.

func (Cluster_AdminMaster_registerModelInstanceFactory_Results_Future) Struct 

func (f Cluster_AdminMaster_registerModelInstanceFactory_Results_Future) Struct() (Cluster_AdminMaster_registerModelInstanceFactory_Results, error)

func (Cluster_AdminMaster_registerModelInstanceFactory_Results_Future) Unregister 

func (p Cluster_AdminMaster_registerModelInstanceFactory_Results_Future) Unregister() Cluster_Unregister

type Cluster_AdminMaster_registerModelInstanceFactory_Results_List 

type Cluster_AdminMaster_registerModelInstanceFactory_Results_List = capnp.StructList[Cluster_AdminMaster_registerModelInstanceFactory_Results]

Cluster_AdminMaster_registerModelInstanceFactory_Results_List is a list of Cluster_AdminMaster_registerModelInstanceFactory_Results.

func NewCluster_AdminMaster_registerModelInstanceFactory_Results_List 

func NewCluster_AdminMaster_registerModelInstanceFactory_Results_List(s *capnp.Segment, sz int32) (Cluster_AdminMaster_registerModelInstanceFactory_Results_List, error)

NewCluster_AdminMaster_registerModelInstanceFactory_Results creates a new list of Cluster_AdminMaster_registerModelInstanceFactory_Results.

type Cluster_Future 

type Cluster_Future struct{ *capnp.Future }

Cluster_Future is a wrapper for a Cluster promised by a client call.

func (Cluster_Future) Struct 

func (f Cluster_Future) Struct() (Cluster, error)

type Cluster_List 

type Cluster_List = capnp.StructList[Cluster]

Cluster_List is a list of Cluster.

func NewCluster_List 

func NewCluster_List(s *capnp.Segment, sz int32) (Cluster_List, error)

NewCluster creates a new list of Cluster.

type Cluster_ModelInstanceFactory 

type Cluster_ModelInstanceFactory capnp.Client

func Cluster_ModelInstanceFactory_ServerToClient 

func Cluster_ModelInstanceFactory_ServerToClient(s Cluster_ModelInstanceFactory_Server) Cluster_ModelInstanceFactory

Cluster_ModelInstanceFactory_ServerToClient creates a new Client from an implementation of Cluster_ModelInstanceFactory_Server. The caller is responsible for calling Release on the returned Client.

func (Cluster_ModelInstanceFactory) AddRef 

func (c Cluster_ModelInstanceFactory) AddRef() Cluster_ModelInstanceFactory

AddRef creates a new Client that refers to the same capability as c. If c is nil or has resolved to null, then AddRef returns nil.

func (Cluster_ModelInstanceFactory) DecodeFromPtr 

func (Cluster_ModelInstanceFactory) DecodeFromPtr(p capnp.Ptr) Cluster_ModelInstanceFactory

func (Cluster_ModelInstanceFactory) EncodeAsPtr 

func (c Cluster_ModelInstanceFactory) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_ModelInstanceFactory) GetFlowLimiter 

func (c Cluster_ModelInstanceFactory) GetFlowLimiter() fc.FlowLimiter

Get the current flowcontrol.FlowLimiter used to manage flow control for this client.

func (Cluster_ModelInstanceFactory) Info 

func (c Cluster_ModelInstanceFactory) Info(ctx context.Context, params func(common.Identifiable_info_Params) error) (common.IdInformation_Future, capnp.ReleaseFunc)

func (Cluster_ModelInstanceFactory) IsSame 

func (c Cluster_ModelInstanceFactory) IsSame(other Cluster_ModelInstanceFactory) bool

IsSame reports whether c and other refer to a capability created by the same call to NewClient. This can return false negatives if c or other are not fully resolved: use Resolve if this is an issue. If either c or other are released, then IsSame panics.

func (Cluster_ModelInstanceFactory) IsValid 

func (c Cluster_ModelInstanceFactory) IsValid() bool

IsValid reports whether c is a valid reference to a capability. A reference is invalid if it is nil, has resolved to null, or has been released.

func (Cluster_ModelInstanceFactory) ModelId 

func (c Cluster_ModelInstanceFactory) ModelId(ctx context.Context, params func(Cluster_ModelInstanceFactory_modelId_Params) error) (Cluster_ModelInstanceFactory_modelId_Results_Future, capnp.ReleaseFunc)

func (Cluster_ModelInstanceFactory) NewCloudViaProxy 

func (c Cluster_ModelInstanceFactory) NewCloudViaProxy(ctx context.Context, params func(Cluster_ModelInstanceFactory_newCloudViaProxy_Params) error) (Cluster_ModelInstanceFactory_newCloudViaProxy_Results_Future, capnp.ReleaseFunc)

func (Cluster_ModelInstanceFactory) NewCloudViaZmqPipelineProxies 

func (c Cluster_ModelInstanceFactory) NewCloudViaZmqPipelineProxies(ctx context.Context, params func(Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params) error) (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results_Future, capnp.ReleaseFunc)

func (Cluster_ModelInstanceFactory) NewInstance 

func (c Cluster_ModelInstanceFactory) NewInstance(ctx context.Context, params func(Cluster_ModelInstanceFactory_newInstance_Params) error) (Cluster_ModelInstanceFactory_newInstance_Results_Future, capnp.ReleaseFunc)

func (Cluster_ModelInstanceFactory) NewInstances 

func (c Cluster_ModelInstanceFactory) NewInstances(ctx context.Context, params func(Cluster_ModelInstanceFactory_newInstances_Params) error) (Cluster_ModelInstanceFactory_newInstances_Results_Future, capnp.ReleaseFunc)

func (Cluster_ModelInstanceFactory) RegisterModelInstance 

func (c Cluster_ModelInstanceFactory) RegisterModelInstance(ctx context.Context, params func(Cluster_ModelInstanceFactory_registerModelInstance_Params) error) (Cluster_ModelInstanceFactory_registerModelInstance_Results_Future, capnp.ReleaseFunc)

func (Cluster_ModelInstanceFactory) Release 

func (c Cluster_ModelInstanceFactory) Release()

Release releases a capability reference. If this is the last reference to the capability, then the underlying resources associated with the capability will be released.

Release will panic if c has already been released, but not if c is nil or resolved to null.

func (Cluster_ModelInstanceFactory) Resolve 

func (c Cluster_ModelInstanceFactory) Resolve(ctx context.Context) error

Resolve blocks until the capability is fully resolved or the Context expires.

func (Cluster_ModelInstanceFactory) RestoreSturdyRef 

func (c Cluster_ModelInstanceFactory) RestoreSturdyRef(ctx context.Context, params func(Cluster_ModelInstanceFactory_restoreSturdyRef_Params) error) (Cluster_ModelInstanceFactory_restoreSturdyRef_Results_Future, capnp.ReleaseFunc)

func (Cluster_ModelInstanceFactory) SetFlowLimiter 

func (c Cluster_ModelInstanceFactory) SetFlowLimiter(lim fc.FlowLimiter)

Update the flowcontrol.FlowLimiter used to manage flow control for this client. This affects all future calls, but not calls already waiting to send. Passing nil sets the value to flowcontrol.NopLimiter, which is also the default.

func (Cluster_ModelInstanceFactory) String 

func (c Cluster_ModelInstanceFactory) String() string

String returns a string that identifies this capability for debugging purposes. Its format should not be depended on: in particular, it should not be used to compare clients. Use IsSame to compare clients for equality.

func (Cluster_ModelInstanceFactory) WaitStreaming 

func (c Cluster_ModelInstanceFactory) WaitStreaming() error

type Cluster_ModelInstanceFactory_List 

type Cluster_ModelInstanceFactory_List = capnp.CapList[Cluster_ModelInstanceFactory]

Cluster_ModelInstanceFactory_List is a list of Cluster_ModelInstanceFactory.

func NewCluster_ModelInstanceFactory_List 

func NewCluster_ModelInstanceFactory_List(s *capnp.Segment, sz int32) (Cluster_ModelInstanceFactory_List, error)

NewCluster_ModelInstanceFactory creates a new list of Cluster_ModelInstanceFactory.

type Cluster_ModelInstanceFactory_Server 

type Cluster_ModelInstanceFactory_Server interface {
	NewInstance(context.Context, Cluster_ModelInstanceFactory_newInstance) error

	NewInstances(context.Context, Cluster_ModelInstanceFactory_newInstances) error

	NewCloudViaZmqPipelineProxies(context.Context, Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies) error

	NewCloudViaProxy(context.Context, Cluster_ModelInstanceFactory_newCloudViaProxy) error

	ModelId(context.Context, Cluster_ModelInstanceFactory_modelId) error

	RegisterModelInstance(context.Context, Cluster_ModelInstanceFactory_registerModelInstance) error

	RestoreSturdyRef(context.Context, Cluster_ModelInstanceFactory_restoreSturdyRef) error

	Info(context.Context, common.Identifiable_info) error
}

A Cluster_ModelInstanceFactory_Server is a Cluster_ModelInstanceFactory with a local implementation.

type Cluster_ModelInstanceFactory_modelId 

type Cluster_ModelInstanceFactory_modelId struct {
	*server.Call
}

Cluster_ModelInstanceFactory_modelId holds the state for a server call to Cluster_ModelInstanceFactory.modelId. See server.Call for documentation.

func (Cluster_ModelInstanceFactory_modelId) AllocResults 

func (c Cluster_ModelInstanceFactory_modelId) AllocResults() (Cluster_ModelInstanceFactory_modelId_Results, error)

AllocResults allocates the results struct.

func (Cluster_ModelInstanceFactory_modelId) Args 

func (c Cluster_ModelInstanceFactory_modelId) Args() Cluster_ModelInstanceFactory_modelId_Params

Args returns the call's arguments.

type Cluster_ModelInstanceFactory_modelId_Params 

type Cluster_ModelInstanceFactory_modelId_Params capnp.Struct

func NewCluster_ModelInstanceFactory_modelId_Params 

func NewCluster_ModelInstanceFactory_modelId_Params(s *capnp.Segment) (Cluster_ModelInstanceFactory_modelId_Params, error)

func NewRootCluster_ModelInstanceFactory_modelId_Params 

func NewRootCluster_ModelInstanceFactory_modelId_Params(s *capnp.Segment) (Cluster_ModelInstanceFactory_modelId_Params, error)

func ReadRootCluster_ModelInstanceFactory_modelId_Params 

func ReadRootCluster_ModelInstanceFactory_modelId_Params(msg *capnp.Message) (Cluster_ModelInstanceFactory_modelId_Params, error)

func (Cluster_ModelInstanceFactory_modelId_Params) DecodeFromPtr 

func (Cluster_ModelInstanceFactory_modelId_Params) DecodeFromPtr(p capnp.Ptr) Cluster_ModelInstanceFactory_modelId_Params

func (Cluster_ModelInstanceFactory_modelId_Params) EncodeAsPtr 

func (s Cluster_ModelInstanceFactory_modelId_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_ModelInstanceFactory_modelId_Params) IsValid 

func (s Cluster_ModelInstanceFactory_modelId_Params) IsValid() bool

func (Cluster_ModelInstanceFactory_modelId_Params) Message 

func (s Cluster_ModelInstanceFactory_modelId_Params) Message() *capnp.Message

func (Cluster_ModelInstanceFactory_modelId_Params) Segment 

func (s Cluster_ModelInstanceFactory_modelId_Params) Segment() *capnp.Segment

func (Cluster_ModelInstanceFactory_modelId_Params) String 

func (s Cluster_ModelInstanceFactory_modelId_Params) String() string

func (Cluster_ModelInstanceFactory_modelId_Params) ToPtr 

func (s Cluster_ModelInstanceFactory_modelId_Params) ToPtr() capnp.Ptr

type Cluster_ModelInstanceFactory_modelId_Params_Future 

type Cluster_ModelInstanceFactory_modelId_Params_Future struct{ *capnp.Future }

Cluster_ModelInstanceFactory_modelId_Params_Future is a wrapper for a Cluster_ModelInstanceFactory_modelId_Params promised by a client call.

func (Cluster_ModelInstanceFactory_modelId_Params_Future) Struct 

func (f Cluster_ModelInstanceFactory_modelId_Params_Future) Struct() (Cluster_ModelInstanceFactory_modelId_Params, error)

type Cluster_ModelInstanceFactory_modelId_Params_List 

type Cluster_ModelInstanceFactory_modelId_Params_List = capnp.StructList[Cluster_ModelInstanceFactory_modelId_Params]

Cluster_ModelInstanceFactory_modelId_Params_List is a list of Cluster_ModelInstanceFactory_modelId_Params.

func NewCluster_ModelInstanceFactory_modelId_Params_List 

func NewCluster_ModelInstanceFactory_modelId_Params_List(s *capnp.Segment, sz int32) (Cluster_ModelInstanceFactory_modelId_Params_List, error)

NewCluster_ModelInstanceFactory_modelId_Params creates a new list of Cluster_ModelInstanceFactory_modelId_Params.

type Cluster_ModelInstanceFactory_modelId_Results 

type Cluster_ModelInstanceFactory_modelId_Results capnp.Struct

func NewCluster_ModelInstanceFactory_modelId_Results 

func NewCluster_ModelInstanceFactory_modelId_Results(s *capnp.Segment) (Cluster_ModelInstanceFactory_modelId_Results, error)

func NewRootCluster_ModelInstanceFactory_modelId_Results 

func NewRootCluster_ModelInstanceFactory_modelId_Results(s *capnp.Segment) (Cluster_ModelInstanceFactory_modelId_Results, error)

func ReadRootCluster_ModelInstanceFactory_modelId_Results 

func ReadRootCluster_ModelInstanceFactory_modelId_Results(msg *capnp.Message) (Cluster_ModelInstanceFactory_modelId_Results, error)

func (Cluster_ModelInstanceFactory_modelId_Results) DecodeFromPtr 

func (Cluster_ModelInstanceFactory_modelId_Results) DecodeFromPtr(p capnp.Ptr) Cluster_ModelInstanceFactory_modelId_Results

func (Cluster_ModelInstanceFactory_modelId_Results) EncodeAsPtr 

func (s Cluster_ModelInstanceFactory_modelId_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_ModelInstanceFactory_modelId_Results) HasId 

func (s Cluster_ModelInstanceFactory_modelId_Results) HasId() bool

func (Cluster_ModelInstanceFactory_modelId_Results) Id 

func (s Cluster_ModelInstanceFactory_modelId_Results) Id() (string, error)

func (Cluster_ModelInstanceFactory_modelId_Results) IdBytes 

func (s Cluster_ModelInstanceFactory_modelId_Results) IdBytes() ([]byte, error)

func (Cluster_ModelInstanceFactory_modelId_Results) IsValid 

func (s Cluster_ModelInstanceFactory_modelId_Results) IsValid() bool

func (Cluster_ModelInstanceFactory_modelId_Results) Message 

func (s Cluster_ModelInstanceFactory_modelId_Results) Message() *capnp.Message

func (Cluster_ModelInstanceFactory_modelId_Results) Segment 

func (s Cluster_ModelInstanceFactory_modelId_Results) Segment() *capnp.Segment

func (Cluster_ModelInstanceFactory_modelId_Results) SetId 

func (s Cluster_ModelInstanceFactory_modelId_Results) SetId(v string) error

func (Cluster_ModelInstanceFactory_modelId_Results) String 

func (s Cluster_ModelInstanceFactory_modelId_Results) String() string

func (Cluster_ModelInstanceFactory_modelId_Results) ToPtr 

func (s Cluster_ModelInstanceFactory_modelId_Results) ToPtr() capnp.Ptr

type Cluster_ModelInstanceFactory_modelId_Results_Future 

type Cluster_ModelInstanceFactory_modelId_Results_Future struct{ *capnp.Future }

Cluster_ModelInstanceFactory_modelId_Results_Future is a wrapper for a Cluster_ModelInstanceFactory_modelId_Results promised by a client call.

func (Cluster_ModelInstanceFactory_modelId_Results_Future) Struct 

func (f Cluster_ModelInstanceFactory_modelId_Results_Future) Struct() (Cluster_ModelInstanceFactory_modelId_Results, error)

type Cluster_ModelInstanceFactory_modelId_Results_List 

type Cluster_ModelInstanceFactory_modelId_Results_List = capnp.StructList[Cluster_ModelInstanceFactory_modelId_Results]

Cluster_ModelInstanceFactory_modelId_Results_List is a list of Cluster_ModelInstanceFactory_modelId_Results.

func NewCluster_ModelInstanceFactory_modelId_Results_List 

func NewCluster_ModelInstanceFactory_modelId_Results_List(s *capnp.Segment, sz int32) (Cluster_ModelInstanceFactory_modelId_Results_List, error)

NewCluster_ModelInstanceFactory_modelId_Results creates a new list of Cluster_ModelInstanceFactory_modelId_Results.

type Cluster_ModelInstanceFactory_newCloudViaProxy 

type Cluster_ModelInstanceFactory_newCloudViaProxy struct {
	*server.Call
}

Cluster_ModelInstanceFactory_newCloudViaProxy holds the state for a server call to Cluster_ModelInstanceFactory.newCloudViaProxy. See server.Call for documentation.

func (Cluster_ModelInstanceFactory_newCloudViaProxy) AllocResults 

func (c Cluster_ModelInstanceFactory_newCloudViaProxy) AllocResults() (Cluster_ModelInstanceFactory_newCloudViaProxy_Results, error)

AllocResults allocates the results struct.

func (Cluster_ModelInstanceFactory_newCloudViaProxy) Args 

func (c Cluster_ModelInstanceFactory_newCloudViaProxy) Args() Cluster_ModelInstanceFactory_newCloudViaProxy_Params

Args returns the call's arguments.

type Cluster_ModelInstanceFactory_newCloudViaProxy_Params 

type Cluster_ModelInstanceFactory_newCloudViaProxy_Params capnp.Struct

func NewCluster_ModelInstanceFactory_newCloudViaProxy_Params 

func NewCluster_ModelInstanceFactory_newCloudViaProxy_Params(s *capnp.Segment) (Cluster_ModelInstanceFactory_newCloudViaProxy_Params, error)

func NewRootCluster_ModelInstanceFactory_newCloudViaProxy_Params 

func NewRootCluster_ModelInstanceFactory_newCloudViaProxy_Params(s *capnp.Segment) (Cluster_ModelInstanceFactory_newCloudViaProxy_Params, error)

func ReadRootCluster_ModelInstanceFactory_newCloudViaProxy_Params 

func ReadRootCluster_ModelInstanceFactory_newCloudViaProxy_Params(msg *capnp.Message) (Cluster_ModelInstanceFactory_newCloudViaProxy_Params, error)

func (Cluster_ModelInstanceFactory_newCloudViaProxy_Params) DecodeFromPtr 

func (Cluster_ModelInstanceFactory_newCloudViaProxy_Params) DecodeFromPtr(p capnp.Ptr) Cluster_ModelInstanceFactory_newCloudViaProxy_Params

func (Cluster_ModelInstanceFactory_newCloudViaProxy_Params) EncodeAsPtr 

func (s Cluster_ModelInstanceFactory_newCloudViaProxy_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_ModelInstanceFactory_newCloudViaProxy_Params) IsValid 

func (s Cluster_ModelInstanceFactory_newCloudViaProxy_Params) IsValid() bool

func (Cluster_ModelInstanceFactory_newCloudViaProxy_Params) Message 

func (s Cluster_ModelInstanceFactory_newCloudViaProxy_Params) Message() *capnp.Message

func (Cluster_ModelInstanceFactory_newCloudViaProxy_Params) NumberOfInstances 

func (s Cluster_ModelInstanceFactory_newCloudViaProxy_Params) NumberOfInstances() int16

func (Cluster_ModelInstanceFactory_newCloudViaProxy_Params) Segment 

func (s Cluster_ModelInstanceFactory_newCloudViaProxy_Params) Segment() *capnp.Segment

func (Cluster_ModelInstanceFactory_newCloudViaProxy_Params) SetNumberOfInstances 

func (s Cluster_ModelInstanceFactory_newCloudViaProxy_Params) SetNumberOfInstances(v int16)

func (Cluster_ModelInstanceFactory_newCloudViaProxy_Params) String 

func (s Cluster_ModelInstanceFactory_newCloudViaProxy_Params) String() string

func (Cluster_ModelInstanceFactory_newCloudViaProxy_Params) ToPtr 

func (s Cluster_ModelInstanceFactory_newCloudViaProxy_Params) ToPtr() capnp.Ptr

type Cluster_ModelInstanceFactory_newCloudViaProxy_Params_Future 

type Cluster_ModelInstanceFactory_newCloudViaProxy_Params_Future struct{ *capnp.Future }

Cluster_ModelInstanceFactory_newCloudViaProxy_Params_Future is a wrapper for a Cluster_ModelInstanceFactory_newCloudViaProxy_Params promised by a client call.

func (Cluster_ModelInstanceFactory_newCloudViaProxy_Params_Future) Struct 

func (f Cluster_ModelInstanceFactory_newCloudViaProxy_Params_Future) Struct() (Cluster_ModelInstanceFactory_newCloudViaProxy_Params, error)

type Cluster_ModelInstanceFactory_newCloudViaProxy_Params_List 

type Cluster_ModelInstanceFactory_newCloudViaProxy_Params_List = capnp.StructList[Cluster_ModelInstanceFactory_newCloudViaProxy_Params]

Cluster_ModelInstanceFactory_newCloudViaProxy_Params_List is a list of Cluster_ModelInstanceFactory_newCloudViaProxy_Params.

func NewCluster_ModelInstanceFactory_newCloudViaProxy_Params_List 

func NewCluster_ModelInstanceFactory_newCloudViaProxy_Params_List(s *capnp.Segment, sz int32) (Cluster_ModelInstanceFactory_newCloudViaProxy_Params_List, error)

NewCluster_ModelInstanceFactory_newCloudViaProxy_Params creates a new list of Cluster_ModelInstanceFactory_newCloudViaProxy_Params.

type Cluster_ModelInstanceFactory_newCloudViaProxy_Results 

type Cluster_ModelInstanceFactory_newCloudViaProxy_Results capnp.Struct

func NewCluster_ModelInstanceFactory_newCloudViaProxy_Results 

func NewCluster_ModelInstanceFactory_newCloudViaProxy_Results(s *capnp.Segment) (Cluster_ModelInstanceFactory_newCloudViaProxy_Results, error)

func NewRootCluster_ModelInstanceFactory_newCloudViaProxy_Results 

func NewRootCluster_ModelInstanceFactory_newCloudViaProxy_Results(s *capnp.Segment) (Cluster_ModelInstanceFactory_newCloudViaProxy_Results, error)

func ReadRootCluster_ModelInstanceFactory_newCloudViaProxy_Results 

func ReadRootCluster_ModelInstanceFactory_newCloudViaProxy_Results(msg *capnp.Message) (Cluster_ModelInstanceFactory_newCloudViaProxy_Results, error)

func (Cluster_ModelInstanceFactory_newCloudViaProxy_Results) DecodeFromPtr 

func (Cluster_ModelInstanceFactory_newCloudViaProxy_Results) DecodeFromPtr(p capnp.Ptr) Cluster_ModelInstanceFactory_newCloudViaProxy_Results

func (Cluster_ModelInstanceFactory_newCloudViaProxy_Results) EncodeAsPtr 

func (s Cluster_ModelInstanceFactory_newCloudViaProxy_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_ModelInstanceFactory_newCloudViaProxy_Results) HasProxy 

func (s Cluster_ModelInstanceFactory_newCloudViaProxy_Results) HasProxy() bool

func (Cluster_ModelInstanceFactory_newCloudViaProxy_Results) IsValid 

func (s Cluster_ModelInstanceFactory_newCloudViaProxy_Results) IsValid() bool

func (Cluster_ModelInstanceFactory_newCloudViaProxy_Results) Message 

func (s Cluster_ModelInstanceFactory_newCloudViaProxy_Results) Message() *capnp.Message

func (Cluster_ModelInstanceFactory_newCloudViaProxy_Results) Proxy 

func (s Cluster_ModelInstanceFactory_newCloudViaProxy_Results) Proxy() Cluster_ValueHolder

func (Cluster_ModelInstanceFactory_newCloudViaProxy_Results) Segment 

func (s Cluster_ModelInstanceFactory_newCloudViaProxy_Results) Segment() *capnp.Segment

func (Cluster_ModelInstanceFactory_newCloudViaProxy_Results) SetProxy 

func (s Cluster_ModelInstanceFactory_newCloudViaProxy_Results) SetProxy(v Cluster_ValueHolder) error

func (Cluster_ModelInstanceFactory_newCloudViaProxy_Results) String 

func (s Cluster_ModelInstanceFactory_newCloudViaProxy_Results) String() string

func (Cluster_ModelInstanceFactory_newCloudViaProxy_Results) ToPtr 

func (s Cluster_ModelInstanceFactory_newCloudViaProxy_Results) ToPtr() capnp.Ptr

type Cluster_ModelInstanceFactory_newCloudViaProxy_Results_Future 

type Cluster_ModelInstanceFactory_newCloudViaProxy_Results_Future struct{ *capnp.Future }

Cluster_ModelInstanceFactory_newCloudViaProxy_Results_Future is a wrapper for a Cluster_ModelInstanceFactory_newCloudViaProxy_Results promised by a client call.

func (Cluster_ModelInstanceFactory_newCloudViaProxy_Results_Future) Proxy 

func (p Cluster_ModelInstanceFactory_newCloudViaProxy_Results_Future) Proxy() Cluster_ValueHolder

func (Cluster_ModelInstanceFactory_newCloudViaProxy_Results_Future) Struct 

func (f Cluster_ModelInstanceFactory_newCloudViaProxy_Results_Future) Struct() (Cluster_ModelInstanceFactory_newCloudViaProxy_Results, error)

type Cluster_ModelInstanceFactory_newCloudViaProxy_Results_List 

type Cluster_ModelInstanceFactory_newCloudViaProxy_Results_List = capnp.StructList[Cluster_ModelInstanceFactory_newCloudViaProxy_Results]

Cluster_ModelInstanceFactory_newCloudViaProxy_Results_List is a list of Cluster_ModelInstanceFactory_newCloudViaProxy_Results.

func NewCluster_ModelInstanceFactory_newCloudViaProxy_Results_List 

func NewCluster_ModelInstanceFactory_newCloudViaProxy_Results_List(s *capnp.Segment, sz int32) (Cluster_ModelInstanceFactory_newCloudViaProxy_Results_List, error)

NewCluster_ModelInstanceFactory_newCloudViaProxy_Results creates a new list of Cluster_ModelInstanceFactory_newCloudViaProxy_Results.

type Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies 

type Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies struct {
	*server.Call
}

Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies holds the state for a server call to Cluster_ModelInstanceFactory.newCloudViaZmqPipelineProxies. See server.Call for documentation.

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies) AllocResults 

func (c Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies) AllocResults() (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results, error)

AllocResults allocates the results struct.

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies) Args 

func (c Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies) Args() Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params

Args returns the call's arguments.

type Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params 

type Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params capnp.Struct

func NewCluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params 

func NewCluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params(s *capnp.Segment) (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params, error)

func NewRootCluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params 

func NewRootCluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params(s *capnp.Segment) (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params, error)

func ReadRootCluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params 

func ReadRootCluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params(msg *capnp.Message) (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params, error)

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params) DecodeFromPtr 

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params) DecodeFromPtr(p capnp.Ptr) Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params) EncodeAsPtr 

func (s Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params) IsValid 

func (s Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params) IsValid() bool

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params) Message 

func (s Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params) Message() *capnp.Message

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params) NumberOfInstances 

func (s Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params) NumberOfInstances() int16

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params) Segment 

func (s Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params) Segment() *capnp.Segment

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params) SetNumberOfInstances 

func (s Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params) SetNumberOfInstances(v int16)

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params) String 

func (s Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params) String() string

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params) ToPtr 

func (s Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params) ToPtr() capnp.Ptr

type Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params_Future 

type Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params_Future struct{ *capnp.Future }

Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params_Future is a wrapper for a Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params promised by a client call.

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params_Future) Struct 

func (f Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params_Future) Struct() (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params, error)

type Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params_List 

type Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params_List = capnp.StructList[Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params]

Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params_List is a list of Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params.

func NewCluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params_List 

func NewCluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params_List(s *capnp.Segment, sz int32) (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params_List, error)

NewCluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params creates a new list of Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Params.

type Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results 

type Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results capnp.Struct

func NewCluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results 

func NewCluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results(s *capnp.Segment) (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results, error)

func NewRootCluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results 

func NewRootCluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results(s *capnp.Segment) (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results, error)

func ReadRootCluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results 

func ReadRootCluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results(msg *capnp.Message) (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results, error)

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results) DecodeFromPtr 

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results) DecodeFromPtr(p capnp.Ptr) Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results) EncodeAsPtr 

func (s Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results) HasProxyAddresses 

func (s Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results) HasProxyAddresses() bool

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results) IsValid 

func (s Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results) IsValid() bool

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results) Message 

func (s Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results) Message() *capnp.Message

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results) ProxyAddresses 

func (s Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results) ProxyAddresses() Cluster_ValueHolder

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results) Segment 

func (s Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results) Segment() *capnp.Segment

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results) SetProxyAddresses 

func (s Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results) SetProxyAddresses(v Cluster_ValueHolder) error

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results) String 

func (s Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results) String() string

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results) ToPtr 

func (s Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results) ToPtr() capnp.Ptr

type Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results_Future 

type Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results_Future struct{ *capnp.Future }

Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results_Future is a wrapper for a Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results promised by a client call.

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results_Future) ProxyAddresses 

func (p Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results_Future) ProxyAddresses() Cluster_ValueHolder

func (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results_Future) Struct 

func (f Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results_Future) Struct() (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results, error)

type Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results_List 

type Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results_List = capnp.StructList[Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results]

Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results_List is a list of Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results.

func NewCluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results_List 

func NewCluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results_List(s *capnp.Segment, sz int32) (Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results_List, error)

NewCluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results creates a new list of Cluster_ModelInstanceFactory_newCloudViaZmqPipelineProxies_Results.

type Cluster_ModelInstanceFactory_newInstance 

type Cluster_ModelInstanceFactory_newInstance struct {
	*server.Call
}

Cluster_ModelInstanceFactory_newInstance holds the state for a server call to Cluster_ModelInstanceFactory.newInstance. See server.Call for documentation.

func (Cluster_ModelInstanceFactory_newInstance) AllocResults 

func (c Cluster_ModelInstanceFactory_newInstance) AllocResults() (Cluster_ModelInstanceFactory_newInstance_Results, error)

AllocResults allocates the results struct.

func (Cluster_ModelInstanceFactory_newInstance) Args 

func (c Cluster_ModelInstanceFactory_newInstance) Args() Cluster_ModelInstanceFactory_newInstance_Params

Args returns the call's arguments.

type Cluster_ModelInstanceFactory_newInstance_Params 

type Cluster_ModelInstanceFactory_newInstance_Params capnp.Struct

func NewCluster_ModelInstanceFactory_newInstance_Params 

func NewCluster_ModelInstanceFactory_newInstance_Params(s *capnp.Segment) (Cluster_ModelInstanceFactory_newInstance_Params, error)

func NewRootCluster_ModelInstanceFactory_newInstance_Params 

func NewRootCluster_ModelInstanceFactory_newInstance_Params(s *capnp.Segment) (Cluster_ModelInstanceFactory_newInstance_Params, error)

func ReadRootCluster_ModelInstanceFactory_newInstance_Params 

func ReadRootCluster_ModelInstanceFactory_newInstance_Params(msg *capnp.Message) (Cluster_ModelInstanceFactory_newInstance_Params, error)

func (Cluster_ModelInstanceFactory_newInstance_Params) DecodeFromPtr 

func (Cluster_ModelInstanceFactory_newInstance_Params) DecodeFromPtr(p capnp.Ptr) Cluster_ModelInstanceFactory_newInstance_Params

func (Cluster_ModelInstanceFactory_newInstance_Params) EncodeAsPtr 

func (s Cluster_ModelInstanceFactory_newInstance_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_ModelInstanceFactory_newInstance_Params) IsValid 

func (s Cluster_ModelInstanceFactory_newInstance_Params) IsValid() bool

func (Cluster_ModelInstanceFactory_newInstance_Params) Message 

func (s Cluster_ModelInstanceFactory_newInstance_Params) Message() *capnp.Message

func (Cluster_ModelInstanceFactory_newInstance_Params) Segment 

func (s Cluster_ModelInstanceFactory_newInstance_Params) Segment() *capnp.Segment

func (Cluster_ModelInstanceFactory_newInstance_Params) String 

func (s Cluster_ModelInstanceFactory_newInstance_Params) String() string

func (Cluster_ModelInstanceFactory_newInstance_Params) ToPtr 

func (s Cluster_ModelInstanceFactory_newInstance_Params) ToPtr() capnp.Ptr

type Cluster_ModelInstanceFactory_newInstance_Params_Future 

type Cluster_ModelInstanceFactory_newInstance_Params_Future struct{ *capnp.Future }

Cluster_ModelInstanceFactory_newInstance_Params_Future is a wrapper for a Cluster_ModelInstanceFactory_newInstance_Params promised by a client call.

func (Cluster_ModelInstanceFactory_newInstance_Params_Future) Struct 

func (f Cluster_ModelInstanceFactory_newInstance_Params_Future) Struct() (Cluster_ModelInstanceFactory_newInstance_Params, error)

type Cluster_ModelInstanceFactory_newInstance_Params_List 

type Cluster_ModelInstanceFactory_newInstance_Params_List = capnp.StructList[Cluster_ModelInstanceFactory_newInstance_Params]

Cluster_ModelInstanceFactory_newInstance_Params_List is a list of Cluster_ModelInstanceFactory_newInstance_Params.

func NewCluster_ModelInstanceFactory_newInstance_Params_List 

func NewCluster_ModelInstanceFactory_newInstance_Params_List(s *capnp.Segment, sz int32) (Cluster_ModelInstanceFactory_newInstance_Params_List, error)

NewCluster_ModelInstanceFactory_newInstance_Params creates a new list of Cluster_ModelInstanceFactory_newInstance_Params.

type Cluster_ModelInstanceFactory_newInstance_Results 

type Cluster_ModelInstanceFactory_newInstance_Results capnp.Struct

func NewCluster_ModelInstanceFactory_newInstance_Results 

func NewCluster_ModelInstanceFactory_newInstance_Results(s *capnp.Segment) (Cluster_ModelInstanceFactory_newInstance_Results, error)

func NewRootCluster_ModelInstanceFactory_newInstance_Results 

func NewRootCluster_ModelInstanceFactory_newInstance_Results(s *capnp.Segment) (Cluster_ModelInstanceFactory_newInstance_Results, error)

func ReadRootCluster_ModelInstanceFactory_newInstance_Results 

func ReadRootCluster_ModelInstanceFactory_newInstance_Results(msg *capnp.Message) (Cluster_ModelInstanceFactory_newInstance_Results, error)

func (Cluster_ModelInstanceFactory_newInstance_Results) DecodeFromPtr 

func (Cluster_ModelInstanceFactory_newInstance_Results) DecodeFromPtr(p capnp.Ptr) Cluster_ModelInstanceFactory_newInstance_Results

func (Cluster_ModelInstanceFactory_newInstance_Results) EncodeAsPtr 

func (s Cluster_ModelInstanceFactory_newInstance_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_ModelInstanceFactory_newInstance_Results) HasInstance 

func (s Cluster_ModelInstanceFactory_newInstance_Results) HasInstance() bool

func (Cluster_ModelInstanceFactory_newInstance_Results) Instance 

func (s Cluster_ModelInstanceFactory_newInstance_Results) Instance() Cluster_ValueHolder

func (Cluster_ModelInstanceFactory_newInstance_Results) IsValid 

func (s Cluster_ModelInstanceFactory_newInstance_Results) IsValid() bool

func (Cluster_ModelInstanceFactory_newInstance_Results) Message 

func (s Cluster_ModelInstanceFactory_newInstance_Results) Message() *capnp.Message

func (Cluster_ModelInstanceFactory_newInstance_Results) Segment 

func (s Cluster_ModelInstanceFactory_newInstance_Results) Segment() *capnp.Segment

func (Cluster_ModelInstanceFactory_newInstance_Results) SetInstance 

func (s Cluster_ModelInstanceFactory_newInstance_Results) SetInstance(v Cluster_ValueHolder) error

func (Cluster_ModelInstanceFactory_newInstance_Results) String 

func (s Cluster_ModelInstanceFactory_newInstance_Results) String() string

func (Cluster_ModelInstanceFactory_newInstance_Results) ToPtr 

func (s Cluster_ModelInstanceFactory_newInstance_Results) ToPtr() capnp.Ptr

type Cluster_ModelInstanceFactory_newInstance_Results_Future 

type Cluster_ModelInstanceFactory_newInstance_Results_Future struct{ *capnp.Future }

Cluster_ModelInstanceFactory_newInstance_Results_Future is a wrapper for a Cluster_ModelInstanceFactory_newInstance_Results promised by a client call.

func (Cluster_ModelInstanceFactory_newInstance_Results_Future) Instance 

func (p Cluster_ModelInstanceFactory_newInstance_Results_Future) Instance() Cluster_ValueHolder

func (Cluster_ModelInstanceFactory_newInstance_Results_Future) Struct 

func (f Cluster_ModelInstanceFactory_newInstance_Results_Future) Struct() (Cluster_ModelInstanceFactory_newInstance_Results, error)

type Cluster_ModelInstanceFactory_newInstance_Results_List 

type Cluster_ModelInstanceFactory_newInstance_Results_List = capnp.StructList[Cluster_ModelInstanceFactory_newInstance_Results]

Cluster_ModelInstanceFactory_newInstance_Results_List is a list of Cluster_ModelInstanceFactory_newInstance_Results.

func NewCluster_ModelInstanceFactory_newInstance_Results_List 

func NewCluster_ModelInstanceFactory_newInstance_Results_List(s *capnp.Segment, sz int32) (Cluster_ModelInstanceFactory_newInstance_Results_List, error)

NewCluster_ModelInstanceFactory_newInstance_Results creates a new list of Cluster_ModelInstanceFactory_newInstance_Results.

type Cluster_ModelInstanceFactory_newInstances 

type Cluster_ModelInstanceFactory_newInstances struct {
	*server.Call
}

Cluster_ModelInstanceFactory_newInstances holds the state for a server call to Cluster_ModelInstanceFactory.newInstances. See server.Call for documentation.

func (Cluster_ModelInstanceFactory_newInstances) AllocResults 

func (c Cluster_ModelInstanceFactory_newInstances) AllocResults() (Cluster_ModelInstanceFactory_newInstances_Results, error)

AllocResults allocates the results struct.

func (Cluster_ModelInstanceFactory_newInstances) Args 

func (c Cluster_ModelInstanceFactory_newInstances) Args() Cluster_ModelInstanceFactory_newInstances_Params

Args returns the call's arguments.

type Cluster_ModelInstanceFactory_newInstances_Params 

type Cluster_ModelInstanceFactory_newInstances_Params capnp.Struct

func NewCluster_ModelInstanceFactory_newInstances_Params 

func NewCluster_ModelInstanceFactory_newInstances_Params(s *capnp.Segment) (Cluster_ModelInstanceFactory_newInstances_Params, error)

func NewRootCluster_ModelInstanceFactory_newInstances_Params 

func NewRootCluster_ModelInstanceFactory_newInstances_Params(s *capnp.Segment) (Cluster_ModelInstanceFactory_newInstances_Params, error)

func ReadRootCluster_ModelInstanceFactory_newInstances_Params 

func ReadRootCluster_ModelInstanceFactory_newInstances_Params(msg *capnp.Message) (Cluster_ModelInstanceFactory_newInstances_Params, error)

func (Cluster_ModelInstanceFactory_newInstances_Params) DecodeFromPtr 

func (Cluster_ModelInstanceFactory_newInstances_Params) DecodeFromPtr(p capnp.Ptr) Cluster_ModelInstanceFactory_newInstances_Params

func (Cluster_ModelInstanceFactory_newInstances_Params) EncodeAsPtr 

func (s Cluster_ModelInstanceFactory_newInstances_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_ModelInstanceFactory_newInstances_Params) IsValid 

func (s Cluster_ModelInstanceFactory_newInstances_Params) IsValid() bool

func (Cluster_ModelInstanceFactory_newInstances_Params) Message 

func (s Cluster_ModelInstanceFactory_newInstances_Params) Message() *capnp.Message

func (Cluster_ModelInstanceFactory_newInstances_Params) NumberOfInstances 

func (s Cluster_ModelInstanceFactory_newInstances_Params) NumberOfInstances() int16

func (Cluster_ModelInstanceFactory_newInstances_Params) Segment 

func (s Cluster_ModelInstanceFactory_newInstances_Params) Segment() *capnp.Segment

func (Cluster_ModelInstanceFactory_newInstances_Params) SetNumberOfInstances 

func (s Cluster_ModelInstanceFactory_newInstances_Params) SetNumberOfInstances(v int16)

func (Cluster_ModelInstanceFactory_newInstances_Params) String 

func (s Cluster_ModelInstanceFactory_newInstances_Params) String() string

func (Cluster_ModelInstanceFactory_newInstances_Params) ToPtr 

func (s Cluster_ModelInstanceFactory_newInstances_Params) ToPtr() capnp.Ptr

type Cluster_ModelInstanceFactory_newInstances_Params_Future 

type Cluster_ModelInstanceFactory_newInstances_Params_Future struct{ *capnp.Future }

Cluster_ModelInstanceFactory_newInstances_Params_Future is a wrapper for a Cluster_ModelInstanceFactory_newInstances_Params promised by a client call.

func (Cluster_ModelInstanceFactory_newInstances_Params_Future) Struct 

func (f Cluster_ModelInstanceFactory_newInstances_Params_Future) Struct() (Cluster_ModelInstanceFactory_newInstances_Params, error)

type Cluster_ModelInstanceFactory_newInstances_Params_List 

type Cluster_ModelInstanceFactory_newInstances_Params_List = capnp.StructList[Cluster_ModelInstanceFactory_newInstances_Params]

Cluster_ModelInstanceFactory_newInstances_Params_List is a list of Cluster_ModelInstanceFactory_newInstances_Params.

func NewCluster_ModelInstanceFactory_newInstances_Params_List 

func NewCluster_ModelInstanceFactory_newInstances_Params_List(s *capnp.Segment, sz int32) (Cluster_ModelInstanceFactory_newInstances_Params_List, error)

NewCluster_ModelInstanceFactory_newInstances_Params creates a new list of Cluster_ModelInstanceFactory_newInstances_Params.

type Cluster_ModelInstanceFactory_newInstances_Results 

type Cluster_ModelInstanceFactory_newInstances_Results capnp.Struct

func NewCluster_ModelInstanceFactory_newInstances_Results 

func NewCluster_ModelInstanceFactory_newInstances_Results(s *capnp.Segment) (Cluster_ModelInstanceFactory_newInstances_Results, error)

func NewRootCluster_ModelInstanceFactory_newInstances_Results 

func NewRootCluster_ModelInstanceFactory_newInstances_Results(s *capnp.Segment) (Cluster_ModelInstanceFactory_newInstances_Results, error)

func ReadRootCluster_ModelInstanceFactory_newInstances_Results 

func ReadRootCluster_ModelInstanceFactory_newInstances_Results(msg *capnp.Message) (Cluster_ModelInstanceFactory_newInstances_Results, error)

func (Cluster_ModelInstanceFactory_newInstances_Results) DecodeFromPtr 

func (Cluster_ModelInstanceFactory_newInstances_Results) DecodeFromPtr(p capnp.Ptr) Cluster_ModelInstanceFactory_newInstances_Results

func (Cluster_ModelInstanceFactory_newInstances_Results) EncodeAsPtr 

func (s Cluster_ModelInstanceFactory_newInstances_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_ModelInstanceFactory_newInstances_Results) HasInstances 

func (s Cluster_ModelInstanceFactory_newInstances_Results) HasInstances() bool

func (Cluster_ModelInstanceFactory_newInstances_Results) Instances 

func (s Cluster_ModelInstanceFactory_newInstances_Results) Instances() Cluster_ValueHolder

func (Cluster_ModelInstanceFactory_newInstances_Results) IsValid 

func (s Cluster_ModelInstanceFactory_newInstances_Results) IsValid() bool

func (Cluster_ModelInstanceFactory_newInstances_Results) Message 

func (s Cluster_ModelInstanceFactory_newInstances_Results) Message() *capnp.Message

func (Cluster_ModelInstanceFactory_newInstances_Results) Segment 

func (s Cluster_ModelInstanceFactory_newInstances_Results) Segment() *capnp.Segment

func (Cluster_ModelInstanceFactory_newInstances_Results) SetInstances 

func (s Cluster_ModelInstanceFactory_newInstances_Results) SetInstances(v Cluster_ValueHolder) error

func (Cluster_ModelInstanceFactory_newInstances_Results) String 

func (s Cluster_ModelInstanceFactory_newInstances_Results) String() string

func (Cluster_ModelInstanceFactory_newInstances_Results) ToPtr 

func (s Cluster_ModelInstanceFactory_newInstances_Results) ToPtr() capnp.Ptr

type Cluster_ModelInstanceFactory_newInstances_Results_Future 

type Cluster_ModelInstanceFactory_newInstances_Results_Future struct{ *capnp.Future }

Cluster_ModelInstanceFactory_newInstances_Results_Future is a wrapper for a Cluster_ModelInstanceFactory_newInstances_Results promised by a client call.

func (Cluster_ModelInstanceFactory_newInstances_Results_Future) Instances 

func (p Cluster_ModelInstanceFactory_newInstances_Results_Future) Instances() Cluster_ValueHolder

func (Cluster_ModelInstanceFactory_newInstances_Results_Future) Struct 

func (f Cluster_ModelInstanceFactory_newInstances_Results_Future) Struct() (Cluster_ModelInstanceFactory_newInstances_Results, error)

type Cluster_ModelInstanceFactory_newInstances_Results_List 

type Cluster_ModelInstanceFactory_newInstances_Results_List = capnp.StructList[Cluster_ModelInstanceFactory_newInstances_Results]

Cluster_ModelInstanceFactory_newInstances_Results_List is a list of Cluster_ModelInstanceFactory_newInstances_Results.

func NewCluster_ModelInstanceFactory_newInstances_Results_List 

func NewCluster_ModelInstanceFactory_newInstances_Results_List(s *capnp.Segment, sz int32) (Cluster_ModelInstanceFactory_newInstances_Results_List, error)

NewCluster_ModelInstanceFactory_newInstances_Results creates a new list of Cluster_ModelInstanceFactory_newInstances_Results.

type Cluster_ModelInstanceFactory_registerModelInstance 

type Cluster_ModelInstanceFactory_registerModelInstance struct {
	*server.Call
}

Cluster_ModelInstanceFactory_registerModelInstance holds the state for a server call to Cluster_ModelInstanceFactory.registerModelInstance. See server.Call for documentation.

func (Cluster_ModelInstanceFactory_registerModelInstance) AllocResults 

func (c Cluster_ModelInstanceFactory_registerModelInstance) AllocResults() (Cluster_ModelInstanceFactory_registerModelInstance_Results, error)

AllocResults allocates the results struct.

func (Cluster_ModelInstanceFactory_registerModelInstance) Args 

func (c Cluster_ModelInstanceFactory_registerModelInstance) Args() Cluster_ModelInstanceFactory_registerModelInstance_Params

Args returns the call's arguments.

type Cluster_ModelInstanceFactory_registerModelInstance_Params 

type Cluster_ModelInstanceFactory_registerModelInstance_Params capnp.Struct

func NewCluster_ModelInstanceFactory_registerModelInstance_Params 

func NewCluster_ModelInstanceFactory_registerModelInstance_Params(s *capnp.Segment) (Cluster_ModelInstanceFactory_registerModelInstance_Params, error)

func NewRootCluster_ModelInstanceFactory_registerModelInstance_Params 

func NewRootCluster_ModelInstanceFactory_registerModelInstance_Params(s *capnp.Segment) (Cluster_ModelInstanceFactory_registerModelInstance_Params, error)

func ReadRootCluster_ModelInstanceFactory_registerModelInstance_Params 

func ReadRootCluster_ModelInstanceFactory_registerModelInstance_Params(msg *capnp.Message) (Cluster_ModelInstanceFactory_registerModelInstance_Params, error)

func (Cluster_ModelInstanceFactory_registerModelInstance_Params) DecodeFromPtr 

func (Cluster_ModelInstanceFactory_registerModelInstance_Params) DecodeFromPtr(p capnp.Ptr) Cluster_ModelInstanceFactory_registerModelInstance_Params

func (Cluster_ModelInstanceFactory_registerModelInstance_Params) EncodeAsPtr 

func (s Cluster_ModelInstanceFactory_registerModelInstance_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_ModelInstanceFactory_registerModelInstance_Params) HasInstance 

func (s Cluster_ModelInstanceFactory_registerModelInstance_Params) HasInstance() bool

func (Cluster_ModelInstanceFactory_registerModelInstance_Params) HasRegistrationToken 

func (s Cluster_ModelInstanceFactory_registerModelInstance_Params) HasRegistrationToken() bool

func (Cluster_ModelInstanceFactory_registerModelInstance_Params) Instance 

func (s Cluster_ModelInstanceFactory_registerModelInstance_Params) Instance() capnp.Client

func (Cluster_ModelInstanceFactory_registerModelInstance_Params) IsValid 

func (s Cluster_ModelInstanceFactory_registerModelInstance_Params) IsValid() bool

func (Cluster_ModelInstanceFactory_registerModelInstance_Params) Message 

func (s Cluster_ModelInstanceFactory_registerModelInstance_Params) Message() *capnp.Message

func (Cluster_ModelInstanceFactory_registerModelInstance_Params) RegistrationToken 

func (s Cluster_ModelInstanceFactory_registerModelInstance_Params) RegistrationToken() (string, error)

func (Cluster_ModelInstanceFactory_registerModelInstance_Params) RegistrationTokenBytes 

func (s Cluster_ModelInstanceFactory_registerModelInstance_Params) RegistrationTokenBytes() ([]byte, error)

func (Cluster_ModelInstanceFactory_registerModelInstance_Params) Segment 

func (s Cluster_ModelInstanceFactory_registerModelInstance_Params) Segment() *capnp.Segment

func (Cluster_ModelInstanceFactory_registerModelInstance_Params) SetInstance 

func (s Cluster_ModelInstanceFactory_registerModelInstance_Params) SetInstance(c capnp.Client) error

func (Cluster_ModelInstanceFactory_registerModelInstance_Params) SetRegistrationToken 

func (s Cluster_ModelInstanceFactory_registerModelInstance_Params) SetRegistrationToken(v string) error

func (Cluster_ModelInstanceFactory_registerModelInstance_Params) String 

func (s Cluster_ModelInstanceFactory_registerModelInstance_Params) String() string

func (Cluster_ModelInstanceFactory_registerModelInstance_Params) ToPtr 

func (s Cluster_ModelInstanceFactory_registerModelInstance_Params) ToPtr() capnp.Ptr

type Cluster_ModelInstanceFactory_registerModelInstance_Params_Future 

type Cluster_ModelInstanceFactory_registerModelInstance_Params_Future struct{ *capnp.Future }

Cluster_ModelInstanceFactory_registerModelInstance_Params_Future is a wrapper for a Cluster_ModelInstanceFactory_registerModelInstance_Params promised by a client call.

func (Cluster_ModelInstanceFactory_registerModelInstance_Params_Future) Instance 

func (p Cluster_ModelInstanceFactory_registerModelInstance_Params_Future) Instance() capnp.Client

func (Cluster_ModelInstanceFactory_registerModelInstance_Params_Future) Struct 

func (f Cluster_ModelInstanceFactory_registerModelInstance_Params_Future) Struct() (Cluster_ModelInstanceFactory_registerModelInstance_Params, error)

type Cluster_ModelInstanceFactory_registerModelInstance_Params_List 

type Cluster_ModelInstanceFactory_registerModelInstance_Params_List = capnp.StructList[Cluster_ModelInstanceFactory_registerModelInstance_Params]

Cluster_ModelInstanceFactory_registerModelInstance_Params_List is a list of Cluster_ModelInstanceFactory_registerModelInstance_Params.

func NewCluster_ModelInstanceFactory_registerModelInstance_Params_List 

func NewCluster_ModelInstanceFactory_registerModelInstance_Params_List(s *capnp.Segment, sz int32) (Cluster_ModelInstanceFactory_registerModelInstance_Params_List, error)

NewCluster_ModelInstanceFactory_registerModelInstance_Params creates a new list of Cluster_ModelInstanceFactory_registerModelInstance_Params.

type Cluster_ModelInstanceFactory_registerModelInstance_Results 

type Cluster_ModelInstanceFactory_registerModelInstance_Results capnp.Struct

func NewCluster_ModelInstanceFactory_registerModelInstance_Results 

func NewCluster_ModelInstanceFactory_registerModelInstance_Results(s *capnp.Segment) (Cluster_ModelInstanceFactory_registerModelInstance_Results, error)

func NewRootCluster_ModelInstanceFactory_registerModelInstance_Results 

func NewRootCluster_ModelInstanceFactory_registerModelInstance_Results(s *capnp.Segment) (Cluster_ModelInstanceFactory_registerModelInstance_Results, error)

func ReadRootCluster_ModelInstanceFactory_registerModelInstance_Results 

func ReadRootCluster_ModelInstanceFactory_registerModelInstance_Results(msg *capnp.Message) (Cluster_ModelInstanceFactory_registerModelInstance_Results, error)

func (Cluster_ModelInstanceFactory_registerModelInstance_Results) DecodeFromPtr 

func (Cluster_ModelInstanceFactory_registerModelInstance_Results) DecodeFromPtr(p capnp.Ptr) Cluster_ModelInstanceFactory_registerModelInstance_Results

func (Cluster_ModelInstanceFactory_registerModelInstance_Results) EncodeAsPtr 

func (s Cluster_ModelInstanceFactory_registerModelInstance_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_ModelInstanceFactory_registerModelInstance_Results) HasUnregister 

func (s Cluster_ModelInstanceFactory_registerModelInstance_Results) HasUnregister() bool

func (Cluster_ModelInstanceFactory_registerModelInstance_Results) IsValid 

func (s Cluster_ModelInstanceFactory_registerModelInstance_Results) IsValid() bool

func (Cluster_ModelInstanceFactory_registerModelInstance_Results) Message 

func (s Cluster_ModelInstanceFactory_registerModelInstance_Results) Message() *capnp.Message

func (Cluster_ModelInstanceFactory_registerModelInstance_Results) Segment 

func (s Cluster_ModelInstanceFactory_registerModelInstance_Results) Segment() *capnp.Segment

func (Cluster_ModelInstanceFactory_registerModelInstance_Results) SetUnregister 

func (s Cluster_ModelInstanceFactory_registerModelInstance_Results) SetUnregister(v Cluster_Unregister) error

func (Cluster_ModelInstanceFactory_registerModelInstance_Results) String 

func (s Cluster_ModelInstanceFactory_registerModelInstance_Results) String() string

func (Cluster_ModelInstanceFactory_registerModelInstance_Results) ToPtr 

func (s Cluster_ModelInstanceFactory_registerModelInstance_Results) ToPtr() capnp.Ptr

func (Cluster_ModelInstanceFactory_registerModelInstance_Results) Unregister 

func (s Cluster_ModelInstanceFactory_registerModelInstance_Results) Unregister() Cluster_Unregister

type Cluster_ModelInstanceFactory_registerModelInstance_Results_Future 

type Cluster_ModelInstanceFactory_registerModelInstance_Results_Future struct{ *capnp.Future }

Cluster_ModelInstanceFactory_registerModelInstance_Results_Future is a wrapper for a Cluster_ModelInstanceFactory_registerModelInstance_Results promised by a client call.

func (Cluster_ModelInstanceFactory_registerModelInstance_Results_Future) Struct 

func (f Cluster_ModelInstanceFactory_registerModelInstance_Results_Future) Struct() (Cluster_ModelInstanceFactory_registerModelInstance_Results, error)

func (Cluster_ModelInstanceFactory_registerModelInstance_Results_Future) Unregister 

func (p Cluster_ModelInstanceFactory_registerModelInstance_Results_Future) Unregister() Cluster_Unregister

type Cluster_ModelInstanceFactory_registerModelInstance_Results_List 

type Cluster_ModelInstanceFactory_registerModelInstance_Results_List = capnp.StructList[Cluster_ModelInstanceFactory_registerModelInstance_Results]

Cluster_ModelInstanceFactory_registerModelInstance_Results_List is a list of Cluster_ModelInstanceFactory_registerModelInstance_Results.

func NewCluster_ModelInstanceFactory_registerModelInstance_Results_List 

func NewCluster_ModelInstanceFactory_registerModelInstance_Results_List(s *capnp.Segment, sz int32) (Cluster_ModelInstanceFactory_registerModelInstance_Results_List, error)

NewCluster_ModelInstanceFactory_registerModelInstance_Results creates a new list of Cluster_ModelInstanceFactory_registerModelInstance_Results.

type Cluster_ModelInstanceFactory_restoreSturdyRef 

type Cluster_ModelInstanceFactory_restoreSturdyRef struct {
	*server.Call
}

Cluster_ModelInstanceFactory_restoreSturdyRef holds the state for a server call to Cluster_ModelInstanceFactory.restoreSturdyRef. See server.Call for documentation.

func (Cluster_ModelInstanceFactory_restoreSturdyRef) AllocResults 

func (c Cluster_ModelInstanceFactory_restoreSturdyRef) AllocResults() (Cluster_ModelInstanceFactory_restoreSturdyRef_Results, error)

AllocResults allocates the results struct.

func (Cluster_ModelInstanceFactory_restoreSturdyRef) Args 

func (c Cluster_ModelInstanceFactory_restoreSturdyRef) Args() Cluster_ModelInstanceFactory_restoreSturdyRef_Params

Args returns the call's arguments.

type Cluster_ModelInstanceFactory_restoreSturdyRef_Params 

type Cluster_ModelInstanceFactory_restoreSturdyRef_Params capnp.Struct

func NewCluster_ModelInstanceFactory_restoreSturdyRef_Params 

func NewCluster_ModelInstanceFactory_restoreSturdyRef_Params(s *capnp.Segment) (Cluster_ModelInstanceFactory_restoreSturdyRef_Params, error)

func NewRootCluster_ModelInstanceFactory_restoreSturdyRef_Params 

func NewRootCluster_ModelInstanceFactory_restoreSturdyRef_Params(s *capnp.Segment) (Cluster_ModelInstanceFactory_restoreSturdyRef_Params, error)

func ReadRootCluster_ModelInstanceFactory_restoreSturdyRef_Params 

func ReadRootCluster_ModelInstanceFactory_restoreSturdyRef_Params(msg *capnp.Message) (Cluster_ModelInstanceFactory_restoreSturdyRef_Params, error)

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Params) DecodeFromPtr 

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Params) DecodeFromPtr(p capnp.Ptr) Cluster_ModelInstanceFactory_restoreSturdyRef_Params

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Params) EncodeAsPtr 

func (s Cluster_ModelInstanceFactory_restoreSturdyRef_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Params) HasSturdyRef 

func (s Cluster_ModelInstanceFactory_restoreSturdyRef_Params) HasSturdyRef() bool

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Params) IsValid 

func (s Cluster_ModelInstanceFactory_restoreSturdyRef_Params) IsValid() bool

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Params) Message 

func (s Cluster_ModelInstanceFactory_restoreSturdyRef_Params) Message() *capnp.Message

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Params) Segment 

func (s Cluster_ModelInstanceFactory_restoreSturdyRef_Params) Segment() *capnp.Segment

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Params) SetSturdyRef 

func (s Cluster_ModelInstanceFactory_restoreSturdyRef_Params) SetSturdyRef(v string) error

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Params) String 

func (s Cluster_ModelInstanceFactory_restoreSturdyRef_Params) String() string

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Params) SturdyRef 

func (s Cluster_ModelInstanceFactory_restoreSturdyRef_Params) SturdyRef() (string, error)

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Params) SturdyRefBytes 

func (s Cluster_ModelInstanceFactory_restoreSturdyRef_Params) SturdyRefBytes() ([]byte, error)

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Params) ToPtr 

func (s Cluster_ModelInstanceFactory_restoreSturdyRef_Params) ToPtr() capnp.Ptr

type Cluster_ModelInstanceFactory_restoreSturdyRef_Params_Future 

type Cluster_ModelInstanceFactory_restoreSturdyRef_Params_Future struct{ *capnp.Future }

Cluster_ModelInstanceFactory_restoreSturdyRef_Params_Future is a wrapper for a Cluster_ModelInstanceFactory_restoreSturdyRef_Params promised by a client call.

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Params_Future) Struct 

func (f Cluster_ModelInstanceFactory_restoreSturdyRef_Params_Future) Struct() (Cluster_ModelInstanceFactory_restoreSturdyRef_Params, error)

type Cluster_ModelInstanceFactory_restoreSturdyRef_Params_List 

type Cluster_ModelInstanceFactory_restoreSturdyRef_Params_List = capnp.StructList[Cluster_ModelInstanceFactory_restoreSturdyRef_Params]

Cluster_ModelInstanceFactory_restoreSturdyRef_Params_List is a list of Cluster_ModelInstanceFactory_restoreSturdyRef_Params.

func NewCluster_ModelInstanceFactory_restoreSturdyRef_Params_List 

func NewCluster_ModelInstanceFactory_restoreSturdyRef_Params_List(s *capnp.Segment, sz int32) (Cluster_ModelInstanceFactory_restoreSturdyRef_Params_List, error)

NewCluster_ModelInstanceFactory_restoreSturdyRef_Params creates a new list of Cluster_ModelInstanceFactory_restoreSturdyRef_Params.

type Cluster_ModelInstanceFactory_restoreSturdyRef_Results 

type Cluster_ModelInstanceFactory_restoreSturdyRef_Results capnp.Struct

func NewCluster_ModelInstanceFactory_restoreSturdyRef_Results 

func NewCluster_ModelInstanceFactory_restoreSturdyRef_Results(s *capnp.Segment) (Cluster_ModelInstanceFactory_restoreSturdyRef_Results, error)

func NewRootCluster_ModelInstanceFactory_restoreSturdyRef_Results 

func NewRootCluster_ModelInstanceFactory_restoreSturdyRef_Results(s *capnp.Segment) (Cluster_ModelInstanceFactory_restoreSturdyRef_Results, error)

func ReadRootCluster_ModelInstanceFactory_restoreSturdyRef_Results 

func ReadRootCluster_ModelInstanceFactory_restoreSturdyRef_Results(msg *capnp.Message) (Cluster_ModelInstanceFactory_restoreSturdyRef_Results, error)

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Results) Cap 

func (s Cluster_ModelInstanceFactory_restoreSturdyRef_Results) Cap() Cluster_ValueHolder

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Results) DecodeFromPtr 

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Results) DecodeFromPtr(p capnp.Ptr) Cluster_ModelInstanceFactory_restoreSturdyRef_Results

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Results) EncodeAsPtr 

func (s Cluster_ModelInstanceFactory_restoreSturdyRef_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Results) HasCap 

func (s Cluster_ModelInstanceFactory_restoreSturdyRef_Results) HasCap() bool

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Results) IsValid 

func (s Cluster_ModelInstanceFactory_restoreSturdyRef_Results) IsValid() bool

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Results) Message 

func (s Cluster_ModelInstanceFactory_restoreSturdyRef_Results) Message() *capnp.Message

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Results) Segment 

func (s Cluster_ModelInstanceFactory_restoreSturdyRef_Results) Segment() *capnp.Segment

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Results) SetCap 

func (s Cluster_ModelInstanceFactory_restoreSturdyRef_Results) SetCap(v Cluster_ValueHolder) error

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Results) String 

func (s Cluster_ModelInstanceFactory_restoreSturdyRef_Results) String() string

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Results) ToPtr 

func (s Cluster_ModelInstanceFactory_restoreSturdyRef_Results) ToPtr() capnp.Ptr

type Cluster_ModelInstanceFactory_restoreSturdyRef_Results_Future 

type Cluster_ModelInstanceFactory_restoreSturdyRef_Results_Future struct{ *capnp.Future }

Cluster_ModelInstanceFactory_restoreSturdyRef_Results_Future is a wrapper for a Cluster_ModelInstanceFactory_restoreSturdyRef_Results promised by a client call.

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Results_Future) Cap 

func (p Cluster_ModelInstanceFactory_restoreSturdyRef_Results_Future) Cap() Cluster_ValueHolder

func (Cluster_ModelInstanceFactory_restoreSturdyRef_Results_Future) Struct 

func (f Cluster_ModelInstanceFactory_restoreSturdyRef_Results_Future) Struct() (Cluster_ModelInstanceFactory_restoreSturdyRef_Results, error)

type Cluster_ModelInstanceFactory_restoreSturdyRef_Results_List 

type Cluster_ModelInstanceFactory_restoreSturdyRef_Results_List = capnp.StructList[Cluster_ModelInstanceFactory_restoreSturdyRef_Results]

Cluster_ModelInstanceFactory_restoreSturdyRef_Results_List is a list of Cluster_ModelInstanceFactory_restoreSturdyRef_Results.

func NewCluster_ModelInstanceFactory_restoreSturdyRef_Results_List 

func NewCluster_ModelInstanceFactory_restoreSturdyRef_Results_List(s *capnp.Segment, sz int32) (Cluster_ModelInstanceFactory_restoreSturdyRef_Results_List, error)

NewCluster_ModelInstanceFactory_restoreSturdyRef_Results creates a new list of Cluster_ModelInstanceFactory_restoreSturdyRef_Results.

type Cluster_Runtime 

type Cluster_Runtime capnp.Client

func Cluster_Runtime_ServerToClient 

func Cluster_Runtime_ServerToClient(s Cluster_Runtime_Server) Cluster_Runtime

Cluster_Runtime_ServerToClient creates a new Client from an implementation of Cluster_Runtime_Server. The caller is responsible for calling Release on the returned Client.

func (Cluster_Runtime) AddRef 

func (c Cluster_Runtime) AddRef() Cluster_Runtime

AddRef creates a new Client that refers to the same capability as c. If c is nil or has resolved to null, then AddRef returns nil.

func (Cluster_Runtime) AvailableModels 

func (c Cluster_Runtime) AvailableModels(ctx context.Context, params func(Cluster_Runtime_availableModels_Params) error) (Cluster_Runtime_availableModels_Results_Future, capnp.ReleaseFunc)

func (Cluster_Runtime) DecodeFromPtr 

func (Cluster_Runtime) DecodeFromPtr(p capnp.Ptr) Cluster_Runtime

func (Cluster_Runtime) EncodeAsPtr 

func (c Cluster_Runtime) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_Runtime) FreeNumberOfCores 

func (c Cluster_Runtime) FreeNumberOfCores(ctx context.Context, params func(Cluster_Runtime_freeNumberOfCores_Params) error) (Cluster_Runtime_freeNumberOfCores_Results_Future, capnp.ReleaseFunc)

func (Cluster_Runtime) GetFlowLimiter 

func (c Cluster_Runtime) GetFlowLimiter() fc.FlowLimiter

Get the current flowcontrol.FlowLimiter used to manage flow control for this client.

func (Cluster_Runtime) Info 

func (c Cluster_Runtime) Info(ctx context.Context, params func(common.Identifiable_info_Params) error) (common.IdInformation_Future, capnp.ReleaseFunc)

func (Cluster_Runtime) IsSame 

func (c Cluster_Runtime) IsSame(other Cluster_Runtime) bool

IsSame reports whether c and other refer to a capability created by the same call to NewClient. This can return false negatives if c or other are not fully resolved: use Resolve if this is an issue. If either c or other are released, then IsSame panics.

func (Cluster_Runtime) IsValid 

func (c Cluster_Runtime) IsValid() bool

IsValid reports whether c is a valid reference to a capability. A reference is invalid if it is nil, has resolved to null, or has been released.

func (Cluster_Runtime) NumberOfCores 

func (c Cluster_Runtime) NumberOfCores(ctx context.Context, params func(Cluster_Runtime_numberOfCores_Params) error) (Cluster_Runtime_numberOfCores_Results_Future, capnp.ReleaseFunc)

func (Cluster_Runtime) RegisterModelInstanceFactory 

func (c Cluster_Runtime) RegisterModelInstanceFactory(ctx context.Context, params func(Cluster_Runtime_registerModelInstanceFactory_Params) error) (Cluster_Runtime_registerModelInstanceFactory_Results_Future, capnp.ReleaseFunc)

func (Cluster_Runtime) Release 

func (c Cluster_Runtime) Release()

Release releases a capability reference. If this is the last reference to the capability, then the underlying resources associated with the capability will be released.

Release will panic if c has already been released, but not if c is nil or resolved to null.

func (Cluster_Runtime) ReserveNumberOfCores 

func (c Cluster_Runtime) ReserveNumberOfCores(ctx context.Context, params func(Cluster_Runtime_reserveNumberOfCores_Params) error) (Cluster_Runtime_reserveNumberOfCores_Results_Future, capnp.ReleaseFunc)

func (Cluster_Runtime) Resolve 

func (c Cluster_Runtime) Resolve(ctx context.Context) error

Resolve blocks until the capability is fully resolved or the Context expires.

func (Cluster_Runtime) SetFlowLimiter 

func (c Cluster_Runtime) SetFlowLimiter(lim fc.FlowLimiter)

Update the flowcontrol.FlowLimiter used to manage flow control for this client. This affects all future calls, but not calls already waiting to send. Passing nil sets the value to flowcontrol.NopLimiter, which is also the default.

func (Cluster_Runtime) String 

func (c Cluster_Runtime) String() string

String returns a string that identifies this capability for debugging purposes. Its format should not be depended on: in particular, it should not be used to compare clients. Use IsSame to compare clients for equality.

func (Cluster_Runtime) WaitStreaming 

func (c Cluster_Runtime) WaitStreaming() error

type Cluster_Runtime_List 

type Cluster_Runtime_List = capnp.CapList[Cluster_Runtime]

Cluster_Runtime_List is a list of Cluster_Runtime.

func NewCluster_Runtime_List 

func NewCluster_Runtime_List(s *capnp.Segment, sz int32) (Cluster_Runtime_List, error)

NewCluster_Runtime creates a new list of Cluster_Runtime.

type Cluster_Runtime_Server 

type Cluster_Runtime_Server interface {
	RegisterModelInstanceFactory(context.Context, Cluster_Runtime_registerModelInstanceFactory) error

	AvailableModels(context.Context, Cluster_Runtime_availableModels) error

	NumberOfCores(context.Context, Cluster_Runtime_numberOfCores) error

	FreeNumberOfCores(context.Context, Cluster_Runtime_freeNumberOfCores) error

	ReserveNumberOfCores(context.Context, Cluster_Runtime_reserveNumberOfCores) error

	Info(context.Context, common.Identifiable_info) error
}

A Cluster_Runtime_Server is a Cluster_Runtime with a local implementation.

type Cluster_Runtime_availableModels 

type Cluster_Runtime_availableModels struct {
	*server.Call
}

Cluster_Runtime_availableModels holds the state for a server call to Cluster_Runtime.availableModels. See server.Call for documentation.

func (Cluster_Runtime_availableModels) AllocResults 

func (c Cluster_Runtime_availableModels) AllocResults() (Cluster_Runtime_availableModels_Results, error)

AllocResults allocates the results struct.

func (Cluster_Runtime_availableModels) Args 

func (c Cluster_Runtime_availableModels) Args() Cluster_Runtime_availableModels_Params

Args returns the call's arguments.

type Cluster_Runtime_availableModels_Params 

type Cluster_Runtime_availableModels_Params capnp.Struct

func NewCluster_Runtime_availableModels_Params 

func NewCluster_Runtime_availableModels_Params(s *capnp.Segment) (Cluster_Runtime_availableModels_Params, error)

func NewRootCluster_Runtime_availableModels_Params 

func NewRootCluster_Runtime_availableModels_Params(s *capnp.Segment) (Cluster_Runtime_availableModels_Params, error)

func ReadRootCluster_Runtime_availableModels_Params 

func ReadRootCluster_Runtime_availableModels_Params(msg *capnp.Message) (Cluster_Runtime_availableModels_Params, error)

func (Cluster_Runtime_availableModels_Params) DecodeFromPtr 

func (Cluster_Runtime_availableModels_Params) DecodeFromPtr(p capnp.Ptr) Cluster_Runtime_availableModels_Params

func (Cluster_Runtime_availableModels_Params) EncodeAsPtr 

func (s Cluster_Runtime_availableModels_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_Runtime_availableModels_Params) IsValid 

func (s Cluster_Runtime_availableModels_Params) IsValid() bool

func (Cluster_Runtime_availableModels_Params) Message 

func (s Cluster_Runtime_availableModels_Params) Message() *capnp.Message

func (Cluster_Runtime_availableModels_Params) Segment 

func (s Cluster_Runtime_availableModels_Params) Segment() *capnp.Segment

func (Cluster_Runtime_availableModels_Params) String 

func (s Cluster_Runtime_availableModels_Params) String() string

func (Cluster_Runtime_availableModels_Params) ToPtr 

func (s Cluster_Runtime_availableModels_Params) ToPtr() capnp.Ptr

type Cluster_Runtime_availableModels_Params_Future 

type Cluster_Runtime_availableModels_Params_Future struct{ *capnp.Future }

Cluster_Runtime_availableModels_Params_Future is a wrapper for a Cluster_Runtime_availableModels_Params promised by a client call.

func (Cluster_Runtime_availableModels_Params_Future) Struct 

func (f Cluster_Runtime_availableModels_Params_Future) Struct() (Cluster_Runtime_availableModels_Params, error)

type Cluster_Runtime_availableModels_Params_List 

type Cluster_Runtime_availableModels_Params_List = capnp.StructList[Cluster_Runtime_availableModels_Params]

Cluster_Runtime_availableModels_Params_List is a list of Cluster_Runtime_availableModels_Params.

func NewCluster_Runtime_availableModels_Params_List 

func NewCluster_Runtime_availableModels_Params_List(s *capnp.Segment, sz int32) (Cluster_Runtime_availableModels_Params_List, error)

NewCluster_Runtime_availableModels_Params creates a new list of Cluster_Runtime_availableModels_Params.

type Cluster_Runtime_availableModels_Results 

type Cluster_Runtime_availableModels_Results capnp.Struct

func NewCluster_Runtime_availableModels_Results 

func NewCluster_Runtime_availableModels_Results(s *capnp.Segment) (Cluster_Runtime_availableModels_Results, error)

func NewRootCluster_Runtime_availableModels_Results 

func NewRootCluster_Runtime_availableModels_Results(s *capnp.Segment) (Cluster_Runtime_availableModels_Results, error)

func ReadRootCluster_Runtime_availableModels_Results 

func ReadRootCluster_Runtime_availableModels_Results(msg *capnp.Message) (Cluster_Runtime_availableModels_Results, error)

func (Cluster_Runtime_availableModels_Results) DecodeFromPtr 

func (Cluster_Runtime_availableModels_Results) DecodeFromPtr(p capnp.Ptr) Cluster_Runtime_availableModels_Results

func (Cluster_Runtime_availableModels_Results) EncodeAsPtr 

func (s Cluster_Runtime_availableModels_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_Runtime_availableModels_Results) Factories 

func (s Cluster_Runtime_availableModels_Results) Factories() (Cluster_ModelInstanceFactory_List, error)

func (Cluster_Runtime_availableModels_Results) HasFactories 

func (s Cluster_Runtime_availableModels_Results) HasFactories() bool

func (Cluster_Runtime_availableModels_Results) IsValid 

func (s Cluster_Runtime_availableModels_Results) IsValid() bool

func (Cluster_Runtime_availableModels_Results) Message 

func (s Cluster_Runtime_availableModels_Results) Message() *capnp.Message

func (Cluster_Runtime_availableModels_Results) NewFactories 

func (s Cluster_Runtime_availableModels_Results) NewFactories(n int32) (Cluster_ModelInstanceFactory_List, error)

NewFactories sets the factories field to a newly allocated Cluster_ModelInstanceFactory_List, preferring placement in s's segment.

func (Cluster_Runtime_availableModels_Results) Segment 

func (s Cluster_Runtime_availableModels_Results) Segment() *capnp.Segment

func (Cluster_Runtime_availableModels_Results) SetFactories 

func (s Cluster_Runtime_availableModels_Results) SetFactories(v Cluster_ModelInstanceFactory_List) error

func (Cluster_Runtime_availableModels_Results) String 

func (s Cluster_Runtime_availableModels_Results) String() string

func (Cluster_Runtime_availableModels_Results) ToPtr 

func (s Cluster_Runtime_availableModels_Results) ToPtr() capnp.Ptr

type Cluster_Runtime_availableModels_Results_Future 

type Cluster_Runtime_availableModels_Results_Future struct{ *capnp.Future }

Cluster_Runtime_availableModels_Results_Future is a wrapper for a Cluster_Runtime_availableModels_Results promised by a client call.

func (Cluster_Runtime_availableModels_Results_Future) Struct 

func (f Cluster_Runtime_availableModels_Results_Future) Struct() (Cluster_Runtime_availableModels_Results, error)

type Cluster_Runtime_availableModels_Results_List 

type Cluster_Runtime_availableModels_Results_List = capnp.StructList[Cluster_Runtime_availableModels_Results]

Cluster_Runtime_availableModels_Results_List is a list of Cluster_Runtime_availableModels_Results.

func NewCluster_Runtime_availableModels_Results_List 

func NewCluster_Runtime_availableModels_Results_List(s *capnp.Segment, sz int32) (Cluster_Runtime_availableModels_Results_List, error)

NewCluster_Runtime_availableModels_Results creates a new list of Cluster_Runtime_availableModels_Results.

type Cluster_Runtime_freeNumberOfCores 

type Cluster_Runtime_freeNumberOfCores struct {
	*server.Call
}

Cluster_Runtime_freeNumberOfCores holds the state for a server call to Cluster_Runtime.freeNumberOfCores. See server.Call for documentation.

func (Cluster_Runtime_freeNumberOfCores) AllocResults 

func (c Cluster_Runtime_freeNumberOfCores) AllocResults() (Cluster_Runtime_freeNumberOfCores_Results, error)

AllocResults allocates the results struct.

func (Cluster_Runtime_freeNumberOfCores) Args 

func (c Cluster_Runtime_freeNumberOfCores) Args() Cluster_Runtime_freeNumberOfCores_Params

Args returns the call's arguments.

type Cluster_Runtime_freeNumberOfCores_Params 

type Cluster_Runtime_freeNumberOfCores_Params capnp.Struct

func NewCluster_Runtime_freeNumberOfCores_Params 

func NewCluster_Runtime_freeNumberOfCores_Params(s *capnp.Segment) (Cluster_Runtime_freeNumberOfCores_Params, error)

func NewRootCluster_Runtime_freeNumberOfCores_Params 

func NewRootCluster_Runtime_freeNumberOfCores_Params(s *capnp.Segment) (Cluster_Runtime_freeNumberOfCores_Params, error)

func ReadRootCluster_Runtime_freeNumberOfCores_Params 

func ReadRootCluster_Runtime_freeNumberOfCores_Params(msg *capnp.Message) (Cluster_Runtime_freeNumberOfCores_Params, error)

func (Cluster_Runtime_freeNumberOfCores_Params) DecodeFromPtr 

func (Cluster_Runtime_freeNumberOfCores_Params) DecodeFromPtr(p capnp.Ptr) Cluster_Runtime_freeNumberOfCores_Params

func (Cluster_Runtime_freeNumberOfCores_Params) EncodeAsPtr 

func (s Cluster_Runtime_freeNumberOfCores_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_Runtime_freeNumberOfCores_Params) IsValid 

func (s Cluster_Runtime_freeNumberOfCores_Params) IsValid() bool

func (Cluster_Runtime_freeNumberOfCores_Params) Message 

func (s Cluster_Runtime_freeNumberOfCores_Params) Message() *capnp.Message

func (Cluster_Runtime_freeNumberOfCores_Params) Segment 

func (s Cluster_Runtime_freeNumberOfCores_Params) Segment() *capnp.Segment

func (Cluster_Runtime_freeNumberOfCores_Params) String 

func (s Cluster_Runtime_freeNumberOfCores_Params) String() string

func (Cluster_Runtime_freeNumberOfCores_Params) ToPtr 

func (s Cluster_Runtime_freeNumberOfCores_Params) ToPtr() capnp.Ptr

type Cluster_Runtime_freeNumberOfCores_Params_Future 

type Cluster_Runtime_freeNumberOfCores_Params_Future struct{ *capnp.Future }

Cluster_Runtime_freeNumberOfCores_Params_Future is a wrapper for a Cluster_Runtime_freeNumberOfCores_Params promised by a client call.

func (Cluster_Runtime_freeNumberOfCores_Params_Future) Struct 

func (f Cluster_Runtime_freeNumberOfCores_Params_Future) Struct() (Cluster_Runtime_freeNumberOfCores_Params, error)

type Cluster_Runtime_freeNumberOfCores_Params_List 

type Cluster_Runtime_freeNumberOfCores_Params_List = capnp.StructList[Cluster_Runtime_freeNumberOfCores_Params]

Cluster_Runtime_freeNumberOfCores_Params_List is a list of Cluster_Runtime_freeNumberOfCores_Params.

func NewCluster_Runtime_freeNumberOfCores_Params_List 

func NewCluster_Runtime_freeNumberOfCores_Params_List(s *capnp.Segment, sz int32) (Cluster_Runtime_freeNumberOfCores_Params_List, error)

NewCluster_Runtime_freeNumberOfCores_Params creates a new list of Cluster_Runtime_freeNumberOfCores_Params.

type Cluster_Runtime_freeNumberOfCores_Results 

type Cluster_Runtime_freeNumberOfCores_Results capnp.Struct

func NewCluster_Runtime_freeNumberOfCores_Results 

func NewCluster_Runtime_freeNumberOfCores_Results(s *capnp.Segment) (Cluster_Runtime_freeNumberOfCores_Results, error)

func NewRootCluster_Runtime_freeNumberOfCores_Results 

func NewRootCluster_Runtime_freeNumberOfCores_Results(s *capnp.Segment) (Cluster_Runtime_freeNumberOfCores_Results, error)

func ReadRootCluster_Runtime_freeNumberOfCores_Results 

func ReadRootCluster_Runtime_freeNumberOfCores_Results(msg *capnp.Message) (Cluster_Runtime_freeNumberOfCores_Results, error)

func (Cluster_Runtime_freeNumberOfCores_Results) Cores 

func (s Cluster_Runtime_freeNumberOfCores_Results) Cores() int16

func (Cluster_Runtime_freeNumberOfCores_Results) DecodeFromPtr 

func (Cluster_Runtime_freeNumberOfCores_Results) DecodeFromPtr(p capnp.Ptr) Cluster_Runtime_freeNumberOfCores_Results

func (Cluster_Runtime_freeNumberOfCores_Results) EncodeAsPtr 

func (s Cluster_Runtime_freeNumberOfCores_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_Runtime_freeNumberOfCores_Results) IsValid 

func (s Cluster_Runtime_freeNumberOfCores_Results) IsValid() bool

func (Cluster_Runtime_freeNumberOfCores_Results) Message 

func (s Cluster_Runtime_freeNumberOfCores_Results) Message() *capnp.Message

func (Cluster_Runtime_freeNumberOfCores_Results) Segment 

func (s Cluster_Runtime_freeNumberOfCores_Results) Segment() *capnp.Segment

func (Cluster_Runtime_freeNumberOfCores_Results) SetCores 

func (s Cluster_Runtime_freeNumberOfCores_Results) SetCores(v int16)

func (Cluster_Runtime_freeNumberOfCores_Results) String 

func (s Cluster_Runtime_freeNumberOfCores_Results) String() string

func (Cluster_Runtime_freeNumberOfCores_Results) ToPtr 

func (s Cluster_Runtime_freeNumberOfCores_Results) ToPtr() capnp.Ptr

type Cluster_Runtime_freeNumberOfCores_Results_Future 

type Cluster_Runtime_freeNumberOfCores_Results_Future struct{ *capnp.Future }

Cluster_Runtime_freeNumberOfCores_Results_Future is a wrapper for a Cluster_Runtime_freeNumberOfCores_Results promised by a client call.

func (Cluster_Runtime_freeNumberOfCores_Results_Future) Struct 

func (f Cluster_Runtime_freeNumberOfCores_Results_Future) Struct() (Cluster_Runtime_freeNumberOfCores_Results, error)

type Cluster_Runtime_freeNumberOfCores_Results_List 

type Cluster_Runtime_freeNumberOfCores_Results_List = capnp.StructList[Cluster_Runtime_freeNumberOfCores_Results]

Cluster_Runtime_freeNumberOfCores_Results_List is a list of Cluster_Runtime_freeNumberOfCores_Results.

func NewCluster_Runtime_freeNumberOfCores_Results_List 

func NewCluster_Runtime_freeNumberOfCores_Results_List(s *capnp.Segment, sz int32) (Cluster_Runtime_freeNumberOfCores_Results_List, error)

NewCluster_Runtime_freeNumberOfCores_Results creates a new list of Cluster_Runtime_freeNumberOfCores_Results.

type Cluster_Runtime_numberOfCores 

type Cluster_Runtime_numberOfCores struct {
	*server.Call
}

Cluster_Runtime_numberOfCores holds the state for a server call to Cluster_Runtime.numberOfCores. See server.Call for documentation.

func (Cluster_Runtime_numberOfCores) AllocResults 

func (c Cluster_Runtime_numberOfCores) AllocResults() (Cluster_Runtime_numberOfCores_Results, error)

AllocResults allocates the results struct.

func (Cluster_Runtime_numberOfCores) Args 

func (c Cluster_Runtime_numberOfCores) Args() Cluster_Runtime_numberOfCores_Params

Args returns the call's arguments.

type Cluster_Runtime_numberOfCores_Params 

type Cluster_Runtime_numberOfCores_Params capnp.Struct

func NewCluster_Runtime_numberOfCores_Params 

func NewCluster_Runtime_numberOfCores_Params(s *capnp.Segment) (Cluster_Runtime_numberOfCores_Params, error)

func NewRootCluster_Runtime_numberOfCores_Params 

func NewRootCluster_Runtime_numberOfCores_Params(s *capnp.Segment) (Cluster_Runtime_numberOfCores_Params, error)

func ReadRootCluster_Runtime_numberOfCores_Params 

func ReadRootCluster_Runtime_numberOfCores_Params(msg *capnp.Message) (Cluster_Runtime_numberOfCores_Params, error)

func (Cluster_Runtime_numberOfCores_Params) DecodeFromPtr 

func (Cluster_Runtime_numberOfCores_Params) DecodeFromPtr(p capnp.Ptr) Cluster_Runtime_numberOfCores_Params

func (Cluster_Runtime_numberOfCores_Params) EncodeAsPtr 

func (s Cluster_Runtime_numberOfCores_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_Runtime_numberOfCores_Params) IsValid 

func (s Cluster_Runtime_numberOfCores_Params) IsValid() bool

func (Cluster_Runtime_numberOfCores_Params) Message 

func (s Cluster_Runtime_numberOfCores_Params) Message() *capnp.Message

func (Cluster_Runtime_numberOfCores_Params) Segment 

func (s Cluster_Runtime_numberOfCores_Params) Segment() *capnp.Segment

func (Cluster_Runtime_numberOfCores_Params) String 

func (s Cluster_Runtime_numberOfCores_Params) String() string

func (Cluster_Runtime_numberOfCores_Params) ToPtr 

func (s Cluster_Runtime_numberOfCores_Params) ToPtr() capnp.Ptr

type Cluster_Runtime_numberOfCores_Params_Future 

type Cluster_Runtime_numberOfCores_Params_Future struct{ *capnp.Future }

Cluster_Runtime_numberOfCores_Params_Future is a wrapper for a Cluster_Runtime_numberOfCores_Params promised by a client call.

func (Cluster_Runtime_numberOfCores_Params_Future) Struct 

func (f Cluster_Runtime_numberOfCores_Params_Future) Struct() (Cluster_Runtime_numberOfCores_Params, error)

type Cluster_Runtime_numberOfCores_Params_List 

type Cluster_Runtime_numberOfCores_Params_List = capnp.StructList[Cluster_Runtime_numberOfCores_Params]

Cluster_Runtime_numberOfCores_Params_List is a list of Cluster_Runtime_numberOfCores_Params.

func NewCluster_Runtime_numberOfCores_Params_List 

func NewCluster_Runtime_numberOfCores_Params_List(s *capnp.Segment, sz int32) (Cluster_Runtime_numberOfCores_Params_List, error)

NewCluster_Runtime_numberOfCores_Params creates a new list of Cluster_Runtime_numberOfCores_Params.

type Cluster_Runtime_numberOfCores_Results 

type Cluster_Runtime_numberOfCores_Results capnp.Struct

func NewCluster_Runtime_numberOfCores_Results 

func NewCluster_Runtime_numberOfCores_Results(s *capnp.Segment) (Cluster_Runtime_numberOfCores_Results, error)

func NewRootCluster_Runtime_numberOfCores_Results 

func NewRootCluster_Runtime_numberOfCores_Results(s *capnp.Segment) (Cluster_Runtime_numberOfCores_Results, error)

func ReadRootCluster_Runtime_numberOfCores_Results 

func ReadRootCluster_Runtime_numberOfCores_Results(msg *capnp.Message) (Cluster_Runtime_numberOfCores_Results, error)

func (Cluster_Runtime_numberOfCores_Results) Cores 

func (s Cluster_Runtime_numberOfCores_Results) Cores() int16

func (Cluster_Runtime_numberOfCores_Results) DecodeFromPtr 

func (Cluster_Runtime_numberOfCores_Results) DecodeFromPtr(p capnp.Ptr) Cluster_Runtime_numberOfCores_Results

func (Cluster_Runtime_numberOfCores_Results) EncodeAsPtr 

func (s Cluster_Runtime_numberOfCores_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_Runtime_numberOfCores_Results) IsValid 

func (s Cluster_Runtime_numberOfCores_Results) IsValid() bool

func (Cluster_Runtime_numberOfCores_Results) Message 

func (s Cluster_Runtime_numberOfCores_Results) Message() *capnp.Message

func (Cluster_Runtime_numberOfCores_Results) Segment 

func (s Cluster_Runtime_numberOfCores_Results) Segment() *capnp.Segment

func (Cluster_Runtime_numberOfCores_Results) SetCores 

func (s Cluster_Runtime_numberOfCores_Results) SetCores(v int16)

func (Cluster_Runtime_numberOfCores_Results) String 

func (s Cluster_Runtime_numberOfCores_Results) String() string

func (Cluster_Runtime_numberOfCores_Results) ToPtr 

func (s Cluster_Runtime_numberOfCores_Results) ToPtr() capnp.Ptr

type Cluster_Runtime_numberOfCores_Results_Future 

type Cluster_Runtime_numberOfCores_Results_Future struct{ *capnp.Future }

Cluster_Runtime_numberOfCores_Results_Future is a wrapper for a Cluster_Runtime_numberOfCores_Results promised by a client call.

func (Cluster_Runtime_numberOfCores_Results_Future) Struct 

func (f Cluster_Runtime_numberOfCores_Results_Future) Struct() (Cluster_Runtime_numberOfCores_Results, error)

type Cluster_Runtime_numberOfCores_Results_List 

type Cluster_Runtime_numberOfCores_Results_List = capnp.StructList[Cluster_Runtime_numberOfCores_Results]

Cluster_Runtime_numberOfCores_Results_List is a list of Cluster_Runtime_numberOfCores_Results.

func NewCluster_Runtime_numberOfCores_Results_List 

func NewCluster_Runtime_numberOfCores_Results_List(s *capnp.Segment, sz int32) (Cluster_Runtime_numberOfCores_Results_List, error)

NewCluster_Runtime_numberOfCores_Results creates a new list of Cluster_Runtime_numberOfCores_Results.

type Cluster_Runtime_registerModelInstanceFactory 

type Cluster_Runtime_registerModelInstanceFactory struct {
	*server.Call
}

Cluster_Runtime_registerModelInstanceFactory holds the state for a server call to Cluster_Runtime.registerModelInstanceFactory. See server.Call for documentation.

func (Cluster_Runtime_registerModelInstanceFactory) AllocResults 

func (c Cluster_Runtime_registerModelInstanceFactory) AllocResults() (Cluster_Runtime_registerModelInstanceFactory_Results, error)

AllocResults allocates the results struct.

func (Cluster_Runtime_registerModelInstanceFactory) Args 

func (c Cluster_Runtime_registerModelInstanceFactory) Args() Cluster_Runtime_registerModelInstanceFactory_Params

Args returns the call's arguments.

type Cluster_Runtime_registerModelInstanceFactory_Params 

type Cluster_Runtime_registerModelInstanceFactory_Params capnp.Struct

func NewCluster_Runtime_registerModelInstanceFactory_Params 

func NewCluster_Runtime_registerModelInstanceFactory_Params(s *capnp.Segment) (Cluster_Runtime_registerModelInstanceFactory_Params, error)

func NewRootCluster_Runtime_registerModelInstanceFactory_Params 

func NewRootCluster_Runtime_registerModelInstanceFactory_Params(s *capnp.Segment) (Cluster_Runtime_registerModelInstanceFactory_Params, error)

func ReadRootCluster_Runtime_registerModelInstanceFactory_Params 

func ReadRootCluster_Runtime_registerModelInstanceFactory_Params(msg *capnp.Message) (Cluster_Runtime_registerModelInstanceFactory_Params, error)

func (Cluster_Runtime_registerModelInstanceFactory_Params) AFactory 

func (s Cluster_Runtime_registerModelInstanceFactory_Params) AFactory() Cluster_ModelInstanceFactory

func (Cluster_Runtime_registerModelInstanceFactory_Params) AModelId 

func (s Cluster_Runtime_registerModelInstanceFactory_Params) AModelId() (string, error)

func (Cluster_Runtime_registerModelInstanceFactory_Params) AModelIdBytes 

func (s Cluster_Runtime_registerModelInstanceFactory_Params) AModelIdBytes() ([]byte, error)

func (Cluster_Runtime_registerModelInstanceFactory_Params) DecodeFromPtr 

func (Cluster_Runtime_registerModelInstanceFactory_Params) DecodeFromPtr(p capnp.Ptr) Cluster_Runtime_registerModelInstanceFactory_Params

func (Cluster_Runtime_registerModelInstanceFactory_Params) EncodeAsPtr 

func (s Cluster_Runtime_registerModelInstanceFactory_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_Runtime_registerModelInstanceFactory_Params) HasAFactory 

func (s Cluster_Runtime_registerModelInstanceFactory_Params) HasAFactory() bool

func (Cluster_Runtime_registerModelInstanceFactory_Params) HasAModelId 

func (s Cluster_Runtime_registerModelInstanceFactory_Params) HasAModelId() bool

func (Cluster_Runtime_registerModelInstanceFactory_Params) IsValid 

func (s Cluster_Runtime_registerModelInstanceFactory_Params) IsValid() bool

func (Cluster_Runtime_registerModelInstanceFactory_Params) Message 

func (s Cluster_Runtime_registerModelInstanceFactory_Params) Message() *capnp.Message

func (Cluster_Runtime_registerModelInstanceFactory_Params) Segment 

func (s Cluster_Runtime_registerModelInstanceFactory_Params) Segment() *capnp.Segment

func (Cluster_Runtime_registerModelInstanceFactory_Params) SetAFactory 

func (s Cluster_Runtime_registerModelInstanceFactory_Params) SetAFactory(v Cluster_ModelInstanceFactory) error

func (Cluster_Runtime_registerModelInstanceFactory_Params) SetAModelId 

func (s Cluster_Runtime_registerModelInstanceFactory_Params) SetAModelId(v string) error

func (Cluster_Runtime_registerModelInstanceFactory_Params) String 

func (s Cluster_Runtime_registerModelInstanceFactory_Params) String() string

func (Cluster_Runtime_registerModelInstanceFactory_Params) ToPtr 

func (s Cluster_Runtime_registerModelInstanceFactory_Params) ToPtr() capnp.Ptr

type Cluster_Runtime_registerModelInstanceFactory_Params_Future 

type Cluster_Runtime_registerModelInstanceFactory_Params_Future struct{ *capnp.Future }

Cluster_Runtime_registerModelInstanceFactory_Params_Future is a wrapper for a Cluster_Runtime_registerModelInstanceFactory_Params promised by a client call.

func (Cluster_Runtime_registerModelInstanceFactory_Params_Future) AFactory 

func (p Cluster_Runtime_registerModelInstanceFactory_Params_Future) AFactory() Cluster_ModelInstanceFactory

func (Cluster_Runtime_registerModelInstanceFactory_Params_Future) Struct 

func (f Cluster_Runtime_registerModelInstanceFactory_Params_Future) Struct() (Cluster_Runtime_registerModelInstanceFactory_Params, error)

type Cluster_Runtime_registerModelInstanceFactory_Params_List 

type Cluster_Runtime_registerModelInstanceFactory_Params_List = capnp.StructList[Cluster_Runtime_registerModelInstanceFactory_Params]

Cluster_Runtime_registerModelInstanceFactory_Params_List is a list of Cluster_Runtime_registerModelInstanceFactory_Params.

func NewCluster_Runtime_registerModelInstanceFactory_Params_List 

func NewCluster_Runtime_registerModelInstanceFactory_Params_List(s *capnp.Segment, sz int32) (Cluster_Runtime_registerModelInstanceFactory_Params_List, error)

NewCluster_Runtime_registerModelInstanceFactory_Params creates a new list of Cluster_Runtime_registerModelInstanceFactory_Params.

type Cluster_Runtime_registerModelInstanceFactory_Results 

type Cluster_Runtime_registerModelInstanceFactory_Results capnp.Struct

func NewCluster_Runtime_registerModelInstanceFactory_Results 

func NewCluster_Runtime_registerModelInstanceFactory_Results(s *capnp.Segment) (Cluster_Runtime_registerModelInstanceFactory_Results, error)

func NewRootCluster_Runtime_registerModelInstanceFactory_Results 

func NewRootCluster_Runtime_registerModelInstanceFactory_Results(s *capnp.Segment) (Cluster_Runtime_registerModelInstanceFactory_Results, error)

func ReadRootCluster_Runtime_registerModelInstanceFactory_Results 

func ReadRootCluster_Runtime_registerModelInstanceFactory_Results(msg *capnp.Message) (Cluster_Runtime_registerModelInstanceFactory_Results, error)

func (Cluster_Runtime_registerModelInstanceFactory_Results) DecodeFromPtr 

func (Cluster_Runtime_registerModelInstanceFactory_Results) DecodeFromPtr(p capnp.Ptr) Cluster_Runtime_registerModelInstanceFactory_Results

func (Cluster_Runtime_registerModelInstanceFactory_Results) EncodeAsPtr 

func (s Cluster_Runtime_registerModelInstanceFactory_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_Runtime_registerModelInstanceFactory_Results) HasUnregister 

func (s Cluster_Runtime_registerModelInstanceFactory_Results) HasUnregister() bool

func (Cluster_Runtime_registerModelInstanceFactory_Results) IsValid 

func (s Cluster_Runtime_registerModelInstanceFactory_Results) IsValid() bool

func (Cluster_Runtime_registerModelInstanceFactory_Results) Message 

func (s Cluster_Runtime_registerModelInstanceFactory_Results) Message() *capnp.Message

func (Cluster_Runtime_registerModelInstanceFactory_Results) Segment 

func (s Cluster_Runtime_registerModelInstanceFactory_Results) Segment() *capnp.Segment

func (Cluster_Runtime_registerModelInstanceFactory_Results) SetUnregister 

func (s Cluster_Runtime_registerModelInstanceFactory_Results) SetUnregister(v Cluster_Unregister) error

func (Cluster_Runtime_registerModelInstanceFactory_Results) String 

func (s Cluster_Runtime_registerModelInstanceFactory_Results) String() string

func (Cluster_Runtime_registerModelInstanceFactory_Results) ToPtr 

func (s Cluster_Runtime_registerModelInstanceFactory_Results) ToPtr() capnp.Ptr

func (Cluster_Runtime_registerModelInstanceFactory_Results) Unregister 

func (s Cluster_Runtime_registerModelInstanceFactory_Results) Unregister() Cluster_Unregister

type Cluster_Runtime_registerModelInstanceFactory_Results_Future 

type Cluster_Runtime_registerModelInstanceFactory_Results_Future struct{ *capnp.Future }

Cluster_Runtime_registerModelInstanceFactory_Results_Future is a wrapper for a Cluster_Runtime_registerModelInstanceFactory_Results promised by a client call.

func (Cluster_Runtime_registerModelInstanceFactory_Results_Future) Struct 

func (f Cluster_Runtime_registerModelInstanceFactory_Results_Future) Struct() (Cluster_Runtime_registerModelInstanceFactory_Results, error)

func (Cluster_Runtime_registerModelInstanceFactory_Results_Future) Unregister 

func (p Cluster_Runtime_registerModelInstanceFactory_Results_Future) Unregister() Cluster_Unregister

type Cluster_Runtime_registerModelInstanceFactory_Results_List 

type Cluster_Runtime_registerModelInstanceFactory_Results_List = capnp.StructList[Cluster_Runtime_registerModelInstanceFactory_Results]

Cluster_Runtime_registerModelInstanceFactory_Results_List is a list of Cluster_Runtime_registerModelInstanceFactory_Results.

func NewCluster_Runtime_registerModelInstanceFactory_Results_List 

func NewCluster_Runtime_registerModelInstanceFactory_Results_List(s *capnp.Segment, sz int32) (Cluster_Runtime_registerModelInstanceFactory_Results_List, error)

NewCluster_Runtime_registerModelInstanceFactory_Results creates a new list of Cluster_Runtime_registerModelInstanceFactory_Results.

type Cluster_Runtime_reserveNumberOfCores 

type Cluster_Runtime_reserveNumberOfCores struct {
	*server.Call
}

Cluster_Runtime_reserveNumberOfCores holds the state for a server call to Cluster_Runtime.reserveNumberOfCores. See server.Call for documentation.

func (Cluster_Runtime_reserveNumberOfCores) AllocResults 

func (c Cluster_Runtime_reserveNumberOfCores) AllocResults() (Cluster_Runtime_reserveNumberOfCores_Results, error)

AllocResults allocates the results struct.

func (Cluster_Runtime_reserveNumberOfCores) Args 

func (c Cluster_Runtime_reserveNumberOfCores) Args() Cluster_Runtime_reserveNumberOfCores_Params

Args returns the call's arguments.

type Cluster_Runtime_reserveNumberOfCores_Params 

type Cluster_Runtime_reserveNumberOfCores_Params capnp.Struct

func NewCluster_Runtime_reserveNumberOfCores_Params 

func NewCluster_Runtime_reserveNumberOfCores_Params(s *capnp.Segment) (Cluster_Runtime_reserveNumberOfCores_Params, error)

func NewRootCluster_Runtime_reserveNumberOfCores_Params 

func NewRootCluster_Runtime_reserveNumberOfCores_Params(s *capnp.Segment) (Cluster_Runtime_reserveNumberOfCores_Params, error)

func ReadRootCluster_Runtime_reserveNumberOfCores_Params 

func ReadRootCluster_Runtime_reserveNumberOfCores_Params(msg *capnp.Message) (Cluster_Runtime_reserveNumberOfCores_Params, error)

func (Cluster_Runtime_reserveNumberOfCores_Params) AModelId 

func (s Cluster_Runtime_reserveNumberOfCores_Params) AModelId() (string, error)

func (Cluster_Runtime_reserveNumberOfCores_Params) AModelIdBytes 

func (s Cluster_Runtime_reserveNumberOfCores_Params) AModelIdBytes() ([]byte, error)

func (Cluster_Runtime_reserveNumberOfCores_Params) DecodeFromPtr 

func (Cluster_Runtime_reserveNumberOfCores_Params) DecodeFromPtr(p capnp.Ptr) Cluster_Runtime_reserveNumberOfCores_Params

func (Cluster_Runtime_reserveNumberOfCores_Params) EncodeAsPtr 

func (s Cluster_Runtime_reserveNumberOfCores_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_Runtime_reserveNumberOfCores_Params) HasAModelId 

func (s Cluster_Runtime_reserveNumberOfCores_Params) HasAModelId() bool

func (Cluster_Runtime_reserveNumberOfCores_Params) IsValid 

func (s Cluster_Runtime_reserveNumberOfCores_Params) IsValid() bool

func (Cluster_Runtime_reserveNumberOfCores_Params) Message 

func (s Cluster_Runtime_reserveNumberOfCores_Params) Message() *capnp.Message

func (Cluster_Runtime_reserveNumberOfCores_Params) ReserveCores 

func (s Cluster_Runtime_reserveNumberOfCores_Params) ReserveCores() int16

func (Cluster_Runtime_reserveNumberOfCores_Params) Segment 

func (s Cluster_Runtime_reserveNumberOfCores_Params) Segment() *capnp.Segment

func (Cluster_Runtime_reserveNumberOfCores_Params) SetAModelId 

func (s Cluster_Runtime_reserveNumberOfCores_Params) SetAModelId(v string) error

func (Cluster_Runtime_reserveNumberOfCores_Params) SetReserveCores 

func (s Cluster_Runtime_reserveNumberOfCores_Params) SetReserveCores(v int16)

func (Cluster_Runtime_reserveNumberOfCores_Params) String 

func (s Cluster_Runtime_reserveNumberOfCores_Params) String() string

func (Cluster_Runtime_reserveNumberOfCores_Params) ToPtr 

func (s Cluster_Runtime_reserveNumberOfCores_Params) ToPtr() capnp.Ptr

type Cluster_Runtime_reserveNumberOfCores_Params_Future 

type Cluster_Runtime_reserveNumberOfCores_Params_Future struct{ *capnp.Future }

Cluster_Runtime_reserveNumberOfCores_Params_Future is a wrapper for a Cluster_Runtime_reserveNumberOfCores_Params promised by a client call.

func (Cluster_Runtime_reserveNumberOfCores_Params_Future) Struct 

func (f Cluster_Runtime_reserveNumberOfCores_Params_Future) Struct() (Cluster_Runtime_reserveNumberOfCores_Params, error)

type Cluster_Runtime_reserveNumberOfCores_Params_List 

type Cluster_Runtime_reserveNumberOfCores_Params_List = capnp.StructList[Cluster_Runtime_reserveNumberOfCores_Params]

Cluster_Runtime_reserveNumberOfCores_Params_List is a list of Cluster_Runtime_reserveNumberOfCores_Params.

func NewCluster_Runtime_reserveNumberOfCores_Params_List 

func NewCluster_Runtime_reserveNumberOfCores_Params_List(s *capnp.Segment, sz int32) (Cluster_Runtime_reserveNumberOfCores_Params_List, error)

NewCluster_Runtime_reserveNumberOfCores_Params creates a new list of Cluster_Runtime_reserveNumberOfCores_Params.

type Cluster_Runtime_reserveNumberOfCores_Results 

type Cluster_Runtime_reserveNumberOfCores_Results capnp.Struct

func NewCluster_Runtime_reserveNumberOfCores_Results 

func NewCluster_Runtime_reserveNumberOfCores_Results(s *capnp.Segment) (Cluster_Runtime_reserveNumberOfCores_Results, error)

func NewRootCluster_Runtime_reserveNumberOfCores_Results 

func NewRootCluster_Runtime_reserveNumberOfCores_Results(s *capnp.Segment) (Cluster_Runtime_reserveNumberOfCores_Results, error)

func ReadRootCluster_Runtime_reserveNumberOfCores_Results 

func ReadRootCluster_Runtime_reserveNumberOfCores_Results(msg *capnp.Message) (Cluster_Runtime_reserveNumberOfCores_Results, error)

func (Cluster_Runtime_reserveNumberOfCores_Results) DecodeFromPtr 

func (Cluster_Runtime_reserveNumberOfCores_Results) DecodeFromPtr(p capnp.Ptr) Cluster_Runtime_reserveNumberOfCores_Results

func (Cluster_Runtime_reserveNumberOfCores_Results) EncodeAsPtr 

func (s Cluster_Runtime_reserveNumberOfCores_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_Runtime_reserveNumberOfCores_Results) IsValid 

func (s Cluster_Runtime_reserveNumberOfCores_Results) IsValid() bool

func (Cluster_Runtime_reserveNumberOfCores_Results) Message 

func (s Cluster_Runtime_reserveNumberOfCores_Results) Message() *capnp.Message

func (Cluster_Runtime_reserveNumberOfCores_Results) ReservedCores 

func (s Cluster_Runtime_reserveNumberOfCores_Results) ReservedCores() int16

func (Cluster_Runtime_reserveNumberOfCores_Results) Segment 

func (s Cluster_Runtime_reserveNumberOfCores_Results) Segment() *capnp.Segment

func (Cluster_Runtime_reserveNumberOfCores_Results) SetReservedCores 

func (s Cluster_Runtime_reserveNumberOfCores_Results) SetReservedCores(v int16)

func (Cluster_Runtime_reserveNumberOfCores_Results) String 

func (s Cluster_Runtime_reserveNumberOfCores_Results) String() string

func (Cluster_Runtime_reserveNumberOfCores_Results) ToPtr 

func (s Cluster_Runtime_reserveNumberOfCores_Results) ToPtr() capnp.Ptr

type Cluster_Runtime_reserveNumberOfCores_Results_Future 

type Cluster_Runtime_reserveNumberOfCores_Results_Future struct{ *capnp.Future }

Cluster_Runtime_reserveNumberOfCores_Results_Future is a wrapper for a Cluster_Runtime_reserveNumberOfCores_Results promised by a client call.

func (Cluster_Runtime_reserveNumberOfCores_Results_Future) Struct 

func (f Cluster_Runtime_reserveNumberOfCores_Results_Future) Struct() (Cluster_Runtime_reserveNumberOfCores_Results, error)

type Cluster_Runtime_reserveNumberOfCores_Results_List 

type Cluster_Runtime_reserveNumberOfCores_Results_List = capnp.StructList[Cluster_Runtime_reserveNumberOfCores_Results]

Cluster_Runtime_reserveNumberOfCores_Results_List is a list of Cluster_Runtime_reserveNumberOfCores_Results.

func NewCluster_Runtime_reserveNumberOfCores_Results_List 

func NewCluster_Runtime_reserveNumberOfCores_Results_List(s *capnp.Segment, sz int32) (Cluster_Runtime_reserveNumberOfCores_Results_List, error)

NewCluster_Runtime_reserveNumberOfCores_Results creates a new list of Cluster_Runtime_reserveNumberOfCores_Results.

type Cluster_Unregister 

type Cluster_Unregister capnp.Client

func Cluster_Unregister_ServerToClient 

func Cluster_Unregister_ServerToClient(s Cluster_Unregister_Server) Cluster_Unregister

Cluster_Unregister_ServerToClient creates a new Client from an implementation of Cluster_Unregister_Server. The caller is responsible for calling Release on the returned Client.

func (Cluster_Unregister) AddRef 

func (c Cluster_Unregister) AddRef() Cluster_Unregister

AddRef creates a new Client that refers to the same capability as c. If c is nil or has resolved to null, then AddRef returns nil.

func (Cluster_Unregister) DecodeFromPtr 

func (Cluster_Unregister) DecodeFromPtr(p capnp.Ptr) Cluster_Unregister

func (Cluster_Unregister) EncodeAsPtr 

func (c Cluster_Unregister) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_Unregister) GetFlowLimiter 

func (c Cluster_Unregister) GetFlowLimiter() fc.FlowLimiter

Get the current flowcontrol.FlowLimiter used to manage flow control for this client.

func (Cluster_Unregister) IsSame 

func (c Cluster_Unregister) IsSame(other Cluster_Unregister) bool

IsSame reports whether c and other refer to a capability created by the same call to NewClient. This can return false negatives if c or other are not fully resolved: use Resolve if this is an issue. If either c or other are released, then IsSame panics.

func (Cluster_Unregister) IsValid 

func (c Cluster_Unregister) IsValid() bool

IsValid reports whether c is a valid reference to a capability. A reference is invalid if it is nil, has resolved to null, or has been released.

func (Cluster_Unregister) Release 

func (c Cluster_Unregister) Release()

Release releases a capability reference. If this is the last reference to the capability, then the underlying resources associated with the capability will be released.

Release will panic if c has already been released, but not if c is nil or resolved to null.

func (Cluster_Unregister) Resolve 

func (c Cluster_Unregister) Resolve(ctx context.Context) error

Resolve blocks until the capability is fully resolved or the Context expires.

func (Cluster_Unregister) SetFlowLimiter 

func (c Cluster_Unregister) SetFlowLimiter(lim fc.FlowLimiter)

Update the flowcontrol.FlowLimiter used to manage flow control for this client. This affects all future calls, but not calls already waiting to send. Passing nil sets the value to flowcontrol.NopLimiter, which is also the default.

func (Cluster_Unregister) String 

func (c Cluster_Unregister) String() string

String returns a string that identifies this capability for debugging purposes. Its format should not be depended on: in particular, it should not be used to compare clients. Use IsSame to compare clients for equality.

func (Cluster_Unregister) Unregister 

func (c Cluster_Unregister) Unregister(ctx context.Context, params func(Cluster_Unregister_unregister_Params) error) (Cluster_Unregister_unregister_Results_Future, capnp.ReleaseFunc)

func (Cluster_Unregister) WaitStreaming 

func (c Cluster_Unregister) WaitStreaming() error

type Cluster_Unregister_List 

type Cluster_Unregister_List = capnp.CapList[Cluster_Unregister]

Cluster_Unregister_List is a list of Cluster_Unregister.

func NewCluster_Unregister_List 

func NewCluster_Unregister_List(s *capnp.Segment, sz int32) (Cluster_Unregister_List, error)

NewCluster_Unregister creates a new list of Cluster_Unregister.

type Cluster_Unregister_Server 

type Cluster_Unregister_Server interface {
	Unregister(context.Context, Cluster_Unregister_unregister) error
}

A Cluster_Unregister_Server is a Cluster_Unregister with a local implementation.

type Cluster_Unregister_unregister 

type Cluster_Unregister_unregister struct {
	*server.Call
}

Cluster_Unregister_unregister holds the state for a server call to Cluster_Unregister.unregister. See server.Call for documentation.

func (Cluster_Unregister_unregister) AllocResults 

func (c Cluster_Unregister_unregister) AllocResults() (Cluster_Unregister_unregister_Results, error)

AllocResults allocates the results struct.

func (Cluster_Unregister_unregister) Args 

func (c Cluster_Unregister_unregister) Args() Cluster_Unregister_unregister_Params

Args returns the call's arguments.

type Cluster_Unregister_unregister_Params 

type Cluster_Unregister_unregister_Params capnp.Struct

func NewCluster_Unregister_unregister_Params 

func NewCluster_Unregister_unregister_Params(s *capnp.Segment) (Cluster_Unregister_unregister_Params, error)

func NewRootCluster_Unregister_unregister_Params 

func NewRootCluster_Unregister_unregister_Params(s *capnp.Segment) (Cluster_Unregister_unregister_Params, error)

func ReadRootCluster_Unregister_unregister_Params 

func ReadRootCluster_Unregister_unregister_Params(msg *capnp.Message) (Cluster_Unregister_unregister_Params, error)

func (Cluster_Unregister_unregister_Params) DecodeFromPtr 

func (Cluster_Unregister_unregister_Params) DecodeFromPtr(p capnp.Ptr) Cluster_Unregister_unregister_Params

func (Cluster_Unregister_unregister_Params) EncodeAsPtr 

func (s Cluster_Unregister_unregister_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_Unregister_unregister_Params) IsValid 

func (s Cluster_Unregister_unregister_Params) IsValid() bool

func (Cluster_Unregister_unregister_Params) Message 

func (s Cluster_Unregister_unregister_Params) Message() *capnp.Message

func (Cluster_Unregister_unregister_Params) Segment 

func (s Cluster_Unregister_unregister_Params) Segment() *capnp.Segment

func (Cluster_Unregister_unregister_Params) String 

func (s Cluster_Unregister_unregister_Params) String() string

func (Cluster_Unregister_unregister_Params) ToPtr 

func (s Cluster_Unregister_unregister_Params) ToPtr() capnp.Ptr

type Cluster_Unregister_unregister_Params_Future 

type Cluster_Unregister_unregister_Params_Future struct{ *capnp.Future }

Cluster_Unregister_unregister_Params_Future is a wrapper for a Cluster_Unregister_unregister_Params promised by a client call.

func (Cluster_Unregister_unregister_Params_Future) Struct 

func (f Cluster_Unregister_unregister_Params_Future) Struct() (Cluster_Unregister_unregister_Params, error)

type Cluster_Unregister_unregister_Params_List 

type Cluster_Unregister_unregister_Params_List = capnp.StructList[Cluster_Unregister_unregister_Params]

Cluster_Unregister_unregister_Params_List is a list of Cluster_Unregister_unregister_Params.

func NewCluster_Unregister_unregister_Params_List 

func NewCluster_Unregister_unregister_Params_List(s *capnp.Segment, sz int32) (Cluster_Unregister_unregister_Params_List, error)

NewCluster_Unregister_unregister_Params creates a new list of Cluster_Unregister_unregister_Params.

type Cluster_Unregister_unregister_Results 

type Cluster_Unregister_unregister_Results capnp.Struct

func NewCluster_Unregister_unregister_Results 

func NewCluster_Unregister_unregister_Results(s *capnp.Segment) (Cluster_Unregister_unregister_Results, error)

func NewRootCluster_Unregister_unregister_Results 

func NewRootCluster_Unregister_unregister_Results(s *capnp.Segment) (Cluster_Unregister_unregister_Results, error)

func ReadRootCluster_Unregister_unregister_Results 

func ReadRootCluster_Unregister_unregister_Results(msg *capnp.Message) (Cluster_Unregister_unregister_Results, error)

func (Cluster_Unregister_unregister_Results) DecodeFromPtr 

func (Cluster_Unregister_unregister_Results) DecodeFromPtr(p capnp.Ptr) Cluster_Unregister_unregister_Results

func (Cluster_Unregister_unregister_Results) EncodeAsPtr 

func (s Cluster_Unregister_unregister_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_Unregister_unregister_Results) IsValid 

func (s Cluster_Unregister_unregister_Results) IsValid() bool

func (Cluster_Unregister_unregister_Results) Message 

func (s Cluster_Unregister_unregister_Results) Message() *capnp.Message

func (Cluster_Unregister_unregister_Results) Segment 

func (s Cluster_Unregister_unregister_Results) Segment() *capnp.Segment

func (Cluster_Unregister_unregister_Results) SetSuccess 

func (s Cluster_Unregister_unregister_Results) SetSuccess(v bool)

func (Cluster_Unregister_unregister_Results) String 

func (s Cluster_Unregister_unregister_Results) String() string

func (Cluster_Unregister_unregister_Results) Success 

func (s Cluster_Unregister_unregister_Results) Success() bool

func (Cluster_Unregister_unregister_Results) ToPtr 

func (s Cluster_Unregister_unregister_Results) ToPtr() capnp.Ptr

type Cluster_Unregister_unregister_Results_Future 

type Cluster_Unregister_unregister_Results_Future struct{ *capnp.Future }

Cluster_Unregister_unregister_Results_Future is a wrapper for a Cluster_Unregister_unregister_Results promised by a client call.

func (Cluster_Unregister_unregister_Results_Future) Struct 

func (f Cluster_Unregister_unregister_Results_Future) Struct() (Cluster_Unregister_unregister_Results, error)

type Cluster_Unregister_unregister_Results_List 

type Cluster_Unregister_unregister_Results_List = capnp.StructList[Cluster_Unregister_unregister_Results]

Cluster_Unregister_unregister_Results_List is a list of Cluster_Unregister_unregister_Results.

func NewCluster_Unregister_unregister_Results_List 

func NewCluster_Unregister_unregister_Results_List(s *capnp.Segment, sz int32) (Cluster_Unregister_unregister_Results_List, error)

NewCluster_Unregister_unregister_Results creates a new list of Cluster_Unregister_unregister_Results.

type Cluster_UserMaster 

type Cluster_UserMaster capnp.Client

func Cluster_UserMaster_ServerToClient 

func Cluster_UserMaster_ServerToClient(s Cluster_UserMaster_Server) Cluster_UserMaster

Cluster_UserMaster_ServerToClient creates a new Client from an implementation of Cluster_UserMaster_Server. The caller is responsible for calling Release on the returned Client.

func (Cluster_UserMaster) AddRef 

func (c Cluster_UserMaster) AddRef() Cluster_UserMaster

AddRef creates a new Client that refers to the same capability as c. If c is nil or has resolved to null, then AddRef returns nil.

func (Cluster_UserMaster) AvailableModels 

func (c Cluster_UserMaster) AvailableModels(ctx context.Context, params func(Cluster_UserMaster_availableModels_Params) error) (Cluster_UserMaster_availableModels_Results_Future, capnp.ReleaseFunc)

func (Cluster_UserMaster) DecodeFromPtr 

func (Cluster_UserMaster) DecodeFromPtr(p capnp.Ptr) Cluster_UserMaster

func (Cluster_UserMaster) EncodeAsPtr 

func (c Cluster_UserMaster) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_UserMaster) GetFlowLimiter 

func (c Cluster_UserMaster) GetFlowLimiter() fc.FlowLimiter

Get the current flowcontrol.FlowLimiter used to manage flow control for this client.

func (Cluster_UserMaster) Info 

func (c Cluster_UserMaster) Info(ctx context.Context, params func(common.Identifiable_info_Params) error) (common.IdInformation_Future, capnp.ReleaseFunc)

func (Cluster_UserMaster) IsSame 

func (c Cluster_UserMaster) IsSame(other Cluster_UserMaster) bool

IsSame reports whether c and other refer to a capability created by the same call to NewClient. This can return false negatives if c or other are not fully resolved: use Resolve if this is an issue. If either c or other are released, then IsSame panics.

func (Cluster_UserMaster) IsValid 

func (c Cluster_UserMaster) IsValid() bool

IsValid reports whether c is a valid reference to a capability. A reference is invalid if it is nil, has resolved to null, or has been released.

func (Cluster_UserMaster) Release 

func (c Cluster_UserMaster) Release()

Release releases a capability reference. If this is the last reference to the capability, then the underlying resources associated with the capability will be released.

Release will panic if c has already been released, but not if c is nil or resolved to null.

func (Cluster_UserMaster) Resolve 

func (c Cluster_UserMaster) Resolve(ctx context.Context) error

Resolve blocks until the capability is fully resolved or the Context expires.

func (Cluster_UserMaster) SetFlowLimiter 

func (c Cluster_UserMaster) SetFlowLimiter(lim fc.FlowLimiter)

Update the flowcontrol.FlowLimiter used to manage flow control for this client. This affects all future calls, but not calls already waiting to send. Passing nil sets the value to flowcontrol.NopLimiter, which is also the default.

func (Cluster_UserMaster) String 

func (c Cluster_UserMaster) String() string

String returns a string that identifies this capability for debugging purposes. Its format should not be depended on: in particular, it should not be used to compare clients. Use IsSame to compare clients for equality.

func (Cluster_UserMaster) WaitStreaming 

func (c Cluster_UserMaster) WaitStreaming() error

type Cluster_UserMaster_List 

type Cluster_UserMaster_List = capnp.CapList[Cluster_UserMaster]

Cluster_UserMaster_List is a list of Cluster_UserMaster.

func NewCluster_UserMaster_List 

func NewCluster_UserMaster_List(s *capnp.Segment, sz int32) (Cluster_UserMaster_List, error)

NewCluster_UserMaster creates a new list of Cluster_UserMaster.

type Cluster_UserMaster_Server 

type Cluster_UserMaster_Server interface {
	AvailableModels(context.Context, Cluster_UserMaster_availableModels) error

	Info(context.Context, common.Identifiable_info) error
}

A Cluster_UserMaster_Server is a Cluster_UserMaster with a local implementation.

type Cluster_UserMaster_availableModels 

type Cluster_UserMaster_availableModels struct {
	*server.Call
}

Cluster_UserMaster_availableModels holds the state for a server call to Cluster_UserMaster.availableModels. See server.Call for documentation.

func (Cluster_UserMaster_availableModels) AllocResults 

func (c Cluster_UserMaster_availableModels) AllocResults() (Cluster_UserMaster_availableModels_Results, error)

AllocResults allocates the results struct.

func (Cluster_UserMaster_availableModels) Args 

func (c Cluster_UserMaster_availableModels) Args() Cluster_UserMaster_availableModels_Params

Args returns the call's arguments.

type Cluster_UserMaster_availableModels_Params 

type Cluster_UserMaster_availableModels_Params capnp.Struct

func NewCluster_UserMaster_availableModels_Params 

func NewCluster_UserMaster_availableModels_Params(s *capnp.Segment) (Cluster_UserMaster_availableModels_Params, error)

func NewRootCluster_UserMaster_availableModels_Params 

func NewRootCluster_UserMaster_availableModels_Params(s *capnp.Segment) (Cluster_UserMaster_availableModels_Params, error)

func ReadRootCluster_UserMaster_availableModels_Params 

func ReadRootCluster_UserMaster_availableModels_Params(msg *capnp.Message) (Cluster_UserMaster_availableModels_Params, error)

func (Cluster_UserMaster_availableModels_Params) DecodeFromPtr 

func (Cluster_UserMaster_availableModels_Params) DecodeFromPtr(p capnp.Ptr) Cluster_UserMaster_availableModels_Params

func (Cluster_UserMaster_availableModels_Params) EncodeAsPtr 

func (s Cluster_UserMaster_availableModels_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_UserMaster_availableModels_Params) IsValid 

func (s Cluster_UserMaster_availableModels_Params) IsValid() bool

func (Cluster_UserMaster_availableModels_Params) Message 

func (s Cluster_UserMaster_availableModels_Params) Message() *capnp.Message

func (Cluster_UserMaster_availableModels_Params) Segment 

func (s Cluster_UserMaster_availableModels_Params) Segment() *capnp.Segment

func (Cluster_UserMaster_availableModels_Params) String 

func (s Cluster_UserMaster_availableModels_Params) String() string

func (Cluster_UserMaster_availableModels_Params) ToPtr 

func (s Cluster_UserMaster_availableModels_Params) ToPtr() capnp.Ptr

type Cluster_UserMaster_availableModels_Params_Future 

type Cluster_UserMaster_availableModels_Params_Future struct{ *capnp.Future }

Cluster_UserMaster_availableModels_Params_Future is a wrapper for a Cluster_UserMaster_availableModels_Params promised by a client call.

func (Cluster_UserMaster_availableModels_Params_Future) Struct 

func (f Cluster_UserMaster_availableModels_Params_Future) Struct() (Cluster_UserMaster_availableModels_Params, error)

type Cluster_UserMaster_availableModels_Params_List 

type Cluster_UserMaster_availableModels_Params_List = capnp.StructList[Cluster_UserMaster_availableModels_Params]

Cluster_UserMaster_availableModels_Params_List is a list of Cluster_UserMaster_availableModels_Params.

func NewCluster_UserMaster_availableModels_Params_List 

func NewCluster_UserMaster_availableModels_Params_List(s *capnp.Segment, sz int32) (Cluster_UserMaster_availableModels_Params_List, error)

NewCluster_UserMaster_availableModels_Params creates a new list of Cluster_UserMaster_availableModels_Params.

type Cluster_UserMaster_availableModels_Results 

type Cluster_UserMaster_availableModels_Results capnp.Struct

func NewCluster_UserMaster_availableModels_Results 

func NewCluster_UserMaster_availableModels_Results(s *capnp.Segment) (Cluster_UserMaster_availableModels_Results, error)

func NewRootCluster_UserMaster_availableModels_Results 

func NewRootCluster_UserMaster_availableModels_Results(s *capnp.Segment) (Cluster_UserMaster_availableModels_Results, error)

func ReadRootCluster_UserMaster_availableModels_Results 

func ReadRootCluster_UserMaster_availableModels_Results(msg *capnp.Message) (Cluster_UserMaster_availableModels_Results, error)

func (Cluster_UserMaster_availableModels_Results) DecodeFromPtr 

func (Cluster_UserMaster_availableModels_Results) DecodeFromPtr(p capnp.Ptr) Cluster_UserMaster_availableModels_Results

func (Cluster_UserMaster_availableModels_Results) EncodeAsPtr 

func (s Cluster_UserMaster_availableModels_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_UserMaster_availableModels_Results) Factories 

func (s Cluster_UserMaster_availableModels_Results) Factories() (Cluster_ModelInstanceFactory_List, error)

func (Cluster_UserMaster_availableModels_Results) HasFactories 

func (s Cluster_UserMaster_availableModels_Results) HasFactories() bool

func (Cluster_UserMaster_availableModels_Results) IsValid 

func (s Cluster_UserMaster_availableModels_Results) IsValid() bool

func (Cluster_UserMaster_availableModels_Results) Message 

func (s Cluster_UserMaster_availableModels_Results) Message() *capnp.Message

func (Cluster_UserMaster_availableModels_Results) NewFactories 

func (s Cluster_UserMaster_availableModels_Results) NewFactories(n int32) (Cluster_ModelInstanceFactory_List, error)

NewFactories sets the factories field to a newly allocated Cluster_ModelInstanceFactory_List, preferring placement in s's segment.

func (Cluster_UserMaster_availableModels_Results) Segment 

func (s Cluster_UserMaster_availableModels_Results) Segment() *capnp.Segment

func (Cluster_UserMaster_availableModels_Results) SetFactories 

func (s Cluster_UserMaster_availableModels_Results) SetFactories(v Cluster_ModelInstanceFactory_List) error

func (Cluster_UserMaster_availableModels_Results) String 

func (s Cluster_UserMaster_availableModels_Results) String() string

func (Cluster_UserMaster_availableModels_Results) ToPtr 

func (s Cluster_UserMaster_availableModels_Results) ToPtr() capnp.Ptr

type Cluster_UserMaster_availableModels_Results_Future 

type Cluster_UserMaster_availableModels_Results_Future struct{ *capnp.Future }

Cluster_UserMaster_availableModels_Results_Future is a wrapper for a Cluster_UserMaster_availableModels_Results promised by a client call.

func (Cluster_UserMaster_availableModels_Results_Future) Struct 

func (f Cluster_UserMaster_availableModels_Results_Future) Struct() (Cluster_UserMaster_availableModels_Results, error)

type Cluster_UserMaster_availableModels_Results_List 

type Cluster_UserMaster_availableModels_Results_List = capnp.StructList[Cluster_UserMaster_availableModels_Results]

Cluster_UserMaster_availableModels_Results_List is a list of Cluster_UserMaster_availableModels_Results.

func NewCluster_UserMaster_availableModels_Results_List 

func NewCluster_UserMaster_availableModels_Results_List(s *capnp.Segment, sz int32) (Cluster_UserMaster_availableModels_Results_List, error)

NewCluster_UserMaster_availableModels_Results creates a new list of Cluster_UserMaster_availableModels_Results.

type Cluster_ValueHolder 

type Cluster_ValueHolder capnp.Client

func Cluster_ValueHolder_ServerToClient 

func Cluster_ValueHolder_ServerToClient(s Cluster_ValueHolder_Server) Cluster_ValueHolder

Cluster_ValueHolder_ServerToClient creates a new Client from an implementation of Cluster_ValueHolder_Server. The caller is responsible for calling Release on the returned Client.

func (Cluster_ValueHolder) AddRef 

func (c Cluster_ValueHolder) AddRef() Cluster_ValueHolder

AddRef creates a new Client that refers to the same capability as c. If c is nil or has resolved to null, then AddRef returns nil.

func (Cluster_ValueHolder) DecodeFromPtr 

func (Cluster_ValueHolder) DecodeFromPtr(p capnp.Ptr) Cluster_ValueHolder

func (Cluster_ValueHolder) EncodeAsPtr 

func (c Cluster_ValueHolder) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_ValueHolder) GetFlowLimiter 

func (c Cluster_ValueHolder) GetFlowLimiter() fc.FlowLimiter

Get the current flowcontrol.FlowLimiter used to manage flow control for this client.

func (Cluster_ValueHolder) IsSame 

func (c Cluster_ValueHolder) IsSame(other Cluster_ValueHolder) bool

IsSame reports whether c and other refer to a capability created by the same call to NewClient. This can return false negatives if c or other are not fully resolved: use Resolve if this is an issue. If either c or other are released, then IsSame panics.

func (Cluster_ValueHolder) IsValid 

func (c Cluster_ValueHolder) IsValid() bool

IsValid reports whether c is a valid reference to a capability. A reference is invalid if it is nil, has resolved to null, or has been released.

func (Cluster_ValueHolder) Release 

func (c Cluster_ValueHolder) Release()

Release releases a capability reference. If this is the last reference to the capability, then the underlying resources associated with the capability will be released.

Release will panic if c has already been released, but not if c is nil or resolved to null.

func (Cluster_ValueHolder) ReleaseValue 

func (c Cluster_ValueHolder) ReleaseValue(ctx context.Context, params func(Cluster_ValueHolder_releaseValue_Params) error) (Cluster_ValueHolder_releaseValue_Results_Future, capnp.ReleaseFunc)

func (Cluster_ValueHolder) Resolve 

func (c Cluster_ValueHolder) Resolve(ctx context.Context) error

Resolve blocks until the capability is fully resolved or the Context expires.

func (Cluster_ValueHolder) SetFlowLimiter 

func (c Cluster_ValueHolder) SetFlowLimiter(lim fc.FlowLimiter)

Update the flowcontrol.FlowLimiter used to manage flow control for this client. This affects all future calls, but not calls already waiting to send. Passing nil sets the value to flowcontrol.NopLimiter, which is also the default.

func (Cluster_ValueHolder) String 

func (c Cluster_ValueHolder) String() string

String returns a string that identifies this capability for debugging purposes. Its format should not be depended on: in particular, it should not be used to compare clients. Use IsSame to compare clients for equality.

func (Cluster_ValueHolder) Value 

func (c Cluster_ValueHolder) Value(ctx context.Context, params func(Cluster_ValueHolder_value_Params) error) (Cluster_ValueHolder_value_Results_Future, capnp.ReleaseFunc)

func (Cluster_ValueHolder) WaitStreaming 

func (c Cluster_ValueHolder) WaitStreaming() error

type Cluster_ValueHolder_List 

type Cluster_ValueHolder_List = capnp.CapList[Cluster_ValueHolder]

Cluster_ValueHolder_List is a list of Cluster_ValueHolder.

func NewCluster_ValueHolder_List 

func NewCluster_ValueHolder_List(s *capnp.Segment, sz int32) (Cluster_ValueHolder_List, error)

NewCluster_ValueHolder creates a new list of Cluster_ValueHolder.

type Cluster_ValueHolder_Server 

type Cluster_ValueHolder_Server interface {
	Value(context.Context, Cluster_ValueHolder_value) error

	ReleaseValue(context.Context, Cluster_ValueHolder_releaseValue) error
}

A Cluster_ValueHolder_Server is a Cluster_ValueHolder with a local implementation.

type Cluster_ValueHolder_releaseValue 

type Cluster_ValueHolder_releaseValue struct {
	*server.Call
}

Cluster_ValueHolder_releaseValue holds the state for a server call to Cluster_ValueHolder.releaseValue. See server.Call for documentation.

func (Cluster_ValueHolder_releaseValue) AllocResults 

func (c Cluster_ValueHolder_releaseValue) AllocResults() (Cluster_ValueHolder_releaseValue_Results, error)

AllocResults allocates the results struct.

func (Cluster_ValueHolder_releaseValue) Args 

func (c Cluster_ValueHolder_releaseValue) Args() Cluster_ValueHolder_releaseValue_Params

Args returns the call's arguments.

type Cluster_ValueHolder_releaseValue_Params 

type Cluster_ValueHolder_releaseValue_Params capnp.Struct

func NewCluster_ValueHolder_releaseValue_Params 

func NewCluster_ValueHolder_releaseValue_Params(s *capnp.Segment) (Cluster_ValueHolder_releaseValue_Params, error)

func NewRootCluster_ValueHolder_releaseValue_Params 

func NewRootCluster_ValueHolder_releaseValue_Params(s *capnp.Segment) (Cluster_ValueHolder_releaseValue_Params, error)

func ReadRootCluster_ValueHolder_releaseValue_Params 

func ReadRootCluster_ValueHolder_releaseValue_Params(msg *capnp.Message) (Cluster_ValueHolder_releaseValue_Params, error)

func (Cluster_ValueHolder_releaseValue_Params) DecodeFromPtr 

func (Cluster_ValueHolder_releaseValue_Params) DecodeFromPtr(p capnp.Ptr) Cluster_ValueHolder_releaseValue_Params

func (Cluster_ValueHolder_releaseValue_Params) EncodeAsPtr 

func (s Cluster_ValueHolder_releaseValue_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_ValueHolder_releaseValue_Params) IsValid 

func (s Cluster_ValueHolder_releaseValue_Params) IsValid() bool

func (Cluster_ValueHolder_releaseValue_Params) Message 

func (s Cluster_ValueHolder_releaseValue_Params) Message() *capnp.Message

func (Cluster_ValueHolder_releaseValue_Params) Segment 

func (s Cluster_ValueHolder_releaseValue_Params) Segment() *capnp.Segment

func (Cluster_ValueHolder_releaseValue_Params) String 

func (s Cluster_ValueHolder_releaseValue_Params) String() string

func (Cluster_ValueHolder_releaseValue_Params) ToPtr 

func (s Cluster_ValueHolder_releaseValue_Params) ToPtr() capnp.Ptr

type Cluster_ValueHolder_releaseValue_Params_Future 

type Cluster_ValueHolder_releaseValue_Params_Future struct{ *capnp.Future }

Cluster_ValueHolder_releaseValue_Params_Future is a wrapper for a Cluster_ValueHolder_releaseValue_Params promised by a client call.

func (Cluster_ValueHolder_releaseValue_Params_Future) Struct 

func (f Cluster_ValueHolder_releaseValue_Params_Future) Struct() (Cluster_ValueHolder_releaseValue_Params, error)

type Cluster_ValueHolder_releaseValue_Params_List 

type Cluster_ValueHolder_releaseValue_Params_List = capnp.StructList[Cluster_ValueHolder_releaseValue_Params]

Cluster_ValueHolder_releaseValue_Params_List is a list of Cluster_ValueHolder_releaseValue_Params.

func NewCluster_ValueHolder_releaseValue_Params_List 

func NewCluster_ValueHolder_releaseValue_Params_List(s *capnp.Segment, sz int32) (Cluster_ValueHolder_releaseValue_Params_List, error)

NewCluster_ValueHolder_releaseValue_Params creates a new list of Cluster_ValueHolder_releaseValue_Params.

type Cluster_ValueHolder_releaseValue_Results 

type Cluster_ValueHolder_releaseValue_Results capnp.Struct

func NewCluster_ValueHolder_releaseValue_Results 

func NewCluster_ValueHolder_releaseValue_Results(s *capnp.Segment) (Cluster_ValueHolder_releaseValue_Results, error)

func NewRootCluster_ValueHolder_releaseValue_Results 

func NewRootCluster_ValueHolder_releaseValue_Results(s *capnp.Segment) (Cluster_ValueHolder_releaseValue_Results, error)

func ReadRootCluster_ValueHolder_releaseValue_Results 

func ReadRootCluster_ValueHolder_releaseValue_Results(msg *capnp.Message) (Cluster_ValueHolder_releaseValue_Results, error)

func (Cluster_ValueHolder_releaseValue_Results) DecodeFromPtr 

func (Cluster_ValueHolder_releaseValue_Results) DecodeFromPtr(p capnp.Ptr) Cluster_ValueHolder_releaseValue_Results

func (Cluster_ValueHolder_releaseValue_Results) EncodeAsPtr 

func (s Cluster_ValueHolder_releaseValue_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_ValueHolder_releaseValue_Results) IsValid 

func (s Cluster_ValueHolder_releaseValue_Results) IsValid() bool

func (Cluster_ValueHolder_releaseValue_Results) Message 

func (s Cluster_ValueHolder_releaseValue_Results) Message() *capnp.Message

func (Cluster_ValueHolder_releaseValue_Results) Segment 

func (s Cluster_ValueHolder_releaseValue_Results) Segment() *capnp.Segment

func (Cluster_ValueHolder_releaseValue_Results) String 

func (s Cluster_ValueHolder_releaseValue_Results) String() string

func (Cluster_ValueHolder_releaseValue_Results) ToPtr 

func (s Cluster_ValueHolder_releaseValue_Results) ToPtr() capnp.Ptr

type Cluster_ValueHolder_releaseValue_Results_Future 

type Cluster_ValueHolder_releaseValue_Results_Future struct{ *capnp.Future }

Cluster_ValueHolder_releaseValue_Results_Future is a wrapper for a Cluster_ValueHolder_releaseValue_Results promised by a client call.

func (Cluster_ValueHolder_releaseValue_Results_Future) Struct 

func (f Cluster_ValueHolder_releaseValue_Results_Future) Struct() (Cluster_ValueHolder_releaseValue_Results, error)

type Cluster_ValueHolder_releaseValue_Results_List 

type Cluster_ValueHolder_releaseValue_Results_List = capnp.StructList[Cluster_ValueHolder_releaseValue_Results]

Cluster_ValueHolder_releaseValue_Results_List is a list of Cluster_ValueHolder_releaseValue_Results.

func NewCluster_ValueHolder_releaseValue_Results_List 

func NewCluster_ValueHolder_releaseValue_Results_List(s *capnp.Segment, sz int32) (Cluster_ValueHolder_releaseValue_Results_List, error)

NewCluster_ValueHolder_releaseValue_Results creates a new list of Cluster_ValueHolder_releaseValue_Results.

type Cluster_ValueHolder_value 

type Cluster_ValueHolder_value struct {
	*server.Call
}

Cluster_ValueHolder_value holds the state for a server call to Cluster_ValueHolder.value. See server.Call for documentation.

func (Cluster_ValueHolder_value) AllocResults 

func (c Cluster_ValueHolder_value) AllocResults() (Cluster_ValueHolder_value_Results, error)

AllocResults allocates the results struct.

func (Cluster_ValueHolder_value) Args 

func (c Cluster_ValueHolder_value) Args() Cluster_ValueHolder_value_Params

Args returns the call's arguments.

type Cluster_ValueHolder_value_Params 

type Cluster_ValueHolder_value_Params capnp.Struct

func NewCluster_ValueHolder_value_Params 

func NewCluster_ValueHolder_value_Params(s *capnp.Segment) (Cluster_ValueHolder_value_Params, error)

func NewRootCluster_ValueHolder_value_Params 

func NewRootCluster_ValueHolder_value_Params(s *capnp.Segment) (Cluster_ValueHolder_value_Params, error)

func ReadRootCluster_ValueHolder_value_Params 

func ReadRootCluster_ValueHolder_value_Params(msg *capnp.Message) (Cluster_ValueHolder_value_Params, error)

func (Cluster_ValueHolder_value_Params) DecodeFromPtr 

func (Cluster_ValueHolder_value_Params) DecodeFromPtr(p capnp.Ptr) Cluster_ValueHolder_value_Params

func (Cluster_ValueHolder_value_Params) EncodeAsPtr 

func (s Cluster_ValueHolder_value_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_ValueHolder_value_Params) IsValid 

func (s Cluster_ValueHolder_value_Params) IsValid() bool

func (Cluster_ValueHolder_value_Params) Message 

func (s Cluster_ValueHolder_value_Params) Message() *capnp.Message

func (Cluster_ValueHolder_value_Params) Segment 

func (s Cluster_ValueHolder_value_Params) Segment() *capnp.Segment

func (Cluster_ValueHolder_value_Params) String 

func (s Cluster_ValueHolder_value_Params) String() string

func (Cluster_ValueHolder_value_Params) ToPtr 

func (s Cluster_ValueHolder_value_Params) ToPtr() capnp.Ptr

type Cluster_ValueHolder_value_Params_Future 

type Cluster_ValueHolder_value_Params_Future struct{ *capnp.Future }

Cluster_ValueHolder_value_Params_Future is a wrapper for a Cluster_ValueHolder_value_Params promised by a client call.

func (Cluster_ValueHolder_value_Params_Future) Struct 

func (f Cluster_ValueHolder_value_Params_Future) Struct() (Cluster_ValueHolder_value_Params, error)

type Cluster_ValueHolder_value_Params_List 

type Cluster_ValueHolder_value_Params_List = capnp.StructList[Cluster_ValueHolder_value_Params]

Cluster_ValueHolder_value_Params_List is a list of Cluster_ValueHolder_value_Params.

func NewCluster_ValueHolder_value_Params_List 

func NewCluster_ValueHolder_value_Params_List(s *capnp.Segment, sz int32) (Cluster_ValueHolder_value_Params_List, error)

NewCluster_ValueHolder_value_Params creates a new list of Cluster_ValueHolder_value_Params.

type Cluster_ValueHolder_value_Results 

type Cluster_ValueHolder_value_Results capnp.Struct

func NewCluster_ValueHolder_value_Results 

func NewCluster_ValueHolder_value_Results(s *capnp.Segment) (Cluster_ValueHolder_value_Results, error)

func NewRootCluster_ValueHolder_value_Results 

func NewRootCluster_ValueHolder_value_Results(s *capnp.Segment) (Cluster_ValueHolder_value_Results, error)

func ReadRootCluster_ValueHolder_value_Results 

func ReadRootCluster_ValueHolder_value_Results(msg *capnp.Message) (Cluster_ValueHolder_value_Results, error)

func (Cluster_ValueHolder_value_Results) DecodeFromPtr 

func (Cluster_ValueHolder_value_Results) DecodeFromPtr(p capnp.Ptr) Cluster_ValueHolder_value_Results

func (Cluster_ValueHolder_value_Results) EncodeAsPtr 

func (s Cluster_ValueHolder_value_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_ValueHolder_value_Results) HasVal 

func (s Cluster_ValueHolder_value_Results) HasVal() bool

func (Cluster_ValueHolder_value_Results) IsValid 

func (s Cluster_ValueHolder_value_Results) IsValid() bool

func (Cluster_ValueHolder_value_Results) Message 

func (s Cluster_ValueHolder_value_Results) Message() *capnp.Message

func (Cluster_ValueHolder_value_Results) Segment 

func (s Cluster_ValueHolder_value_Results) Segment() *capnp.Segment

func (Cluster_ValueHolder_value_Results) SetVal 

func (s Cluster_ValueHolder_value_Results) SetVal(v capnp.Ptr) error

func (Cluster_ValueHolder_value_Results) String 

func (s Cluster_ValueHolder_value_Results) String() string

func (Cluster_ValueHolder_value_Results) ToPtr 

func (s Cluster_ValueHolder_value_Results) ToPtr() capnp.Ptr

func (Cluster_ValueHolder_value_Results) Val 

func (s Cluster_ValueHolder_value_Results) Val() (capnp.Ptr, error)

type Cluster_ValueHolder_value_Results_Future 

type Cluster_ValueHolder_value_Results_Future struct{ *capnp.Future }

Cluster_ValueHolder_value_Results_Future is a wrapper for a Cluster_ValueHolder_value_Results promised by a client call.

func (Cluster_ValueHolder_value_Results_Future) Struct 

func (f Cluster_ValueHolder_value_Results_Future) Struct() (Cluster_ValueHolder_value_Results, error)

func (Cluster_ValueHolder_value_Results_Future) Val 

func (p Cluster_ValueHolder_value_Results_Future) Val() *capnp.Future

type Cluster_ValueHolder_value_Results_List 

type Cluster_ValueHolder_value_Results_List = capnp.StructList[Cluster_ValueHolder_value_Results]

Cluster_ValueHolder_value_Results_List is a list of Cluster_ValueHolder_value_Results.

func NewCluster_ValueHolder_value_Results_List 

func NewCluster_ValueHolder_value_Results_List(s *capnp.Segment, sz int32) (Cluster_ValueHolder_value_Results_List, error)

NewCluster_ValueHolder_value_Results creates a new list of Cluster_ValueHolder_value_Results.

type Cluster_ZmqPipelineAddresses 

type Cluster_ZmqPipelineAddresses capnp.Struct

func NewCluster_ZmqPipelineAddresses 

func NewCluster_ZmqPipelineAddresses(s *capnp.Segment) (Cluster_ZmqPipelineAddresses, error)

func NewRootCluster_ZmqPipelineAddresses 

func NewRootCluster_ZmqPipelineAddresses(s *capnp.Segment) (Cluster_ZmqPipelineAddresses, error)

func ReadRootCluster_ZmqPipelineAddresses 

func ReadRootCluster_ZmqPipelineAddresses(msg *capnp.Message) (Cluster_ZmqPipelineAddresses, error)

func (Cluster_ZmqPipelineAddresses) DecodeFromPtr 

func (Cluster_ZmqPipelineAddresses) DecodeFromPtr(p capnp.Ptr) Cluster_ZmqPipelineAddresses

func (Cluster_ZmqPipelineAddresses) EncodeAsPtr 

func (s Cluster_ZmqPipelineAddresses) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Cluster_ZmqPipelineAddresses) HasInput 

func (s Cluster_ZmqPipelineAddresses) HasInput() bool

func (Cluster_ZmqPipelineAddresses) HasOutput 

func (s Cluster_ZmqPipelineAddresses) HasOutput() bool

func (Cluster_ZmqPipelineAddresses) Input 

func (s Cluster_ZmqPipelineAddresses) Input() (string, error)

func (Cluster_ZmqPipelineAddresses) InputBytes 

func (s Cluster_ZmqPipelineAddresses) InputBytes() ([]byte, error)

func (Cluster_ZmqPipelineAddresses) IsValid 

func (s Cluster_ZmqPipelineAddresses) IsValid() bool

func (Cluster_ZmqPipelineAddresses) Message 

func (s Cluster_ZmqPipelineAddresses) Message() *capnp.Message

func (Cluster_ZmqPipelineAddresses) Output 

func (s Cluster_ZmqPipelineAddresses) Output() (string, error)

func (Cluster_ZmqPipelineAddresses) OutputBytes 

func (s Cluster_ZmqPipelineAddresses) OutputBytes() ([]byte, error)

func (Cluster_ZmqPipelineAddresses) Segment 

func (s Cluster_ZmqPipelineAddresses) Segment() *capnp.Segment

func (Cluster_ZmqPipelineAddresses) SetInput 

func (s Cluster_ZmqPipelineAddresses) SetInput(v string) error

func (Cluster_ZmqPipelineAddresses) SetOutput 

func (s Cluster_ZmqPipelineAddresses) SetOutput(v string) error

func (Cluster_ZmqPipelineAddresses) String 

func (s Cluster_ZmqPipelineAddresses) String() string

func (Cluster_ZmqPipelineAddresses) ToPtr 

func (s Cluster_ZmqPipelineAddresses) ToPtr() capnp.Ptr

type Cluster_ZmqPipelineAddresses_Future 

type Cluster_ZmqPipelineAddresses_Future struct{ *capnp.Future }

Cluster_ZmqPipelineAddresses_Future is a wrapper for a Cluster_ZmqPipelineAddresses promised by a client call.

func (Cluster_ZmqPipelineAddresses_Future) Struct 

func (f Cluster_ZmqPipelineAddresses_Future) Struct() (Cluster_ZmqPipelineAddresses, error)

type Cluster_ZmqPipelineAddresses_List 

type Cluster_ZmqPipelineAddresses_List = capnp.StructList[Cluster_ZmqPipelineAddresses]

Cluster_ZmqPipelineAddresses_List is a list of Cluster_ZmqPipelineAddresses.

func NewCluster_ZmqPipelineAddresses_List 

func NewCluster_ZmqPipelineAddresses_List(s *capnp.Segment, sz int32) (Cluster_ZmqPipelineAddresses_List, error)

NewCluster_ZmqPipelineAddresses creates a new list of Cluster_ZmqPipelineAddresses.

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.