persistence

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: 8 Imported by: 12

Documentation

Index

Constants

View Source 
const Address_TypeID = 0xfb47810671a05b0d

Address_TypeID is the unique identifier for the type Address.

View Source 
const HostPortResolver_Registrar_Heartbeat_TypeID = 0x87de92d2d68df26f

HostPortResolver_Registrar_Heartbeat_TypeID is the unique identifier for the type HostPortResolver_Registrar_Heartbeat.

View Source 
const HostPortResolver_Registrar_Heartbeat_beat_Params_TypeID = 0xebff70497e0ba555

HostPortResolver_Registrar_Heartbeat_beat_Params_TypeID is the unique identifier for the type HostPortResolver_Registrar_Heartbeat_beat_Params.

View Source 
const HostPortResolver_Registrar_Heartbeat_beat_Results_TypeID = 0x9510c22fa544a65e

HostPortResolver_Registrar_Heartbeat_beat_Results_TypeID is the unique identifier for the type HostPortResolver_Registrar_Heartbeat_beat_Results.

View Source 
const HostPortResolver_Registrar_RegisterParams_TypeID = 0xbf018f62ff460d0f

HostPortResolver_Registrar_RegisterParams_TypeID is the unique identifier for the type HostPortResolver_Registrar_RegisterParams.

View Source 
const HostPortResolver_Registrar_TypeID = 0xb0caf775704690b2

HostPortResolver_Registrar_TypeID is the unique identifier for the type HostPortResolver_Registrar.

View Source 
const HostPortResolver_Registrar_register_Results_TypeID = 0xfafc816633f98bb9

HostPortResolver_Registrar_register_Results_TypeID is the unique identifier for the type HostPortResolver_Registrar_register_Results.

View Source 
const HostPortResolver_ResolveIdent_Params_TypeID = 0xe6f8966f0f2cbb33

HostPortResolver_ResolveIdent_Params_TypeID is the unique identifier for the type HostPortResolver_ResolveIdent_Params.

View Source 
const HostPortResolver_ResolveIdent_Results_TypeID = 0xfc185f518d220b8c

HostPortResolver_ResolveIdent_Results_TypeID is the unique identifier for the type HostPortResolver_ResolveIdent_Results.

View Source 
const HostPortResolver_TypeID = 0xaa8d91fab6d01d9f

HostPortResolver_TypeID is the unique identifier for the type HostPortResolver.

View Source 
const Persistent_ReleaseSturdyRef_TypeID = 0x8f700f81169f2e52

Persistent_ReleaseSturdyRef_TypeID is the unique identifier for the type Persistent_ReleaseSturdyRef.

View Source 
const Persistent_ReleaseSturdyRef_releaseSR_Params_TypeID = 0xa4db8c20d9807c15

Persistent_ReleaseSturdyRef_releaseSR_Params_TypeID is the unique identifier for the type Persistent_ReleaseSturdyRef_releaseSR_Params.

View Source 
const Persistent_ReleaseSturdyRef_releaseSR_Results_TypeID = 0x932d6ee32410e853

Persistent_ReleaseSturdyRef_releaseSR_Results_TypeID is the unique identifier for the type Persistent_ReleaseSturdyRef_releaseSR_Results.

View Source 
const Persistent_SaveParams_TypeID = 0xd5e0aac4225e0343

Persistent_SaveParams_TypeID is the unique identifier for the type Persistent_SaveParams.

View Source 
const Persistent_SaveResults_TypeID = 0xdc5bd1ef982cec13

Persistent_SaveResults_TypeID is the unique identifier for the type Persistent_SaveResults.

View Source 
const Persistent_TypeID = 0xc1a7daa0dc36cb65

Persistent_TypeID is the unique identifier for the type Persistent.

View Source 
const Restorer_RestoreParams_TypeID = 0xc541e5764a37d73a

Restorer_RestoreParams_TypeID is the unique identifier for the type Restorer_RestoreParams.

View Source 
const Restorer_TypeID = 0x9fb6218427d92e3c

Restorer_TypeID is the unique identifier for the type Restorer.

View Source 
const Restorer_restore_Results_TypeID = 0xda966d1d252e4d25

Restorer_restore_Results_TypeID is the unique identifier for the type Restorer_restore_Results.

View Source 
const SturdyRef_Owner_TypeID = 0xfdd799ed60c87723

SturdyRef_Owner_TypeID is the unique identifier for the type SturdyRef_Owner.

View Source 
const SturdyRef_Token_TypeID = 0xfa412bb47f11b488

SturdyRef_Token_TypeID is the unique identifier for the type SturdyRef_Token.

View Source 
const SturdyRef_TypeID = 0x886d68271d83de4d

SturdyRef_TypeID is the unique identifier for the type SturdyRef.

View Source 
const VatId_TypeID = 0xe10a5d74d58bd18d

VatId_TypeID is the unique identifier for the type VatId.

View Source 
const VatPath_TypeID = 0xd9eccdf2dbc48087

VatPath_TypeID is the unique identifier for the type VatPath.

Variables

This section is empty.

Functions

func HostPortResolver_Methods 

func HostPortResolver_Methods(methods []server.Method, s HostPortResolver_Server) []server.Method

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

func HostPortResolver_NewServer 

func HostPortResolver_NewServer(s HostPortResolver_Server) *server.Server

HostPortResolver_NewServer creates a new Server from an implementation of HostPortResolver_Server.

func HostPortResolver_Registrar_Heartbeat_Methods 

func HostPortResolver_Registrar_Heartbeat_Methods(methods []server.Method, s HostPortResolver_Registrar_Heartbeat_Server) []server.Method

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

func HostPortResolver_Registrar_Heartbeat_NewServer 

func HostPortResolver_Registrar_Heartbeat_NewServer(s HostPortResolver_Registrar_Heartbeat_Server) *server.Server

HostPortResolver_Registrar_Heartbeat_NewServer creates a new Server from an implementation of HostPortResolver_Registrar_Heartbeat_Server.

func HostPortResolver_Registrar_Methods 

func HostPortResolver_Registrar_Methods(methods []server.Method, s HostPortResolver_Registrar_Server) []server.Method

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

func HostPortResolver_Registrar_NewServer 

func HostPortResolver_Registrar_NewServer(s HostPortResolver_Registrar_Server) *server.Server

HostPortResolver_Registrar_NewServer creates a new Server from an implementation of HostPortResolver_Registrar_Server.

func Persistent_Methods 

func Persistent_Methods(methods []server.Method, s Persistent_Server) []server.Method

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

func Persistent_NewServer 

func Persistent_NewServer(s Persistent_Server) *server.Server

Persistent_NewServer creates a new Server from an implementation of Persistent_Server.

func Persistent_ReleaseSturdyRef_Methods 

func Persistent_ReleaseSturdyRef_Methods(methods []server.Method, s Persistent_ReleaseSturdyRef_Server) []server.Method

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

func Persistent_ReleaseSturdyRef_NewServer 

func Persistent_ReleaseSturdyRef_NewServer(s Persistent_ReleaseSturdyRef_Server) *server.Server

Persistent_ReleaseSturdyRef_NewServer creates a new Server from an implementation of Persistent_ReleaseSturdyRef_Server.

func RegisterSchema 

func RegisterSchema(reg *schemas.Registry)

func Restorer_Methods 

func Restorer_Methods(methods []server.Method, s Restorer_Server) []server.Method

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

func Restorer_NewServer 

func Restorer_NewServer(s Restorer_Server) *server.Server

Restorer_NewServer creates a new Server from an implementation of Restorer_Server.

Types

type Address 

type Address capnp.Struct

func NewAddress 

func NewAddress(s *capnp.Segment) (Address, error)

func NewRootAddress 

func NewRootAddress(s *capnp.Segment) (Address, error)

func ReadRootAddress 

func ReadRootAddress(msg *capnp.Message) (Address, error)

func (Address) DecodeFromPtr 

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

func (Address) EncodeAsPtr 

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

func (Address) HasHost 

func (s Address) HasHost() bool

func (Address) Host 

func (s Address) Host() (string, error)

func (Address) HostBytes 

func (s Address) HostBytes() ([]byte, error)

func (Address) Ip6 

func (s Address) Ip6() Address_ip6

func (Address) IsValid 

func (s Address) IsValid() bool

func (Address) Message 

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

func (Address) Port 

func (s Address) Port() uint16

func (Address) Segment 

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

func (Address) SetHost 

func (s Address) SetHost(v string) error

func (Address) SetIp6 

func (s Address) SetIp6()

func (Address) SetPort 

func (s Address) SetPort(v uint16)

func (Address) String 

func (s Address) String() string

func (Address) ToPtr 

func (s Address) ToPtr() capnp.Ptr

func (Address) Which 

func (s Address) Which() Address_Which

type Address_Future 

type Address_Future struct{ *capnp.Future }

Address_Future is a wrapper for a Address promised by a client call.

func (Address_Future) Ip6 

func (p Address_Future) Ip6() Address_ip6_Future

func (Address_Future) Struct 

func (f Address_Future) Struct() (Address, error)

type Address_List 

type Address_List = capnp.StructList[Address]

Address_List is a list of Address.

func NewAddress_List 

func NewAddress_List(s *capnp.Segment, sz int32) (Address_List, error)

NewAddress creates a new list of Address.

type Address_Which 

type Address_Which uint16
const (
	Address_Which_ip6  Address_Which = 0
	Address_Which_host Address_Which = 1
)

func (Address_Which) String 

func (w Address_Which) String() string

type Address_ip6 

type Address_ip6 Address

func (Address_ip6) IsValid 

func (s Address_ip6) IsValid() bool

func (Address_ip6) Lower64 

func (s Address_ip6) Lower64() uint64

func (Address_ip6) Message 

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

func (Address_ip6) Segment 

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

func (Address_ip6) SetLower64 

func (s Address_ip6) SetLower64(v uint64)

func (Address_ip6) SetUpper64 

func (s Address_ip6) SetUpper64(v uint64)

func (Address_ip6) Upper64 

func (s Address_ip6) Upper64() uint64

type Address_ip6_Future 

type Address_ip6_Future struct{ *capnp.Future }

Address_ip6_Future is a wrapper for a Address_ip6 promised by a client call.

func (Address_ip6_Future) Struct 

func (f Address_ip6_Future) Struct() (Address_ip6, error)

type HostPortResolver 

type HostPortResolver capnp.Client

func HostPortResolver_ServerToClient 

func HostPortResolver_ServerToClient(s HostPortResolver_Server) HostPortResolver

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

func (HostPortResolver) AddRef 

func (c HostPortResolver) AddRef() HostPortResolver

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 (HostPortResolver) DecodeFromPtr 

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

func (HostPortResolver) EncodeAsPtr 

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

func (HostPortResolver) GetFlowLimiter 

func (c HostPortResolver) GetFlowLimiter() fc.FlowLimiter

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

func (HostPortResolver) Info 

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

func (HostPortResolver) IsSame 

func (c HostPortResolver) IsSame(other HostPortResolver) 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 (HostPortResolver) IsValid 

func (c HostPortResolver) 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 (HostPortResolver) Release 

func (c HostPortResolver) 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 (HostPortResolver) Resolve 

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

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

func (HostPortResolver) ResolveIdent 

func (c HostPortResolver) ResolveIdent(ctx context.Context, params func(HostPortResolver_ResolveIdent_Params) error) (HostPortResolver_ResolveIdent_Results_Future, capnp.ReleaseFunc)

func (HostPortResolver) Restore 

func (c HostPortResolver) Restore(ctx context.Context, params func(Restorer_RestoreParams) error) (Restorer_restore_Results_Future, capnp.ReleaseFunc)

func (HostPortResolver) SetFlowLimiter 

func (c HostPortResolver) 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 (HostPortResolver) String 

func (c HostPortResolver) 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 (HostPortResolver) WaitStreaming 

func (c HostPortResolver) WaitStreaming() error

type HostPortResolver_List 

type HostPortResolver_List = capnp.CapList[HostPortResolver]

HostPortResolver_List is a list of HostPortResolver.

func NewHostPortResolver_List 

func NewHostPortResolver_List(s *capnp.Segment, sz int32) (HostPortResolver_List, error)

NewHostPortResolver creates a new list of HostPortResolver.

type HostPortResolver_Registrar 

type HostPortResolver_Registrar capnp.Client

func HostPortResolver_Registrar_ServerToClient 

func HostPortResolver_Registrar_ServerToClient(s HostPortResolver_Registrar_Server) HostPortResolver_Registrar

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

func (HostPortResolver_Registrar) AddRef 

func (c HostPortResolver_Registrar) AddRef() HostPortResolver_Registrar

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 (HostPortResolver_Registrar) DecodeFromPtr 

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

func (HostPortResolver_Registrar) EncodeAsPtr 

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

func (HostPortResolver_Registrar) GetFlowLimiter 

func (c HostPortResolver_Registrar) GetFlowLimiter() fc.FlowLimiter

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

func (HostPortResolver_Registrar) IsSame 

func (c HostPortResolver_Registrar) IsSame(other HostPortResolver_Registrar) 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 (HostPortResolver_Registrar) IsValid 

func (c HostPortResolver_Registrar) 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 (HostPortResolver_Registrar) Register 

func (c HostPortResolver_Registrar) Register(ctx context.Context, params func(HostPortResolver_Registrar_RegisterParams) error) (HostPortResolver_Registrar_register_Results_Future, capnp.ReleaseFunc)

func (HostPortResolver_Registrar) Release 

func (c HostPortResolver_Registrar) 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 (HostPortResolver_Registrar) Resolve 

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

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

func (HostPortResolver_Registrar) SetFlowLimiter 

func (c HostPortResolver_Registrar) 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 (HostPortResolver_Registrar) String 

func (c HostPortResolver_Registrar) 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 (HostPortResolver_Registrar) WaitStreaming 

func (c HostPortResolver_Registrar) WaitStreaming() error

type HostPortResolver_Registrar_Heartbeat 

type HostPortResolver_Registrar_Heartbeat capnp.Client

func HostPortResolver_Registrar_Heartbeat_ServerToClient 

func HostPortResolver_Registrar_Heartbeat_ServerToClient(s HostPortResolver_Registrar_Heartbeat_Server) HostPortResolver_Registrar_Heartbeat

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

func (HostPortResolver_Registrar_Heartbeat) AddRef 

func (c HostPortResolver_Registrar_Heartbeat) AddRef() HostPortResolver_Registrar_Heartbeat

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 (HostPortResolver_Registrar_Heartbeat) Beat 

func (c HostPortResolver_Registrar_Heartbeat) Beat(ctx context.Context, params func(HostPortResolver_Registrar_Heartbeat_beat_Params) error) (HostPortResolver_Registrar_Heartbeat_beat_Results_Future, capnp.ReleaseFunc)

func (HostPortResolver_Registrar_Heartbeat) DecodeFromPtr 

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

func (HostPortResolver_Registrar_Heartbeat) EncodeAsPtr 

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

func (HostPortResolver_Registrar_Heartbeat) GetFlowLimiter 

func (c HostPortResolver_Registrar_Heartbeat) GetFlowLimiter() fc.FlowLimiter

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

func (HostPortResolver_Registrar_Heartbeat) IsSame 

func (c HostPortResolver_Registrar_Heartbeat) IsSame(other HostPortResolver_Registrar_Heartbeat) 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 (HostPortResolver_Registrar_Heartbeat) IsValid 

func (c HostPortResolver_Registrar_Heartbeat) 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 (HostPortResolver_Registrar_Heartbeat) Release 

func (c HostPortResolver_Registrar_Heartbeat) 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 (HostPortResolver_Registrar_Heartbeat) Resolve 

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

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

func (HostPortResolver_Registrar_Heartbeat) SetFlowLimiter 

func (c HostPortResolver_Registrar_Heartbeat) 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 (HostPortResolver_Registrar_Heartbeat) String 

func (c HostPortResolver_Registrar_Heartbeat) 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 (HostPortResolver_Registrar_Heartbeat) WaitStreaming 

func (c HostPortResolver_Registrar_Heartbeat) WaitStreaming() error

type HostPortResolver_Registrar_Heartbeat_List 

type HostPortResolver_Registrar_Heartbeat_List = capnp.CapList[HostPortResolver_Registrar_Heartbeat]

HostPortResolver_Registrar_Heartbeat_List is a list of HostPortResolver_Registrar_Heartbeat.

func NewHostPortResolver_Registrar_Heartbeat_List 

func NewHostPortResolver_Registrar_Heartbeat_List(s *capnp.Segment, sz int32) (HostPortResolver_Registrar_Heartbeat_List, error)

NewHostPortResolver_Registrar_Heartbeat creates a new list of HostPortResolver_Registrar_Heartbeat.

type HostPortResolver_Registrar_Heartbeat_Server 

type HostPortResolver_Registrar_Heartbeat_Server interface {
	Beat(context.Context, HostPortResolver_Registrar_Heartbeat_beat) error
}

A HostPortResolver_Registrar_Heartbeat_Server is a HostPortResolver_Registrar_Heartbeat with a local implementation.

type HostPortResolver_Registrar_Heartbeat_beat 

type HostPortResolver_Registrar_Heartbeat_beat struct {
	*server.Call
}

HostPortResolver_Registrar_Heartbeat_beat holds the state for a server call to HostPortResolver_Registrar_Heartbeat.beat. See server.Call for documentation.

func (HostPortResolver_Registrar_Heartbeat_beat) AllocResults 

func (c HostPortResolver_Registrar_Heartbeat_beat) AllocResults() (HostPortResolver_Registrar_Heartbeat_beat_Results, error)

AllocResults allocates the results struct.

func (HostPortResolver_Registrar_Heartbeat_beat) Args 

func (c HostPortResolver_Registrar_Heartbeat_beat) Args() HostPortResolver_Registrar_Heartbeat_beat_Params

Args returns the call's arguments.

type HostPortResolver_Registrar_Heartbeat_beat_Params 

type HostPortResolver_Registrar_Heartbeat_beat_Params capnp.Struct

func NewHostPortResolver_Registrar_Heartbeat_beat_Params 

func NewHostPortResolver_Registrar_Heartbeat_beat_Params(s *capnp.Segment) (HostPortResolver_Registrar_Heartbeat_beat_Params, error)

func NewRootHostPortResolver_Registrar_Heartbeat_beat_Params 

func NewRootHostPortResolver_Registrar_Heartbeat_beat_Params(s *capnp.Segment) (HostPortResolver_Registrar_Heartbeat_beat_Params, error)

func ReadRootHostPortResolver_Registrar_Heartbeat_beat_Params 

func ReadRootHostPortResolver_Registrar_Heartbeat_beat_Params(msg *capnp.Message) (HostPortResolver_Registrar_Heartbeat_beat_Params, error)

func (HostPortResolver_Registrar_Heartbeat_beat_Params) DecodeFromPtr 

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

func (HostPortResolver_Registrar_Heartbeat_beat_Params) EncodeAsPtr 

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

func (HostPortResolver_Registrar_Heartbeat_beat_Params) IsValid 

func (s HostPortResolver_Registrar_Heartbeat_beat_Params) IsValid() bool

func (HostPortResolver_Registrar_Heartbeat_beat_Params) Message 

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

func (HostPortResolver_Registrar_Heartbeat_beat_Params) Segment 

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

func (HostPortResolver_Registrar_Heartbeat_beat_Params) String 

func (s HostPortResolver_Registrar_Heartbeat_beat_Params) String() string

func (HostPortResolver_Registrar_Heartbeat_beat_Params) ToPtr 

func (s HostPortResolver_Registrar_Heartbeat_beat_Params) ToPtr() capnp.Ptr

type HostPortResolver_Registrar_Heartbeat_beat_Params_Future 

type HostPortResolver_Registrar_Heartbeat_beat_Params_Future struct{ *capnp.Future }

HostPortResolver_Registrar_Heartbeat_beat_Params_Future is a wrapper for a HostPortResolver_Registrar_Heartbeat_beat_Params promised by a client call.

func (HostPortResolver_Registrar_Heartbeat_beat_Params_Future) Struct 

func (f HostPortResolver_Registrar_Heartbeat_beat_Params_Future) Struct() (HostPortResolver_Registrar_Heartbeat_beat_Params, error)

type HostPortResolver_Registrar_Heartbeat_beat_Params_List 

type HostPortResolver_Registrar_Heartbeat_beat_Params_List = capnp.StructList[HostPortResolver_Registrar_Heartbeat_beat_Params]

HostPortResolver_Registrar_Heartbeat_beat_Params_List is a list of HostPortResolver_Registrar_Heartbeat_beat_Params.

func NewHostPortResolver_Registrar_Heartbeat_beat_Params_List 

func NewHostPortResolver_Registrar_Heartbeat_beat_Params_List(s *capnp.Segment, sz int32) (HostPortResolver_Registrar_Heartbeat_beat_Params_List, error)

NewHostPortResolver_Registrar_Heartbeat_beat_Params creates a new list of HostPortResolver_Registrar_Heartbeat_beat_Params.

type HostPortResolver_Registrar_Heartbeat_beat_Results 

type HostPortResolver_Registrar_Heartbeat_beat_Results capnp.Struct

func NewHostPortResolver_Registrar_Heartbeat_beat_Results 

func NewHostPortResolver_Registrar_Heartbeat_beat_Results(s *capnp.Segment) (HostPortResolver_Registrar_Heartbeat_beat_Results, error)

func NewRootHostPortResolver_Registrar_Heartbeat_beat_Results 

func NewRootHostPortResolver_Registrar_Heartbeat_beat_Results(s *capnp.Segment) (HostPortResolver_Registrar_Heartbeat_beat_Results, error)

func ReadRootHostPortResolver_Registrar_Heartbeat_beat_Results 

func ReadRootHostPortResolver_Registrar_Heartbeat_beat_Results(msg *capnp.Message) (HostPortResolver_Registrar_Heartbeat_beat_Results, error)

func (HostPortResolver_Registrar_Heartbeat_beat_Results) DecodeFromPtr 

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

func (HostPortResolver_Registrar_Heartbeat_beat_Results) EncodeAsPtr 

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

func (HostPortResolver_Registrar_Heartbeat_beat_Results) IsValid 

func (s HostPortResolver_Registrar_Heartbeat_beat_Results) IsValid() bool

func (HostPortResolver_Registrar_Heartbeat_beat_Results) Message 

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

func (HostPortResolver_Registrar_Heartbeat_beat_Results) Segment 

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

func (HostPortResolver_Registrar_Heartbeat_beat_Results) String 

func (s HostPortResolver_Registrar_Heartbeat_beat_Results) String() string

func (HostPortResolver_Registrar_Heartbeat_beat_Results) ToPtr 

func (s HostPortResolver_Registrar_Heartbeat_beat_Results) ToPtr() capnp.Ptr

type HostPortResolver_Registrar_Heartbeat_beat_Results_Future 

type HostPortResolver_Registrar_Heartbeat_beat_Results_Future struct{ *capnp.Future }

HostPortResolver_Registrar_Heartbeat_beat_Results_Future is a wrapper for a HostPortResolver_Registrar_Heartbeat_beat_Results promised by a client call.

func (HostPortResolver_Registrar_Heartbeat_beat_Results_Future) Struct 

func (f HostPortResolver_Registrar_Heartbeat_beat_Results_Future) Struct() (HostPortResolver_Registrar_Heartbeat_beat_Results, error)

type HostPortResolver_Registrar_Heartbeat_beat_Results_List 

type HostPortResolver_Registrar_Heartbeat_beat_Results_List = capnp.StructList[HostPortResolver_Registrar_Heartbeat_beat_Results]

HostPortResolver_Registrar_Heartbeat_beat_Results_List is a list of HostPortResolver_Registrar_Heartbeat_beat_Results.

func NewHostPortResolver_Registrar_Heartbeat_beat_Results_List 

func NewHostPortResolver_Registrar_Heartbeat_beat_Results_List(s *capnp.Segment, sz int32) (HostPortResolver_Registrar_Heartbeat_beat_Results_List, error)

NewHostPortResolver_Registrar_Heartbeat_beat_Results creates a new list of HostPortResolver_Registrar_Heartbeat_beat_Results.

type HostPortResolver_Registrar_List 

type HostPortResolver_Registrar_List = capnp.CapList[HostPortResolver_Registrar]

HostPortResolver_Registrar_List is a list of HostPortResolver_Registrar.

func NewHostPortResolver_Registrar_List 

func NewHostPortResolver_Registrar_List(s *capnp.Segment, sz int32) (HostPortResolver_Registrar_List, error)

NewHostPortResolver_Registrar creates a new list of HostPortResolver_Registrar.

type HostPortResolver_Registrar_RegisterParams 

type HostPortResolver_Registrar_RegisterParams capnp.Struct

func NewHostPortResolver_Registrar_RegisterParams 

func NewHostPortResolver_Registrar_RegisterParams(s *capnp.Segment) (HostPortResolver_Registrar_RegisterParams, error)

func NewRootHostPortResolver_Registrar_RegisterParams 

func NewRootHostPortResolver_Registrar_RegisterParams(s *capnp.Segment) (HostPortResolver_Registrar_RegisterParams, error)

func ReadRootHostPortResolver_Registrar_RegisterParams 

func ReadRootHostPortResolver_Registrar_RegisterParams(msg *capnp.Message) (HostPortResolver_Registrar_RegisterParams, error)

func (HostPortResolver_Registrar_RegisterParams) Alias 

func (s HostPortResolver_Registrar_RegisterParams) Alias() (string, error)

func (HostPortResolver_Registrar_RegisterParams) AliasBytes 

func (s HostPortResolver_Registrar_RegisterParams) AliasBytes() ([]byte, error)

func (HostPortResolver_Registrar_RegisterParams) Base64VatId 

func (s HostPortResolver_Registrar_RegisterParams) Base64VatId() (string, error)

func (HostPortResolver_Registrar_RegisterParams) Base64VatIdBytes 

func (s HostPortResolver_Registrar_RegisterParams) Base64VatIdBytes() ([]byte, error)

func (HostPortResolver_Registrar_RegisterParams) DecodeFromPtr 

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

func (HostPortResolver_Registrar_RegisterParams) EncodeAsPtr 

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

func (HostPortResolver_Registrar_RegisterParams) HasAlias 

func (s HostPortResolver_Registrar_RegisterParams) HasAlias() bool

func (HostPortResolver_Registrar_RegisterParams) HasBase64VatId 

func (s HostPortResolver_Registrar_RegisterParams) HasBase64VatId() bool

func (HostPortResolver_Registrar_RegisterParams) HasHost 

func (s HostPortResolver_Registrar_RegisterParams) HasHost() bool

func (HostPortResolver_Registrar_RegisterParams) Host 

func (s HostPortResolver_Registrar_RegisterParams) Host() (string, error)

func (HostPortResolver_Registrar_RegisterParams) HostBytes 

func (s HostPortResolver_Registrar_RegisterParams) HostBytes() ([]byte, error)

func (HostPortResolver_Registrar_RegisterParams) IsValid 

func (s HostPortResolver_Registrar_RegisterParams) IsValid() bool

func (HostPortResolver_Registrar_RegisterParams) Message 

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

func (HostPortResolver_Registrar_RegisterParams) Port 

func (s HostPortResolver_Registrar_RegisterParams) Port() uint16

func (HostPortResolver_Registrar_RegisterParams) Segment 

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

func (HostPortResolver_Registrar_RegisterParams) SetAlias 

func (s HostPortResolver_Registrar_RegisterParams) SetAlias(v string) error

func (HostPortResolver_Registrar_RegisterParams) SetBase64VatId 

func (s HostPortResolver_Registrar_RegisterParams) SetBase64VatId(v string) error

func (HostPortResolver_Registrar_RegisterParams) SetHost 

func (s HostPortResolver_Registrar_RegisterParams) SetHost(v string) error

func (HostPortResolver_Registrar_RegisterParams) SetPort 

func (s HostPortResolver_Registrar_RegisterParams) SetPort(v uint16)

func (HostPortResolver_Registrar_RegisterParams) String 

func (s HostPortResolver_Registrar_RegisterParams) String() string

func (HostPortResolver_Registrar_RegisterParams) ToPtr 

func (s HostPortResolver_Registrar_RegisterParams) ToPtr() capnp.Ptr

type HostPortResolver_Registrar_RegisterParams_Future 

type HostPortResolver_Registrar_RegisterParams_Future struct{ *capnp.Future }

HostPortResolver_Registrar_RegisterParams_Future is a wrapper for a HostPortResolver_Registrar_RegisterParams promised by a client call.

func (HostPortResolver_Registrar_RegisterParams_Future) Struct 

func (f HostPortResolver_Registrar_RegisterParams_Future) Struct() (HostPortResolver_Registrar_RegisterParams, error)

type HostPortResolver_Registrar_RegisterParams_List 

type HostPortResolver_Registrar_RegisterParams_List = capnp.StructList[HostPortResolver_Registrar_RegisterParams]

HostPortResolver_Registrar_RegisterParams_List is a list of HostPortResolver_Registrar_RegisterParams.

func NewHostPortResolver_Registrar_RegisterParams_List 

func NewHostPortResolver_Registrar_RegisterParams_List(s *capnp.Segment, sz int32) (HostPortResolver_Registrar_RegisterParams_List, error)

NewHostPortResolver_Registrar_RegisterParams creates a new list of HostPortResolver_Registrar_RegisterParams.

type HostPortResolver_Registrar_Server 

type HostPortResolver_Registrar_Server interface {
	Register(context.Context, HostPortResolver_Registrar_register) error
}

A HostPortResolver_Registrar_Server is a HostPortResolver_Registrar with a local implementation.

type HostPortResolver_Registrar_register 

type HostPortResolver_Registrar_register struct {
	*server.Call
}

HostPortResolver_Registrar_register holds the state for a server call to HostPortResolver_Registrar.register. See server.Call for documentation.

func (HostPortResolver_Registrar_register) AllocResults 

func (c HostPortResolver_Registrar_register) AllocResults() (HostPortResolver_Registrar_register_Results, error)

AllocResults allocates the results struct.

func (HostPortResolver_Registrar_register) Args 

func (c HostPortResolver_Registrar_register) Args() HostPortResolver_Registrar_RegisterParams

Args returns the call's arguments.

type HostPortResolver_Registrar_register_Results 

type HostPortResolver_Registrar_register_Results capnp.Struct

func NewHostPortResolver_Registrar_register_Results 

func NewHostPortResolver_Registrar_register_Results(s *capnp.Segment) (HostPortResolver_Registrar_register_Results, error)

func NewRootHostPortResolver_Registrar_register_Results 

func NewRootHostPortResolver_Registrar_register_Results(s *capnp.Segment) (HostPortResolver_Registrar_register_Results, error)

func ReadRootHostPortResolver_Registrar_register_Results 

func ReadRootHostPortResolver_Registrar_register_Results(msg *capnp.Message) (HostPortResolver_Registrar_register_Results, error)

func (HostPortResolver_Registrar_register_Results) DecodeFromPtr 

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

func (HostPortResolver_Registrar_register_Results) EncodeAsPtr 

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

func (HostPortResolver_Registrar_register_Results) HasHeartbeat 

func (s HostPortResolver_Registrar_register_Results) HasHeartbeat() bool

func (HostPortResolver_Registrar_register_Results) Heartbeat 

func (s HostPortResolver_Registrar_register_Results) Heartbeat() HostPortResolver_Registrar_Heartbeat

func (HostPortResolver_Registrar_register_Results) IsValid 

func (s HostPortResolver_Registrar_register_Results) IsValid() bool

func (HostPortResolver_Registrar_register_Results) Message 

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

func (HostPortResolver_Registrar_register_Results) SecsHeartbeatInterval 

func (s HostPortResolver_Registrar_register_Results) SecsHeartbeatInterval() uint32

func (HostPortResolver_Registrar_register_Results) Segment 

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

func (HostPortResolver_Registrar_register_Results) SetHeartbeat 

func (s HostPortResolver_Registrar_register_Results) SetHeartbeat(v HostPortResolver_Registrar_Heartbeat) error

func (HostPortResolver_Registrar_register_Results) SetSecsHeartbeatInterval 

func (s HostPortResolver_Registrar_register_Results) SetSecsHeartbeatInterval(v uint32)

func (HostPortResolver_Registrar_register_Results) String 

func (s HostPortResolver_Registrar_register_Results) String() string

func (HostPortResolver_Registrar_register_Results) ToPtr 

func (s HostPortResolver_Registrar_register_Results) ToPtr() capnp.Ptr

type HostPortResolver_Registrar_register_Results_Future 

type HostPortResolver_Registrar_register_Results_Future struct{ *capnp.Future }

HostPortResolver_Registrar_register_Results_Future is a wrapper for a HostPortResolver_Registrar_register_Results promised by a client call.

func (HostPortResolver_Registrar_register_Results_Future) Heartbeat 

func (p HostPortResolver_Registrar_register_Results_Future) Heartbeat() HostPortResolver_Registrar_Heartbeat

func (HostPortResolver_Registrar_register_Results_Future) Struct 

func (f HostPortResolver_Registrar_register_Results_Future) Struct() (HostPortResolver_Registrar_register_Results, error)

type HostPortResolver_Registrar_register_Results_List 

type HostPortResolver_Registrar_register_Results_List = capnp.StructList[HostPortResolver_Registrar_register_Results]

HostPortResolver_Registrar_register_Results_List is a list of HostPortResolver_Registrar_register_Results.

func NewHostPortResolver_Registrar_register_Results_List 

func NewHostPortResolver_Registrar_register_Results_List(s *capnp.Segment, sz int32) (HostPortResolver_Registrar_register_Results_List, error)

NewHostPortResolver_Registrar_register_Results creates a new list of HostPortResolver_Registrar_register_Results.

type HostPortResolver_ResolveIdent 

type HostPortResolver_ResolveIdent struct {
	*server.Call
}

HostPortResolver_ResolveIdent holds the state for a server call to HostPortResolver.ResolveIdent. See server.Call for documentation.

func (HostPortResolver_ResolveIdent) AllocResults 

func (c HostPortResolver_ResolveIdent) AllocResults() (HostPortResolver_ResolveIdent_Results, error)

AllocResults allocates the results struct.

func (HostPortResolver_ResolveIdent) Args 

func (c HostPortResolver_ResolveIdent) Args() HostPortResolver_ResolveIdent_Params

Args returns the call's arguments.

type HostPortResolver_ResolveIdent_Params 

type HostPortResolver_ResolveIdent_Params capnp.Struct

func NewHostPortResolver_ResolveIdent_Params 

func NewHostPortResolver_ResolveIdent_Params(s *capnp.Segment) (HostPortResolver_ResolveIdent_Params, error)

func NewRootHostPortResolver_ResolveIdent_Params 

func NewRootHostPortResolver_ResolveIdent_Params(s *capnp.Segment) (HostPortResolver_ResolveIdent_Params, error)

func ReadRootHostPortResolver_ResolveIdent_Params 

func ReadRootHostPortResolver_ResolveIdent_Params(msg *capnp.Message) (HostPortResolver_ResolveIdent_Params, error)

func (HostPortResolver_ResolveIdent_Params) DecodeFromPtr 

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

func (HostPortResolver_ResolveIdent_Params) EncodeAsPtr 

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

func (HostPortResolver_ResolveIdent_Params) HasId 

func (s HostPortResolver_ResolveIdent_Params) HasId() bool

func (HostPortResolver_ResolveIdent_Params) Id 

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

func (HostPortResolver_ResolveIdent_Params) IdBytes 

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

func (HostPortResolver_ResolveIdent_Params) IsValid 

func (s HostPortResolver_ResolveIdent_Params) IsValid() bool

func (HostPortResolver_ResolveIdent_Params) Message 

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

func (HostPortResolver_ResolveIdent_Params) Segment 

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

func (HostPortResolver_ResolveIdent_Params) SetId 

func (s HostPortResolver_ResolveIdent_Params) SetId(v string) error

func (HostPortResolver_ResolveIdent_Params) String 

func (s HostPortResolver_ResolveIdent_Params) String() string

func (HostPortResolver_ResolveIdent_Params) ToPtr 

func (s HostPortResolver_ResolveIdent_Params) ToPtr() capnp.Ptr

type HostPortResolver_ResolveIdent_Params_Future 

type HostPortResolver_ResolveIdent_Params_Future struct{ *capnp.Future }

HostPortResolver_ResolveIdent_Params_Future is a wrapper for a HostPortResolver_ResolveIdent_Params promised by a client call.

func (HostPortResolver_ResolveIdent_Params_Future) Struct 

func (f HostPortResolver_ResolveIdent_Params_Future) Struct() (HostPortResolver_ResolveIdent_Params, error)

type HostPortResolver_ResolveIdent_Params_List 

type HostPortResolver_ResolveIdent_Params_List = capnp.StructList[HostPortResolver_ResolveIdent_Params]

HostPortResolver_ResolveIdent_Params_List is a list of HostPortResolver_ResolveIdent_Params.

func NewHostPortResolver_ResolveIdent_Params_List 

func NewHostPortResolver_ResolveIdent_Params_List(s *capnp.Segment, sz int32) (HostPortResolver_ResolveIdent_Params_List, error)

NewHostPortResolver_ResolveIdent_Params creates a new list of HostPortResolver_ResolveIdent_Params.

type HostPortResolver_ResolveIdent_Results 

type HostPortResolver_ResolveIdent_Results capnp.Struct

func NewHostPortResolver_ResolveIdent_Results 

func NewHostPortResolver_ResolveIdent_Results(s *capnp.Segment) (HostPortResolver_ResolveIdent_Results, error)

func NewRootHostPortResolver_ResolveIdent_Results 

func NewRootHostPortResolver_ResolveIdent_Results(s *capnp.Segment) (HostPortResolver_ResolveIdent_Results, error)

func ReadRootHostPortResolver_ResolveIdent_Results 

func ReadRootHostPortResolver_ResolveIdent_Results(msg *capnp.Message) (HostPortResolver_ResolveIdent_Results, error)

func (HostPortResolver_ResolveIdent_Results) DecodeFromPtr 

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

func (HostPortResolver_ResolveIdent_Results) EncodeAsPtr 

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

func (HostPortResolver_ResolveIdent_Results) HasHost 

func (s HostPortResolver_ResolveIdent_Results) HasHost() bool

func (HostPortResolver_ResolveIdent_Results) Host 

func (s HostPortResolver_ResolveIdent_Results) Host() (string, error)

func (HostPortResolver_ResolveIdent_Results) HostBytes 

func (s HostPortResolver_ResolveIdent_Results) HostBytes() ([]byte, error)

func (HostPortResolver_ResolveIdent_Results) IsValid 

func (s HostPortResolver_ResolveIdent_Results) IsValid() bool

func (HostPortResolver_ResolveIdent_Results) Message 

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

func (HostPortResolver_ResolveIdent_Results) Port 

func (s HostPortResolver_ResolveIdent_Results) Port() uint16

func (HostPortResolver_ResolveIdent_Results) Segment 

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

func (HostPortResolver_ResolveIdent_Results) SetHost 

func (s HostPortResolver_ResolveIdent_Results) SetHost(v string) error

func (HostPortResolver_ResolveIdent_Results) SetPort 

func (s HostPortResolver_ResolveIdent_Results) SetPort(v uint16)

func (HostPortResolver_ResolveIdent_Results) String 

func (s HostPortResolver_ResolveIdent_Results) String() string

func (HostPortResolver_ResolveIdent_Results) ToPtr 

func (s HostPortResolver_ResolveIdent_Results) ToPtr() capnp.Ptr

type HostPortResolver_ResolveIdent_Results_Future 

type HostPortResolver_ResolveIdent_Results_Future struct{ *capnp.Future }

HostPortResolver_ResolveIdent_Results_Future is a wrapper for a HostPortResolver_ResolveIdent_Results promised by a client call.

func (HostPortResolver_ResolveIdent_Results_Future) Struct 

func (f HostPortResolver_ResolveIdent_Results_Future) Struct() (HostPortResolver_ResolveIdent_Results, error)

type HostPortResolver_ResolveIdent_Results_List 

type HostPortResolver_ResolveIdent_Results_List = capnp.StructList[HostPortResolver_ResolveIdent_Results]

HostPortResolver_ResolveIdent_Results_List is a list of HostPortResolver_ResolveIdent_Results.

func NewHostPortResolver_ResolveIdent_Results_List 

func NewHostPortResolver_ResolveIdent_Results_List(s *capnp.Segment, sz int32) (HostPortResolver_ResolveIdent_Results_List, error)

NewHostPortResolver_ResolveIdent_Results creates a new list of HostPortResolver_ResolveIdent_Results.

type HostPortResolver_Server 

type HostPortResolver_Server interface {
	ResolveIdent(context.Context, HostPortResolver_ResolveIdent) error

	Info(context.Context, common.Identifiable_info) error

	Restore(context.Context, Restorer_restore) error
}

A HostPortResolver_Server is a HostPortResolver with a local implementation.

type Persistent 

type Persistent capnp.Client

func Persistent_ServerToClient 

func Persistent_ServerToClient(s Persistent_Server) Persistent

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

func (Persistent) AddRef 

func (c Persistent) AddRef() Persistent

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 (Persistent) DecodeFromPtr 

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

func (Persistent) EncodeAsPtr 

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

func (Persistent) GetFlowLimiter 

func (c Persistent) GetFlowLimiter() fc.FlowLimiter

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

func (Persistent) IsSame 

func (c Persistent) IsSame(other Persistent) 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 (Persistent) IsValid 

func (c Persistent) 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 (Persistent) Release 

func (c Persistent) 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 (Persistent) Resolve 

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

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

func (Persistent) Save 

func (c Persistent) Save(ctx context.Context, params func(Persistent_SaveParams) error) (Persistent_SaveResults_Future, capnp.ReleaseFunc)

func (Persistent) SetFlowLimiter 

func (c Persistent) 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 (Persistent) String 

func (c Persistent) 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 (Persistent) WaitStreaming 

func (c Persistent) WaitStreaming() error

type Persistent_List 

type Persistent_List = capnp.CapList[Persistent]

Persistent_List is a list of Persistent.

func NewPersistent_List 

func NewPersistent_List(s *capnp.Segment, sz int32) (Persistent_List, error)

NewPersistent creates a new list of Persistent.

type Persistent_ReleaseSturdyRef 

type Persistent_ReleaseSturdyRef capnp.Client

func Persistent_ReleaseSturdyRef_ServerToClient 

func Persistent_ReleaseSturdyRef_ServerToClient(s Persistent_ReleaseSturdyRef_Server) Persistent_ReleaseSturdyRef

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

func (Persistent_ReleaseSturdyRef) AddRef 

func (c Persistent_ReleaseSturdyRef) AddRef() Persistent_ReleaseSturdyRef

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 (Persistent_ReleaseSturdyRef) DecodeFromPtr 

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

func (Persistent_ReleaseSturdyRef) EncodeAsPtr 

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

func (Persistent_ReleaseSturdyRef) GetFlowLimiter 

func (c Persistent_ReleaseSturdyRef) GetFlowLimiter() fc.FlowLimiter

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

func (Persistent_ReleaseSturdyRef) IsSame 

func (c Persistent_ReleaseSturdyRef) IsSame(other Persistent_ReleaseSturdyRef) 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 (Persistent_ReleaseSturdyRef) IsValid 

func (c Persistent_ReleaseSturdyRef) 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 (Persistent_ReleaseSturdyRef) Release 

func (c Persistent_ReleaseSturdyRef) 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 (Persistent_ReleaseSturdyRef) ReleaseSR 

func (c Persistent_ReleaseSturdyRef) ReleaseSR(ctx context.Context, params func(Persistent_ReleaseSturdyRef_releaseSR_Params) error) (Persistent_ReleaseSturdyRef_releaseSR_Results_Future, capnp.ReleaseFunc)

func (Persistent_ReleaseSturdyRef) Resolve 

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

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

func (Persistent_ReleaseSturdyRef) SetFlowLimiter 

func (c Persistent_ReleaseSturdyRef) 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 (Persistent_ReleaseSturdyRef) String 

func (c Persistent_ReleaseSturdyRef) 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 (Persistent_ReleaseSturdyRef) WaitStreaming 

func (c Persistent_ReleaseSturdyRef) WaitStreaming() error

type Persistent_ReleaseSturdyRef_List 

type Persistent_ReleaseSturdyRef_List = capnp.CapList[Persistent_ReleaseSturdyRef]

Persistent_ReleaseSturdyRef_List is a list of Persistent_ReleaseSturdyRef.

func NewPersistent_ReleaseSturdyRef_List 

func NewPersistent_ReleaseSturdyRef_List(s *capnp.Segment, sz int32) (Persistent_ReleaseSturdyRef_List, error)

NewPersistent_ReleaseSturdyRef creates a new list of Persistent_ReleaseSturdyRef.

type Persistent_ReleaseSturdyRef_Server 

type Persistent_ReleaseSturdyRef_Server interface {
	ReleaseSR(context.Context, Persistent_ReleaseSturdyRef_releaseSR) error
}

A Persistent_ReleaseSturdyRef_Server is a Persistent_ReleaseSturdyRef with a local implementation.

type Persistent_ReleaseSturdyRef_releaseSR 

type Persistent_ReleaseSturdyRef_releaseSR struct {
	*server.Call
}

Persistent_ReleaseSturdyRef_releaseSR holds the state for a server call to Persistent_ReleaseSturdyRef.releaseSR. See server.Call for documentation.

func (Persistent_ReleaseSturdyRef_releaseSR) AllocResults 

func (c Persistent_ReleaseSturdyRef_releaseSR) AllocResults() (Persistent_ReleaseSturdyRef_releaseSR_Results, error)

AllocResults allocates the results struct.

func (Persistent_ReleaseSturdyRef_releaseSR) Args 

func (c Persistent_ReleaseSturdyRef_releaseSR) Args() Persistent_ReleaseSturdyRef_releaseSR_Params

Args returns the call's arguments.

type Persistent_ReleaseSturdyRef_releaseSR_Params 

type Persistent_ReleaseSturdyRef_releaseSR_Params capnp.Struct

func NewPersistent_ReleaseSturdyRef_releaseSR_Params 

func NewPersistent_ReleaseSturdyRef_releaseSR_Params(s *capnp.Segment) (Persistent_ReleaseSturdyRef_releaseSR_Params, error)

func NewRootPersistent_ReleaseSturdyRef_releaseSR_Params 

func NewRootPersistent_ReleaseSturdyRef_releaseSR_Params(s *capnp.Segment) (Persistent_ReleaseSturdyRef_releaseSR_Params, error)

func ReadRootPersistent_ReleaseSturdyRef_releaseSR_Params 

func ReadRootPersistent_ReleaseSturdyRef_releaseSR_Params(msg *capnp.Message) (Persistent_ReleaseSturdyRef_releaseSR_Params, error)

func (Persistent_ReleaseSturdyRef_releaseSR_Params) DecodeFromPtr 

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

func (Persistent_ReleaseSturdyRef_releaseSR_Params) EncodeAsPtr 

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

func (Persistent_ReleaseSturdyRef_releaseSR_Params) IsValid 

func (s Persistent_ReleaseSturdyRef_releaseSR_Params) IsValid() bool

func (Persistent_ReleaseSturdyRef_releaseSR_Params) Message 

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

func (Persistent_ReleaseSturdyRef_releaseSR_Params) Segment 

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

func (Persistent_ReleaseSturdyRef_releaseSR_Params) String 

func (s Persistent_ReleaseSturdyRef_releaseSR_Params) String() string

func (Persistent_ReleaseSturdyRef_releaseSR_Params) ToPtr 

func (s Persistent_ReleaseSturdyRef_releaseSR_Params) ToPtr() capnp.Ptr

type Persistent_ReleaseSturdyRef_releaseSR_Params_Future 

type Persistent_ReleaseSturdyRef_releaseSR_Params_Future struct{ *capnp.Future }

Persistent_ReleaseSturdyRef_releaseSR_Params_Future is a wrapper for a Persistent_ReleaseSturdyRef_releaseSR_Params promised by a client call.

func (Persistent_ReleaseSturdyRef_releaseSR_Params_Future) Struct 

func (f Persistent_ReleaseSturdyRef_releaseSR_Params_Future) Struct() (Persistent_ReleaseSturdyRef_releaseSR_Params, error)

type Persistent_ReleaseSturdyRef_releaseSR_Params_List 

type Persistent_ReleaseSturdyRef_releaseSR_Params_List = capnp.StructList[Persistent_ReleaseSturdyRef_releaseSR_Params]

Persistent_ReleaseSturdyRef_releaseSR_Params_List is a list of Persistent_ReleaseSturdyRef_releaseSR_Params.

func NewPersistent_ReleaseSturdyRef_releaseSR_Params_List 

func NewPersistent_ReleaseSturdyRef_releaseSR_Params_List(s *capnp.Segment, sz int32) (Persistent_ReleaseSturdyRef_releaseSR_Params_List, error)

NewPersistent_ReleaseSturdyRef_releaseSR_Params creates a new list of Persistent_ReleaseSturdyRef_releaseSR_Params.

type Persistent_ReleaseSturdyRef_releaseSR_Results 

type Persistent_ReleaseSturdyRef_releaseSR_Results capnp.Struct

func NewPersistent_ReleaseSturdyRef_releaseSR_Results 

func NewPersistent_ReleaseSturdyRef_releaseSR_Results(s *capnp.Segment) (Persistent_ReleaseSturdyRef_releaseSR_Results, error)

func NewRootPersistent_ReleaseSturdyRef_releaseSR_Results 

func NewRootPersistent_ReleaseSturdyRef_releaseSR_Results(s *capnp.Segment) (Persistent_ReleaseSturdyRef_releaseSR_Results, error)

func ReadRootPersistent_ReleaseSturdyRef_releaseSR_Results 

func ReadRootPersistent_ReleaseSturdyRef_releaseSR_Results(msg *capnp.Message) (Persistent_ReleaseSturdyRef_releaseSR_Results, error)

func (Persistent_ReleaseSturdyRef_releaseSR_Results) DecodeFromPtr 

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

func (Persistent_ReleaseSturdyRef_releaseSR_Results) EncodeAsPtr 

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

func (Persistent_ReleaseSturdyRef_releaseSR_Results) IsValid 

func (s Persistent_ReleaseSturdyRef_releaseSR_Results) IsValid() bool

func (Persistent_ReleaseSturdyRef_releaseSR_Results) Message 

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

func (Persistent_ReleaseSturdyRef_releaseSR_Results) Segment 

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

func (Persistent_ReleaseSturdyRef_releaseSR_Results) SetSuccess 

func (s Persistent_ReleaseSturdyRef_releaseSR_Results) SetSuccess(v bool)

func (Persistent_ReleaseSturdyRef_releaseSR_Results) String 

func (s Persistent_ReleaseSturdyRef_releaseSR_Results) String() string

func (Persistent_ReleaseSturdyRef_releaseSR_Results) Success 

func (s Persistent_ReleaseSturdyRef_releaseSR_Results) Success() bool

func (Persistent_ReleaseSturdyRef_releaseSR_Results) ToPtr 

func (s Persistent_ReleaseSturdyRef_releaseSR_Results) ToPtr() capnp.Ptr

type Persistent_ReleaseSturdyRef_releaseSR_Results_Future 

type Persistent_ReleaseSturdyRef_releaseSR_Results_Future struct{ *capnp.Future }

Persistent_ReleaseSturdyRef_releaseSR_Results_Future is a wrapper for a Persistent_ReleaseSturdyRef_releaseSR_Results promised by a client call.

func (Persistent_ReleaseSturdyRef_releaseSR_Results_Future) Struct 

func (f Persistent_ReleaseSturdyRef_releaseSR_Results_Future) Struct() (Persistent_ReleaseSturdyRef_releaseSR_Results, error)

type Persistent_ReleaseSturdyRef_releaseSR_Results_List 

type Persistent_ReleaseSturdyRef_releaseSR_Results_List = capnp.StructList[Persistent_ReleaseSturdyRef_releaseSR_Results]

Persistent_ReleaseSturdyRef_releaseSR_Results_List is a list of Persistent_ReleaseSturdyRef_releaseSR_Results.

func NewPersistent_ReleaseSturdyRef_releaseSR_Results_List 

func NewPersistent_ReleaseSturdyRef_releaseSR_Results_List(s *capnp.Segment, sz int32) (Persistent_ReleaseSturdyRef_releaseSR_Results_List, error)

NewPersistent_ReleaseSturdyRef_releaseSR_Results creates a new list of Persistent_ReleaseSturdyRef_releaseSR_Results.

type Persistent_SaveParams 

type Persistent_SaveParams capnp.Struct

func NewPersistent_SaveParams 

func NewPersistent_SaveParams(s *capnp.Segment) (Persistent_SaveParams, error)

func NewRootPersistent_SaveParams 

func NewRootPersistent_SaveParams(s *capnp.Segment) (Persistent_SaveParams, error)

func ReadRootPersistent_SaveParams 

func ReadRootPersistent_SaveParams(msg *capnp.Message) (Persistent_SaveParams, error)

func (Persistent_SaveParams) DecodeFromPtr 

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

func (Persistent_SaveParams) EncodeAsPtr 

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

func (Persistent_SaveParams) HasSealFor 

func (s Persistent_SaveParams) HasSealFor() bool

func (Persistent_SaveParams) IsValid 

func (s Persistent_SaveParams) IsValid() bool

func (Persistent_SaveParams) Message 

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

func (Persistent_SaveParams) NewSealFor 

func (s Persistent_SaveParams) NewSealFor() (SturdyRef_Owner, error)

NewSealFor sets the sealFor field to a newly allocated SturdyRef_Owner struct, preferring placement in s's segment.

func (Persistent_SaveParams) SealFor 

func (s Persistent_SaveParams) SealFor() (SturdyRef_Owner, error)

func (Persistent_SaveParams) Segment 

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

func (Persistent_SaveParams) SetSealFor 

func (s Persistent_SaveParams) SetSealFor(v SturdyRef_Owner) error

func (Persistent_SaveParams) String 

func (s Persistent_SaveParams) String() string

func (Persistent_SaveParams) ToPtr 

func (s Persistent_SaveParams) ToPtr() capnp.Ptr

type Persistent_SaveParams_Future 

type Persistent_SaveParams_Future struct{ *capnp.Future }

Persistent_SaveParams_Future is a wrapper for a Persistent_SaveParams promised by a client call.

func (Persistent_SaveParams_Future) SealFor 

func (p Persistent_SaveParams_Future) SealFor() SturdyRef_Owner_Future

func (Persistent_SaveParams_Future) Struct 

func (f Persistent_SaveParams_Future) Struct() (Persistent_SaveParams, error)

type Persistent_SaveParams_List 

type Persistent_SaveParams_List = capnp.StructList[Persistent_SaveParams]

Persistent_SaveParams_List is a list of Persistent_SaveParams.

func NewPersistent_SaveParams_List 

func NewPersistent_SaveParams_List(s *capnp.Segment, sz int32) (Persistent_SaveParams_List, error)

NewPersistent_SaveParams creates a new list of Persistent_SaveParams.

type Persistent_SaveResults 

type Persistent_SaveResults capnp.Struct

func NewPersistent_SaveResults 

func NewPersistent_SaveResults(s *capnp.Segment) (Persistent_SaveResults, error)

func NewRootPersistent_SaveResults 

func NewRootPersistent_SaveResults(s *capnp.Segment) (Persistent_SaveResults, error)

func ReadRootPersistent_SaveResults 

func ReadRootPersistent_SaveResults(msg *capnp.Message) (Persistent_SaveResults, error)

func (Persistent_SaveResults) DecodeFromPtr 

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

func (Persistent_SaveResults) EncodeAsPtr 

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

func (Persistent_SaveResults) HasSturdyRef 

func (s Persistent_SaveResults) HasSturdyRef() bool

func (Persistent_SaveResults) HasUnsaveSR 

func (s Persistent_SaveResults) HasUnsaveSR() bool

func (Persistent_SaveResults) IsValid 

func (s Persistent_SaveResults) IsValid() bool

func (Persistent_SaveResults) Message 

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

func (Persistent_SaveResults) NewSturdyRef 

func (s Persistent_SaveResults) NewSturdyRef() (SturdyRef, error)

NewSturdyRef sets the sturdyRef field to a newly allocated SturdyRef struct, preferring placement in s's segment.

func (Persistent_SaveResults) NewUnsaveSR 

func (s Persistent_SaveResults) NewUnsaveSR() (SturdyRef, error)

NewUnsaveSR sets the unsaveSR field to a newly allocated SturdyRef struct, preferring placement in s's segment.

func (Persistent_SaveResults) Segment 

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

func (Persistent_SaveResults) SetSturdyRef 

func (s Persistent_SaveResults) SetSturdyRef(v SturdyRef) error

func (Persistent_SaveResults) SetUnsaveSR 

func (s Persistent_SaveResults) SetUnsaveSR(v SturdyRef) error

func (Persistent_SaveResults) String 

func (s Persistent_SaveResults) String() string

func (Persistent_SaveResults) SturdyRef 

func (s Persistent_SaveResults) SturdyRef() (SturdyRef, error)

func (Persistent_SaveResults) ToPtr 

func (s Persistent_SaveResults) ToPtr() capnp.Ptr

func (Persistent_SaveResults) UnsaveSR 

func (s Persistent_SaveResults) UnsaveSR() (SturdyRef, error)

type Persistent_SaveResults_Future 

type Persistent_SaveResults_Future struct{ *capnp.Future }

Persistent_SaveResults_Future is a wrapper for a Persistent_SaveResults promised by a client call.

func (Persistent_SaveResults_Future) Struct 

func (f Persistent_SaveResults_Future) Struct() (Persistent_SaveResults, error)

func (Persistent_SaveResults_Future) SturdyRef 

func (p Persistent_SaveResults_Future) SturdyRef() SturdyRef_Future

func (Persistent_SaveResults_Future) UnsaveSR 

func (p Persistent_SaveResults_Future) UnsaveSR() SturdyRef_Future

type Persistent_SaveResults_List 

type Persistent_SaveResults_List = capnp.StructList[Persistent_SaveResults]

Persistent_SaveResults_List is a list of Persistent_SaveResults.

func NewPersistent_SaveResults_List 

func NewPersistent_SaveResults_List(s *capnp.Segment, sz int32) (Persistent_SaveResults_List, error)

NewPersistent_SaveResults creates a new list of Persistent_SaveResults.

type Persistent_Server 

type Persistent_Server interface {
	Save(context.Context, Persistent_save) error
}

A Persistent_Server is a Persistent with a local implementation.

type Persistent_save 

type Persistent_save struct {
	*server.Call
}

Persistent_save holds the state for a server call to Persistent.save. See server.Call for documentation.

func (Persistent_save) AllocResults 

func (c Persistent_save) AllocResults() (Persistent_SaveResults, error)

AllocResults allocates the results struct.

func (Persistent_save) Args 

func (c Persistent_save) Args() Persistent_SaveParams

Args returns the call's arguments.

type Restorer 

type Restorer capnp.Client

func Restorer_ServerToClient 

func Restorer_ServerToClient(s Restorer_Server) Restorer

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

func (Restorer) AddRef 

func (c Restorer) AddRef() Restorer

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 (Restorer) DecodeFromPtr 

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

func (Restorer) EncodeAsPtr 

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

func (Restorer) GetFlowLimiter 

func (c Restorer) GetFlowLimiter() fc.FlowLimiter

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

func (Restorer) IsSame 

func (c Restorer) IsSame(other Restorer) 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 (Restorer) IsValid 

func (c Restorer) 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 (Restorer) Release 

func (c Restorer) 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 (Restorer) Resolve 

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

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

func (Restorer) Restore 

func (c Restorer) Restore(ctx context.Context, params func(Restorer_RestoreParams) error) (Restorer_restore_Results_Future, capnp.ReleaseFunc)

func (Restorer) SetFlowLimiter 

func (c Restorer) 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 (Restorer) String 

func (c Restorer) 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 (Restorer) WaitStreaming 

func (c Restorer) WaitStreaming() error

type Restorer_List 

type Restorer_List = capnp.CapList[Restorer]

Restorer_List is a list of Restorer.

func NewRestorer_List 

func NewRestorer_List(s *capnp.Segment, sz int32) (Restorer_List, error)

NewRestorer creates a new list of Restorer.

type Restorer_RestoreParams 

type Restorer_RestoreParams capnp.Struct

func NewRestorer_RestoreParams 

func NewRestorer_RestoreParams(s *capnp.Segment) (Restorer_RestoreParams, error)

func NewRootRestorer_RestoreParams 

func NewRootRestorer_RestoreParams(s *capnp.Segment) (Restorer_RestoreParams, error)

func ReadRootRestorer_RestoreParams 

func ReadRootRestorer_RestoreParams(msg *capnp.Message) (Restorer_RestoreParams, error)

func (Restorer_RestoreParams) DecodeFromPtr 

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

func (Restorer_RestoreParams) EncodeAsPtr 

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

func (Restorer_RestoreParams) HasLocalRef 

func (s Restorer_RestoreParams) HasLocalRef() bool

func (Restorer_RestoreParams) HasSealedBy 

func (s Restorer_RestoreParams) HasSealedBy() bool

func (Restorer_RestoreParams) IsValid 

func (s Restorer_RestoreParams) IsValid() bool

func (Restorer_RestoreParams) LocalRef 

func (s Restorer_RestoreParams) LocalRef() (SturdyRef_Token, error)

func (Restorer_RestoreParams) Message 

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

func (Restorer_RestoreParams) NewLocalRef 

func (s Restorer_RestoreParams) NewLocalRef() (SturdyRef_Token, error)

NewLocalRef sets the localRef field to a newly allocated SturdyRef_Token struct, preferring placement in s's segment.

func (Restorer_RestoreParams) NewSealedBy 

func (s Restorer_RestoreParams) NewSealedBy() (SturdyRef_Owner, error)

NewSealedBy sets the sealedBy field to a newly allocated SturdyRef_Owner struct, preferring placement in s's segment.

func (Restorer_RestoreParams) SealedBy 

func (s Restorer_RestoreParams) SealedBy() (SturdyRef_Owner, error)

func (Restorer_RestoreParams) Segment 

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

func (Restorer_RestoreParams) SetLocalRef 

func (s Restorer_RestoreParams) SetLocalRef(v SturdyRef_Token) error

func (Restorer_RestoreParams) SetSealedBy 

func (s Restorer_RestoreParams) SetSealedBy(v SturdyRef_Owner) error

func (Restorer_RestoreParams) String 

func (s Restorer_RestoreParams) String() string

func (Restorer_RestoreParams) ToPtr 

func (s Restorer_RestoreParams) ToPtr() capnp.Ptr

type Restorer_RestoreParams_Future 

type Restorer_RestoreParams_Future struct{ *capnp.Future }

Restorer_RestoreParams_Future is a wrapper for a Restorer_RestoreParams promised by a client call.

func (Restorer_RestoreParams_Future) LocalRef 

func (p Restorer_RestoreParams_Future) LocalRef() SturdyRef_Token_Future

func (Restorer_RestoreParams_Future) SealedBy 

func (p Restorer_RestoreParams_Future) SealedBy() SturdyRef_Owner_Future

func (Restorer_RestoreParams_Future) Struct 

func (f Restorer_RestoreParams_Future) Struct() (Restorer_RestoreParams, error)

type Restorer_RestoreParams_List 

type Restorer_RestoreParams_List = capnp.StructList[Restorer_RestoreParams]

Restorer_RestoreParams_List is a list of Restorer_RestoreParams.

func NewRestorer_RestoreParams_List 

func NewRestorer_RestoreParams_List(s *capnp.Segment, sz int32) (Restorer_RestoreParams_List, error)

NewRestorer_RestoreParams creates a new list of Restorer_RestoreParams.

type Restorer_Server 

type Restorer_Server interface {
	Restore(context.Context, Restorer_restore) error
}

A Restorer_Server is a Restorer with a local implementation.

type Restorer_restore 

type Restorer_restore struct {
	*server.Call
}

Restorer_restore holds the state for a server call to Restorer.restore. See server.Call for documentation.

func (Restorer_restore) AllocResults 

func (c Restorer_restore) AllocResults() (Restorer_restore_Results, error)

AllocResults allocates the results struct.

func (Restorer_restore) Args 

func (c Restorer_restore) Args() Restorer_RestoreParams

Args returns the call's arguments.

type Restorer_restore_Results 

type Restorer_restore_Results capnp.Struct

func NewRestorer_restore_Results 

func NewRestorer_restore_Results(s *capnp.Segment) (Restorer_restore_Results, error)

func NewRootRestorer_restore_Results 

func NewRootRestorer_restore_Results(s *capnp.Segment) (Restorer_restore_Results, error)

func ReadRootRestorer_restore_Results 

func ReadRootRestorer_restore_Results(msg *capnp.Message) (Restorer_restore_Results, error)

func (Restorer_restore_Results) Cap 

func (s Restorer_restore_Results) Cap() capnp.Client

func (Restorer_restore_Results) DecodeFromPtr 

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

func (Restorer_restore_Results) EncodeAsPtr 

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

func (Restorer_restore_Results) HasCap 

func (s Restorer_restore_Results) HasCap() bool

func (Restorer_restore_Results) IsValid 

func (s Restorer_restore_Results) IsValid() bool

func (Restorer_restore_Results) Message 

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

func (Restorer_restore_Results) Segment 

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

func (Restorer_restore_Results) SetCap 

func (s Restorer_restore_Results) SetCap(c capnp.Client) error

func (Restorer_restore_Results) String 

func (s Restorer_restore_Results) String() string

func (Restorer_restore_Results) ToPtr 

func (s Restorer_restore_Results) ToPtr() capnp.Ptr

type Restorer_restore_Results_Future 

type Restorer_restore_Results_Future struct{ *capnp.Future }

Restorer_restore_Results_Future is a wrapper for a Restorer_restore_Results promised by a client call.

func (Restorer_restore_Results_Future) Cap 

func (p Restorer_restore_Results_Future) Cap() capnp.Client

func (Restorer_restore_Results_Future) Struct 

func (f Restorer_restore_Results_Future) Struct() (Restorer_restore_Results, error)

type Restorer_restore_Results_List 

type Restorer_restore_Results_List = capnp.StructList[Restorer_restore_Results]

Restorer_restore_Results_List is a list of Restorer_restore_Results.

func NewRestorer_restore_Results_List 

func NewRestorer_restore_Results_List(s *capnp.Segment, sz int32) (Restorer_restore_Results_List, error)

NewRestorer_restore_Results creates a new list of Restorer_restore_Results.

type SturdyRef 

type SturdyRef capnp.Struct

func NewRootSturdyRef 

func NewRootSturdyRef(s *capnp.Segment) (SturdyRef, error)

func NewSturdyRef 

func NewSturdyRef(s *capnp.Segment) (SturdyRef, error)

func ReadRootSturdyRef 

func ReadRootSturdyRef(msg *capnp.Message) (SturdyRef, error)

func (SturdyRef) DecodeFromPtr 

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

func (SturdyRef) EncodeAsPtr 

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

func (SturdyRef) HasLocalRef 

func (s SturdyRef) HasLocalRef() bool

func (SturdyRef) HasVat 

func (s SturdyRef) HasVat() bool

func (SturdyRef) IsValid 

func (s SturdyRef) IsValid() bool

func (SturdyRef) LocalRef 

func (s SturdyRef) LocalRef() (SturdyRef_Token, error)

func (SturdyRef) Message 

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

func (SturdyRef) NewLocalRef 

func (s SturdyRef) NewLocalRef() (SturdyRef_Token, error)

NewLocalRef sets the localRef field to a newly allocated SturdyRef_Token struct, preferring placement in s's segment.

func (SturdyRef) NewVat 

func (s SturdyRef) NewVat() (VatPath, error)

NewVat sets the vat field to a newly allocated VatPath struct, preferring placement in s's segment.

func (SturdyRef) Segment 

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

func (SturdyRef) SetLocalRef 

func (s SturdyRef) SetLocalRef(v SturdyRef_Token) error

func (SturdyRef) SetVat 

func (s SturdyRef) SetVat(v VatPath) error

func (SturdyRef) String 

func (s SturdyRef) String() string

func (SturdyRef) ToPtr 

func (s SturdyRef) ToPtr() capnp.Ptr

func (SturdyRef) Vat 

func (s SturdyRef) Vat() (VatPath, error)

type SturdyRef_Future 

type SturdyRef_Future struct{ *capnp.Future }

SturdyRef_Future is a wrapper for a SturdyRef promised by a client call.

func (SturdyRef_Future) LocalRef 

func (p SturdyRef_Future) LocalRef() SturdyRef_Token_Future

func (SturdyRef_Future) Struct 

func (f SturdyRef_Future) Struct() (SturdyRef, error)

func (SturdyRef_Future) Vat 

func (p SturdyRef_Future) Vat() VatPath_Future

type SturdyRef_List 

type SturdyRef_List = capnp.StructList[SturdyRef]

SturdyRef_List is a list of SturdyRef.

func NewSturdyRef_List 

func NewSturdyRef_List(s *capnp.Segment, sz int32) (SturdyRef_List, error)

NewSturdyRef creates a new list of SturdyRef.

type SturdyRef_Owner 

type SturdyRef_Owner capnp.Struct

func NewRootSturdyRef_Owner 

func NewRootSturdyRef_Owner(s *capnp.Segment) (SturdyRef_Owner, error)

func NewSturdyRef_Owner 

func NewSturdyRef_Owner(s *capnp.Segment) (SturdyRef_Owner, error)

func ReadRootSturdyRef_Owner 

func ReadRootSturdyRef_Owner(msg *capnp.Message) (SturdyRef_Owner, error)

func (SturdyRef_Owner) DecodeFromPtr 

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

func (SturdyRef_Owner) EncodeAsPtr 

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

func (SturdyRef_Owner) Guid 

func (s SturdyRef_Owner) Guid() (string, error)

func (SturdyRef_Owner) GuidBytes 

func (s SturdyRef_Owner) GuidBytes() ([]byte, error)

func (SturdyRef_Owner) HasGuid 

func (s SturdyRef_Owner) HasGuid() bool

func (SturdyRef_Owner) IsValid 

func (s SturdyRef_Owner) IsValid() bool

func (SturdyRef_Owner) Message 

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

func (SturdyRef_Owner) Segment 

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

func (SturdyRef_Owner) SetGuid 

func (s SturdyRef_Owner) SetGuid(v string) error

func (SturdyRef_Owner) String 

func (s SturdyRef_Owner) String() string

func (SturdyRef_Owner) ToPtr 

func (s SturdyRef_Owner) ToPtr() capnp.Ptr

type SturdyRef_Owner_Future 

type SturdyRef_Owner_Future struct{ *capnp.Future }

SturdyRef_Owner_Future is a wrapper for a SturdyRef_Owner promised by a client call.

func (SturdyRef_Owner_Future) Struct 

func (f SturdyRef_Owner_Future) Struct() (SturdyRef_Owner, error)

type SturdyRef_Owner_List 

type SturdyRef_Owner_List = capnp.StructList[SturdyRef_Owner]

SturdyRef_Owner_List is a list of SturdyRef_Owner.

func NewSturdyRef_Owner_List 

func NewSturdyRef_Owner_List(s *capnp.Segment, sz int32) (SturdyRef_Owner_List, error)

NewSturdyRef_Owner creates a new list of SturdyRef_Owner.

type SturdyRef_Token 

type SturdyRef_Token capnp.Struct

func NewRootSturdyRef_Token 

func NewRootSturdyRef_Token(s *capnp.Segment) (SturdyRef_Token, error)

func NewSturdyRef_Token 

func NewSturdyRef_Token(s *capnp.Segment) (SturdyRef_Token, error)

func ReadRootSturdyRef_Token 

func ReadRootSturdyRef_Token(msg *capnp.Message) (SturdyRef_Token, error)

func (SturdyRef_Token) Data 

func (s SturdyRef_Token) Data() ([]byte, error)

func (SturdyRef_Token) DecodeFromPtr 

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

func (SturdyRef_Token) EncodeAsPtr 

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

func (SturdyRef_Token) HasData 

func (s SturdyRef_Token) HasData() bool

func (SturdyRef_Token) HasText 

func (s SturdyRef_Token) HasText() bool

func (SturdyRef_Token) IsValid 

func (s SturdyRef_Token) IsValid() bool

func (SturdyRef_Token) Message 

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

func (SturdyRef_Token) Segment 

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

func (SturdyRef_Token) SetData 

func (s SturdyRef_Token) SetData(v []byte) error

func (SturdyRef_Token) SetText 

func (s SturdyRef_Token) SetText(v string) error

func (SturdyRef_Token) String 

func (s SturdyRef_Token) String() string

func (SturdyRef_Token) Text 

func (s SturdyRef_Token) Text() (string, error)

func (SturdyRef_Token) TextBytes 

func (s SturdyRef_Token) TextBytes() ([]byte, error)

func (SturdyRef_Token) ToPtr 

func (s SturdyRef_Token) ToPtr() capnp.Ptr

func (SturdyRef_Token) Which 

func (s SturdyRef_Token) Which() SturdyRef_Token_Which

type SturdyRef_Token_Future 

type SturdyRef_Token_Future struct{ *capnp.Future }

SturdyRef_Token_Future is a wrapper for a SturdyRef_Token promised by a client call.

func (SturdyRef_Token_Future) Struct 

func (f SturdyRef_Token_Future) Struct() (SturdyRef_Token, error)

type SturdyRef_Token_List 

type SturdyRef_Token_List = capnp.StructList[SturdyRef_Token]

SturdyRef_Token_List is a list of SturdyRef_Token.

func NewSturdyRef_Token_List 

func NewSturdyRef_Token_List(s *capnp.Segment, sz int32) (SturdyRef_Token_List, error)

NewSturdyRef_Token creates a new list of SturdyRef_Token.

type SturdyRef_Token_Which 

type SturdyRef_Token_Which uint16
const (
	SturdyRef_Token_Which_text SturdyRef_Token_Which = 0
	SturdyRef_Token_Which_data SturdyRef_Token_Which = 1
)

func (SturdyRef_Token_Which) String 

func (w SturdyRef_Token_Which) String() string

type VatId 

type VatId capnp.Struct

func NewRootVatId 

func NewRootVatId(s *capnp.Segment) (VatId, error)

func NewVatId 

func NewVatId(s *capnp.Segment) (VatId, error)

func ReadRootVatId 

func ReadRootVatId(msg *capnp.Message) (VatId, error)

func (VatId) DecodeFromPtr 

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

func (VatId) EncodeAsPtr 

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

func (VatId) IsValid 

func (s VatId) IsValid() bool

func (VatId) Message 

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

func (VatId) PublicKey0 

func (s VatId) PublicKey0() uint64

func (VatId) PublicKey1 

func (s VatId) PublicKey1() uint64

func (VatId) PublicKey2 

func (s VatId) PublicKey2() uint64

func (VatId) PublicKey3 

func (s VatId) PublicKey3() uint64

func (VatId) Segment 

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

func (VatId) SetPublicKey0 

func (s VatId) SetPublicKey0(v uint64)

func (VatId) SetPublicKey1 

func (s VatId) SetPublicKey1(v uint64)

func (VatId) SetPublicKey2 

func (s VatId) SetPublicKey2(v uint64)

func (VatId) SetPublicKey3 

func (s VatId) SetPublicKey3(v uint64)

func (VatId) String 

func (s VatId) String() string

func (VatId) ToPtr 

func (s VatId) ToPtr() capnp.Ptr

type VatId_Future 

type VatId_Future struct{ *capnp.Future }

VatId_Future is a wrapper for a VatId promised by a client call.

func (VatId_Future) Struct 

func (f VatId_Future) Struct() (VatId, error)

type VatId_List 

type VatId_List = capnp.StructList[VatId]

VatId_List is a list of VatId.

func NewVatId_List 

func NewVatId_List(s *capnp.Segment, sz int32) (VatId_List, error)

NewVatId creates a new list of VatId.

type VatPath 

type VatPath capnp.Struct

func NewRootVatPath 

func NewRootVatPath(s *capnp.Segment) (VatPath, error)

func NewVatPath 

func NewVatPath(s *capnp.Segment) (VatPath, error)

func ReadRootVatPath 

func ReadRootVatPath(msg *capnp.Message) (VatPath, error)

func (VatPath) Address 

func (s VatPath) Address() (Address, error)

func (VatPath) DecodeFromPtr 

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

func (VatPath) EncodeAsPtr 

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

func (VatPath) HasAddress 

func (s VatPath) HasAddress() bool

func (VatPath) HasId 

func (s VatPath) HasId() bool

func (VatPath) Id 

func (s VatPath) Id() (VatId, error)

func (VatPath) IsValid 

func (s VatPath) IsValid() bool

func (VatPath) Message 

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

func (VatPath) NewAddress 

func (s VatPath) NewAddress() (Address, error)

NewAddress sets the address field to a newly allocated Address struct, preferring placement in s's segment.

func (VatPath) NewId 

func (s VatPath) NewId() (VatId, error)

NewId sets the id field to a newly allocated VatId struct, preferring placement in s's segment.

func (VatPath) Segment 

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

func (VatPath) SetAddress 

func (s VatPath) SetAddress(v Address) error

func (VatPath) SetId 

func (s VatPath) SetId(v VatId) error

func (VatPath) String 

func (s VatPath) String() string

func (VatPath) ToPtr 

func (s VatPath) ToPtr() capnp.Ptr

type VatPath_Future 

type VatPath_Future struct{ *capnp.Future }

VatPath_Future is a wrapper for a VatPath promised by a client call.

func (VatPath_Future) Address 

func (p VatPath_Future) Address() Address_Future

func (VatPath_Future) Id 

func (p VatPath_Future) Id() VatId_Future

func (VatPath_Future) Struct 

func (f VatPath_Future) Struct() (VatPath, error)

type VatPath_List 

type VatPath_List = capnp.StructList[VatPath]

VatPath_List is a list of VatPath.

func NewVatPath_List 

func NewVatPath_List(s *capnp.Segment, sz int32) (VatPath_List, error)

NewVatPath creates a new list of VatPath.

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.