protocol

package
v0.0.0-...-6ce3ea9 Latest Latest
Warning

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

 Go to latest Published: Feb 16, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const Cell_TypeID = 0x86dfe7e96ebb541d

Cell_TypeID is the unique identifier for the type Cell.

View Source 
const ContentId_Algo_TypeID = 0x889936d1bbf13253

ContentId_Algo_TypeID is the unique identifier for the type ContentId_Algo.

View Source 
const ContentId_TypeID = 0xc5bd7ad468fa72a6

ContentId_TypeID is the unique identifier for the type ContentId.

View Source 
const Dynamic_TypeID = 0xc03ae9bd42824061

Dynamic_TypeID is the unique identifier for the type Dynamic.

View Source 
const Getter_TypeID = 0xb1928944e0fc3173

Getter_TypeID is the unique identifier for the type Getter.

View Source 
const Getter_get_Params_TypeID = 0xbf17007e9138e225

Getter_get_Params_TypeID is the unique identifier for the type Getter_get_Params.

View Source 
const Getter_get_Results_TypeID = 0xf3c3dfe1133f40f5

Getter_get_Results_TypeID is the unique identifier for the type Getter_get_Results.

View Source 
const Map_TypeID = 0xfb36f41541e13f38

Map_TypeID is the unique identifier for the type Map.

View Source 
const Map_find_Params_TypeID = 0xa20a1eb578989942

Map_find_Params_TypeID is the unique identifier for the type Map_find_Params.

View Source 
const Map_find_Results_TypeID = 0x9d379fc7e30aecb8

Map_find_Results_TypeID is the unique identifier for the type Map_find_Results.

View Source 
const Ref_TypeID = 0xa14ffd6d795dbc31

Ref_TypeID is the unique identifier for the type Ref.

View Source 
const Ref_getStored_Params_TypeID = 0xa28b89f8877a0b1c

Ref_getStored_Params_TypeID is the unique identifier for the type Ref_getStored_Params.

View Source 
const Ref_getStored_Results_TypeID = 0xfe10400cc1d31474

Ref_getStored_Results_TypeID is the unique identifier for the type Ref_getStored_Results.

View Source 
const RootApi_TypeID = 0xbf3d5608637940e8

RootApi_TypeID is the unique identifier for the type RootApi.

View Source 
const RootApi_blobMap_Params_TypeID = 0xe2e07eea432c8e12

RootApi_blobMap_Params_TypeID is the unique identifier for the type RootApi_blobMap_Params.

View Source 
const RootApi_blobMap_Results_TypeID = 0xa7d5e26e70f192f5

RootApi_blobMap_Results_TypeID is the unique identifier for the type RootApi_blobMap_Results.

View Source 
const RootApi_root_Params_TypeID = 0x9eb1a39212b38ec1

RootApi_root_Params_TypeID is the unique identifier for the type RootApi_root_Params.

View Source 
const RootApi_root_Results_TypeID = 0xd73f2e504c7f9730

RootApi_root_Results_TypeID is the unique identifier for the type RootApi_root_Results.

View Source 
const RootApi_storage_Params_TypeID = 0xfdb4062d10a3ca31

RootApi_storage_Params_TypeID is the unique identifier for the type RootApi_storage_Params.

View Source 
const RootApi_storage_Results_TypeID = 0xcd2937d0c1251d4e

RootApi_storage_Results_TypeID is the unique identifier for the type RootApi_storage_Results.

View Source 
const RootPtr_TypeID = 0xec69889c3a1aaf50

RootPtr_TypeID is the unique identifier for the type RootPtr.

View Source 
const Setter_TypeID = 0xedefcf72d1a4dcd5

Setter_TypeID is the unique identifier for the type Setter.

View Source 
const Setter_set_Params_TypeID = 0xc57b0d3e5cf4c9ee

Setter_set_Params_TypeID is the unique identifier for the type Setter_set_Params.

View Source 
const Setter_set_Results_TypeID = 0x92f67194cfd010ca

Setter_set_Results_TypeID is the unique identifier for the type Setter_set_Results.

View Source 
const Storage_TypeID = 0x84ec75049386a248

Storage_TypeID is the unique identifier for the type Storage.

View Source 
const Storage_put_Params_TypeID = 0xd17d67c20039536b

Storage_put_Params_TypeID is the unique identifier for the type Storage_put_Params.

View Source 
const Storage_put_Results_TypeID = 0xc5dc8978c148f57a

Storage_put_Results_TypeID is the unique identifier for the type Storage_put_Results.

View Source 
const Stored_TypeID = 0xe6eb5cba7d06cb58

Stored_TypeID is the unique identifier for the type Stored.

View Source 
const TxCell_TypeID = 0xfcd1f0de6c4076f9

TxCell_TypeID is the unique identifier for the type TxCell.

View Source 
const TxCell_txGet_Params_TypeID = 0xf39598e0c091fed8

TxCell_txGet_Params_TypeID is the unique identifier for the type TxCell_txGet_Params.

View Source 
const TxCell_txGet_Results_TypeID = 0xdfeaf85f84328172

TxCell_txGet_Results_TypeID is the unique identifier for the type TxCell_txGet_Results.

Variables

This section is empty.

Functions

func Cell_Methods 

func Cell_Methods(methods []server.Method, s Cell_Server) []server.Method

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

func Cell_NewServer 

func Cell_NewServer(s Cell_Server) *server.Server

Cell_NewServer creates a new Server from an implementation of Cell_Server.

func Getter_Methods 

func Getter_Methods(methods []server.Method, s Getter_Server) []server.Method

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

func Getter_NewServer 

func Getter_NewServer(s Getter_Server) *server.Server

Getter_NewServer creates a new Server from an implementation of Getter_Server.

func Map_Methods 

func Map_Methods(methods []server.Method, s Map_Server) []server.Method

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

func Map_NewServer 

func Map_NewServer(s Map_Server) *server.Server

Map_NewServer creates a new Server from an implementation of Map_Server.

func Ref_Methods 

func Ref_Methods(methods []server.Method, s Ref_Server) []server.Method

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

func Ref_NewServer 

func Ref_NewServer(s Ref_Server) *server.Server

Ref_NewServer creates a new Server from an implementation of Ref_Server.

func RootApi_Methods 

func RootApi_Methods(methods []server.Method, s RootApi_Server) []server.Method

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

func RootApi_NewServer 

func RootApi_NewServer(s RootApi_Server) *server.Server

RootApi_NewServer creates a new Server from an implementation of RootApi_Server.

func RootPtr_Methods 

func RootPtr_Methods(methods []server.Method, s RootPtr_Server) []server.Method

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

func RootPtr_NewServer 

func RootPtr_NewServer(s RootPtr_Server) *server.Server

RootPtr_NewServer creates a new Server from an implementation of RootPtr_Server.

func Setter_Methods 

func Setter_Methods(methods []server.Method, s Setter_Server) []server.Method

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

func Setter_NewServer 

func Setter_NewServer(s Setter_Server) *server.Server

Setter_NewServer creates a new Server from an implementation of Setter_Server.

func Storage_Methods 

func Storage_Methods(methods []server.Method, s Storage_Server) []server.Method

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

func Storage_NewServer 

func Storage_NewServer(s Storage_Server) *server.Server

Storage_NewServer creates a new Server from an implementation of Storage_Server.

func TxCell_Methods 

func TxCell_Methods(methods []server.Method, s TxCell_Server) []server.Method

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

func TxCell_NewServer 

func TxCell_NewServer(s TxCell_Server) *server.Server

TxCell_NewServer creates a new Server from an implementation of TxCell_Server.

Types

type Cell 

type Cell capnp.Client

func Cell_ServerToClient 

func Cell_ServerToClient(s Cell_Server) Cell

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

func (Cell) AddRef 

func (c Cell) AddRef() Cell

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

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

func (Cell) EncodeAsPtr 

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

func (Cell) Get 

func (c Cell) Get(ctx context.Context, params func(Getter_get_Params) error) (Getter_get_Results_Future, capnp.ReleaseFunc)

func (Cell) GetFlowLimiter 

func (c Cell) GetFlowLimiter() fc.FlowLimiter

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

func (Cell) IsSame 

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

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

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

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

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

func (Cell) Set 

func (c Cell) Set(ctx context.Context, params func(Setter_set_Params) error) (Setter_set_Results_Future, capnp.ReleaseFunc)

func (Cell) SetFlowLimiter 

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

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

func (c Cell) WaitStreaming() error

type Cell_List 

type Cell_List = capnp.CapList[Cell]

Cell_List is a list of Cell.

func NewCell_List 

func NewCell_List(s *capnp.Segment, sz int32) (Cell_List, error)

NewCell creates a new list of Cell.

type Cell_Server 

type Cell_Server interface {
	Set(context.Context, Setter_set) error

	Get(context.Context, Getter_get) error
}

A Cell_Server is a Cell with a local implementation.

type ContentId 

type ContentId capnp.Struct

func NewContentId 

func NewContentId(s *capnp.Segment) (ContentId, error)

func NewRootContentId 

func NewRootContentId(s *capnp.Segment) (ContentId, error)

func ReadRootContentId 

func ReadRootContentId(msg *capnp.Message) (ContentId, error)

func (ContentId) Algo 

func (s ContentId) Algo() ContentId_Algo

func (ContentId) DecodeFromPtr 

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

func (ContentId) Digest 

func (s ContentId) Digest() ([]byte, error)

func (ContentId) EncodeAsPtr 

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

func (ContentId) HasDigest 

func (s ContentId) HasDigest() bool

func (ContentId) IsValid 

func (s ContentId) IsValid() bool

func (ContentId) Message 

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

func (ContentId) Segment 

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

func (ContentId) SetAlgo 

func (s ContentId) SetAlgo(v ContentId_Algo)

func (ContentId) SetDigest 

func (s ContentId) SetDigest(v []byte) error

func (ContentId) String 

func (s ContentId) String() string

func (ContentId) ToPtr 

func (s ContentId) ToPtr() capnp.Ptr

type ContentId_Algo 

type ContentId_Algo uint16
const (
	ContentId_Algo_sha256 ContentId_Algo = 0
)

Values of ContentId_Algo.

func ContentId_AlgoFromString 

func ContentId_AlgoFromString(c string) ContentId_Algo

ContentId_AlgoFromString returns the enum value with a name, or the zero value if there's no such value.

func (ContentId_Algo) String 

func (c ContentId_Algo) String() string

String returns the enum's constant name.

type ContentId_Algo_List 

type ContentId_Algo_List = capnp.EnumList[ContentId_Algo]

func NewContentId_Algo_List 

func NewContentId_Algo_List(s *capnp.Segment, sz int32) (ContentId_Algo_List, error)

type ContentId_Future 

type ContentId_Future struct{ *capnp.Future }

ContentId_Future is a wrapper for a ContentId promised by a client call.

func (ContentId_Future) Struct 

func (f ContentId_Future) Struct() (ContentId, error)

type ContentId_List 

type ContentId_List = capnp.StructList[ContentId]

ContentId_List is a list of ContentId.

func NewContentId_List 

func NewContentId_List(s *capnp.Segment, sz int32) (ContentId_List, error)

NewContentId creates a new list of ContentId.

type Dynamic 

type Dynamic capnp.Struct

func NewDynamic 

func NewDynamic(s *capnp.Segment) (Dynamic, error)

func NewRootDynamic 

func NewRootDynamic(s *capnp.Segment) (Dynamic, error)

func ReadRootDynamic 

func ReadRootDynamic(msg *capnp.Message) (Dynamic, error)

func (Dynamic) DecodeFromPtr 

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

func (Dynamic) EncodeAsPtr 

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

func (Dynamic) HasRef 

func (s Dynamic) HasRef() bool

func (Dynamic) IsValid 

func (s Dynamic) IsValid() bool

func (Dynamic) Message 

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

func (Dynamic) Ref 

func (s Dynamic) Ref() Ref

func (Dynamic) Segment 

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

func (Dynamic) SetRef 

func (s Dynamic) SetRef(v Ref) error

func (Dynamic) SetTypeId 

func (s Dynamic) SetTypeId(v uint64)

func (Dynamic) String 

func (s Dynamic) String() string

func (Dynamic) ToPtr 

func (s Dynamic) ToPtr() capnp.Ptr

func (Dynamic) TypeId 

func (s Dynamic) TypeId() uint64

type Dynamic_Future 

type Dynamic_Future struct{ *capnp.Future }

Dynamic_Future is a wrapper for a Dynamic promised by a client call.

func (Dynamic_Future) Ref 

func (p Dynamic_Future) Ref() Ref

func (Dynamic_Future) Struct 

func (f Dynamic_Future) Struct() (Dynamic, error)

type Dynamic_List 

type Dynamic_List = capnp.StructList[Dynamic]

Dynamic_List is a list of Dynamic.

func NewDynamic_List 

func NewDynamic_List(s *capnp.Segment, sz int32) (Dynamic_List, error)

NewDynamic creates a new list of Dynamic.

type Getter 

type Getter capnp.Client

func Getter_ServerToClient 

func Getter_ServerToClient(s Getter_Server) Getter

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

func (Getter) AddRef 

func (c Getter) AddRef() Getter

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

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

func (Getter) EncodeAsPtr 

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

func (Getter) Get 

func (c Getter) Get(ctx context.Context, params func(Getter_get_Params) error) (Getter_get_Results_Future, capnp.ReleaseFunc)

func (Getter) GetFlowLimiter 

func (c Getter) GetFlowLimiter() fc.FlowLimiter

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

func (Getter) IsSame 

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

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

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

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

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

func (Getter) SetFlowLimiter 

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

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

func (c Getter) WaitStreaming() error

type Getter_List 

type Getter_List = capnp.CapList[Getter]

Getter_List is a list of Getter.

func NewGetter_List 

func NewGetter_List(s *capnp.Segment, sz int32) (Getter_List, error)

NewGetter creates a new list of Getter.

type Getter_Server 

type Getter_Server interface {
	Get(context.Context, Getter_get) error
}

A Getter_Server is a Getter with a local implementation.

type Getter_get 

type Getter_get struct {
	*server.Call
}

Getter_get holds the state for a server call to Getter.get. See server.Call for documentation.

func (Getter_get) AllocResults 

func (c Getter_get) AllocResults() (Getter_get_Results, error)

AllocResults allocates the results struct.

func (Getter_get) Args 

func (c Getter_get) Args() Getter_get_Params

Args returns the call's arguments.

type Getter_get_Params 

type Getter_get_Params capnp.Struct

func NewGetter_get_Params 

func NewGetter_get_Params(s *capnp.Segment) (Getter_get_Params, error)

func NewRootGetter_get_Params 

func NewRootGetter_get_Params(s *capnp.Segment) (Getter_get_Params, error)

func ReadRootGetter_get_Params 

func ReadRootGetter_get_Params(msg *capnp.Message) (Getter_get_Params, error)

func (Getter_get_Params) DecodeFromPtr 

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

func (Getter_get_Params) EncodeAsPtr 

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

func (Getter_get_Params) IsValid 

func (s Getter_get_Params) IsValid() bool

func (Getter_get_Params) Message 

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

func (Getter_get_Params) Segment 

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

func (Getter_get_Params) String 

func (s Getter_get_Params) String() string

func (Getter_get_Params) ToPtr 

func (s Getter_get_Params) ToPtr() capnp.Ptr

type Getter_get_Params_Future 

type Getter_get_Params_Future struct{ *capnp.Future }

Getter_get_Params_Future is a wrapper for a Getter_get_Params promised by a client call.

func (Getter_get_Params_Future) Struct 

func (f Getter_get_Params_Future) Struct() (Getter_get_Params, error)

type Getter_get_Params_List 

type Getter_get_Params_List = capnp.StructList[Getter_get_Params]

Getter_get_Params_List is a list of Getter_get_Params.

func NewGetter_get_Params_List 

func NewGetter_get_Params_List(s *capnp.Segment, sz int32) (Getter_get_Params_List, error)

NewGetter_get_Params creates a new list of Getter_get_Params.

type Getter_get_Results 

type Getter_get_Results capnp.Struct

func NewGetter_get_Results 

func NewGetter_get_Results(s *capnp.Segment) (Getter_get_Results, error)

func NewRootGetter_get_Results 

func NewRootGetter_get_Results(s *capnp.Segment) (Getter_get_Results, error)

func ReadRootGetter_get_Results 

func ReadRootGetter_get_Results(msg *capnp.Message) (Getter_get_Results, error)

func (Getter_get_Results) DecodeFromPtr 

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

func (Getter_get_Results) EncodeAsPtr 

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

func (Getter_get_Results) HasValue 

func (s Getter_get_Results) HasValue() bool

func (Getter_get_Results) IsValid 

func (s Getter_get_Results) IsValid() bool

func (Getter_get_Results) Message 

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

func (Getter_get_Results) Segment 

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

func (Getter_get_Results) SetValue 

func (s Getter_get_Results) SetValue(v capnp.Ptr) error

func (Getter_get_Results) String 

func (s Getter_get_Results) String() string

func (Getter_get_Results) ToPtr 

func (s Getter_get_Results) ToPtr() capnp.Ptr

func (Getter_get_Results) Value 

func (s Getter_get_Results) Value() (capnp.Ptr, error)

type Getter_get_Results_Future 

type Getter_get_Results_Future struct{ *capnp.Future }

Getter_get_Results_Future is a wrapper for a Getter_get_Results promised by a client call.

func (Getter_get_Results_Future) Struct 

func (f Getter_get_Results_Future) Struct() (Getter_get_Results, error)

func (Getter_get_Results_Future) Value 

func (p Getter_get_Results_Future) Value() *capnp.Future

type Getter_get_Results_List 

type Getter_get_Results_List = capnp.StructList[Getter_get_Results]

Getter_get_Results_List is a list of Getter_get_Results.

func NewGetter_get_Results_List 

func NewGetter_get_Results_List(s *capnp.Segment, sz int32) (Getter_get_Results_List, error)

NewGetter_get_Results creates a new list of Getter_get_Results.

type Map 

type Map capnp.Client

func Map_ServerToClient 

func Map_ServerToClient(s Map_Server) Map

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

func (Map) AddRef 

func (c Map) AddRef() Map

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

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

func (Map) EncodeAsPtr 

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

func (Map) Find 

func (c Map) Find(ctx context.Context, params func(Map_find_Params) error) (Map_find_Results_Future, capnp.ReleaseFunc)

func (Map) GetFlowLimiter 

func (c Map) GetFlowLimiter() fc.FlowLimiter

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

func (Map) IsSame 

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

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

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

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

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

func (Map) SetFlowLimiter 

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

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

func (c Map) WaitStreaming() error

type Map_List 

type Map_List = capnp.CapList[Map]

Map_List is a list of Map.

func NewMap_List 

func NewMap_List(s *capnp.Segment, sz int32) (Map_List, error)

NewMap creates a new list of Map.

type Map_Server 

type Map_Server interface {
	Find(context.Context, Map_find) error
}

A Map_Server is a Map with a local implementation.

type Map_find 

type Map_find struct {
	*server.Call
}

Map_find holds the state for a server call to Map.find. See server.Call for documentation.

func (Map_find) AllocResults 

func (c Map_find) AllocResults() (Map_find_Results, error)

AllocResults allocates the results struct.

func (Map_find) Args 

func (c Map_find) Args() Map_find_Params

Args returns the call's arguments.

type Map_find_Params 

type Map_find_Params capnp.Struct

func NewMap_find_Params 

func NewMap_find_Params(s *capnp.Segment) (Map_find_Params, error)

func NewRootMap_find_Params 

func NewRootMap_find_Params(s *capnp.Segment) (Map_find_Params, error)

func ReadRootMap_find_Params 

func ReadRootMap_find_Params(msg *capnp.Message) (Map_find_Params, error)

func (Map_find_Params) DecodeFromPtr 

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

func (Map_find_Params) EncodeAsPtr 

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

func (Map_find_Params) HasKey 

func (s Map_find_Params) HasKey() bool

func (Map_find_Params) IsValid 

func (s Map_find_Params) IsValid() bool

func (Map_find_Params) Key 

func (s Map_find_Params) Key() (capnp.Ptr, error)

func (Map_find_Params) Message 

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

func (Map_find_Params) Segment 

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

func (Map_find_Params) SetKey 

func (s Map_find_Params) SetKey(v capnp.Ptr) error

func (Map_find_Params) String 

func (s Map_find_Params) String() string

func (Map_find_Params) ToPtr 

func (s Map_find_Params) ToPtr() capnp.Ptr

type Map_find_Params_Future 

type Map_find_Params_Future struct{ *capnp.Future }

Map_find_Params_Future is a wrapper for a Map_find_Params promised by a client call.

func (Map_find_Params_Future) Key 

func (p Map_find_Params_Future) Key() *capnp.Future

func (Map_find_Params_Future) Struct 

func (f Map_find_Params_Future) Struct() (Map_find_Params, error)

type Map_find_Params_List 

type Map_find_Params_List = capnp.StructList[Map_find_Params]

Map_find_Params_List is a list of Map_find_Params.

func NewMap_find_Params_List 

func NewMap_find_Params_List(s *capnp.Segment, sz int32) (Map_find_Params_List, error)

NewMap_find_Params creates a new list of Map_find_Params.

type Map_find_Results 

type Map_find_Results capnp.Struct

func NewMap_find_Results 

func NewMap_find_Results(s *capnp.Segment) (Map_find_Results, error)

func NewRootMap_find_Results 

func NewRootMap_find_Results(s *capnp.Segment) (Map_find_Results, error)

func ReadRootMap_find_Results 

func ReadRootMap_find_Results(msg *capnp.Message) (Map_find_Results, error)

func (Map_find_Results) DecodeFromPtr 

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

func (Map_find_Results) EncodeAsPtr 

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

func (Map_find_Results) HasValue 

func (s Map_find_Results) HasValue() bool

func (Map_find_Results) IsValid 

func (s Map_find_Results) IsValid() bool

func (Map_find_Results) Message 

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

func (Map_find_Results) Segment 

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

func (Map_find_Results) SetValue 

func (s Map_find_Results) SetValue(v capnp.Ptr) error

func (Map_find_Results) String 

func (s Map_find_Results) String() string

func (Map_find_Results) ToPtr 

func (s Map_find_Results) ToPtr() capnp.Ptr

func (Map_find_Results) Value 

func (s Map_find_Results) Value() (capnp.Ptr, error)

type Map_find_Results_Future 

type Map_find_Results_Future struct{ *capnp.Future }

Map_find_Results_Future is a wrapper for a Map_find_Results promised by a client call.

func (Map_find_Results_Future) Struct 

func (f Map_find_Results_Future) Struct() (Map_find_Results, error)

func (Map_find_Results_Future) Value 

func (p Map_find_Results_Future) Value() *capnp.Future

type Map_find_Results_List 

type Map_find_Results_List = capnp.StructList[Map_find_Results]

Map_find_Results_List is a list of Map_find_Results.

func NewMap_find_Results_List 

func NewMap_find_Results_List(s *capnp.Segment, sz int32) (Map_find_Results_List, error)

NewMap_find_Results creates a new list of Map_find_Results.

type Ref 

type Ref capnp.Client

func Ref_ServerToClient 

func Ref_ServerToClient(s Ref_Server) Ref

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

func (Ref) AddRef 

func (c Ref) AddRef() Ref

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

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

func (Ref) EncodeAsPtr 

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

func (Ref) Get 

func (c Ref) Get(ctx context.Context, params func(Getter_get_Params) error) (Getter_get_Results_Future, capnp.ReleaseFunc)

func (Ref) GetFlowLimiter 

func (c Ref) GetFlowLimiter() fc.FlowLimiter

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

func (Ref) GetStored 

func (c Ref) GetStored(ctx context.Context, params func(Ref_getStored_Params) error) (Ref_getStored_Results_Future, capnp.ReleaseFunc)

func (Ref) IsSame 

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

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

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

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

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

func (Ref) SetFlowLimiter 

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

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

func (c Ref) WaitStreaming() error

type Ref_List 

type Ref_List = capnp.CapList[Ref]

Ref_List is a list of Ref.

func NewRef_List 

func NewRef_List(s *capnp.Segment, sz int32) (Ref_List, error)

NewRef creates a new list of Ref.

type Ref_Server 

type Ref_Server interface {
	GetStored(context.Context, Ref_getStored) error

	Get(context.Context, Getter_get) error
}

A Ref_Server is a Ref with a local implementation.

type Ref_getStored 

type Ref_getStored struct {
	*server.Call
}

Ref_getStored holds the state for a server call to Ref.getStored. See server.Call for documentation.

func (Ref_getStored) AllocResults 

func (c Ref_getStored) AllocResults() (Ref_getStored_Results, error)

AllocResults allocates the results struct.

func (Ref_getStored) Args 

func (c Ref_getStored) Args() Ref_getStored_Params

Args returns the call's arguments.

type Ref_getStored_Params 

type Ref_getStored_Params capnp.Struct

func NewRef_getStored_Params 

func NewRef_getStored_Params(s *capnp.Segment) (Ref_getStored_Params, error)

func NewRootRef_getStored_Params 

func NewRootRef_getStored_Params(s *capnp.Segment) (Ref_getStored_Params, error)

func ReadRootRef_getStored_Params 

func ReadRootRef_getStored_Params(msg *capnp.Message) (Ref_getStored_Params, error)

func (Ref_getStored_Params) DecodeFromPtr 

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

func (Ref_getStored_Params) EncodeAsPtr 

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

func (Ref_getStored_Params) IsValid 

func (s Ref_getStored_Params) IsValid() bool

func (Ref_getStored_Params) Message 

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

func (Ref_getStored_Params) Segment 

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

func (Ref_getStored_Params) String 

func (s Ref_getStored_Params) String() string

func (Ref_getStored_Params) ToPtr 

func (s Ref_getStored_Params) ToPtr() capnp.Ptr

type Ref_getStored_Params_Future 

type Ref_getStored_Params_Future struct{ *capnp.Future }

Ref_getStored_Params_Future is a wrapper for a Ref_getStored_Params promised by a client call.

func (Ref_getStored_Params_Future) Struct 

func (f Ref_getStored_Params_Future) Struct() (Ref_getStored_Params, error)

type Ref_getStored_Params_List 

type Ref_getStored_Params_List = capnp.StructList[Ref_getStored_Params]

Ref_getStored_Params_List is a list of Ref_getStored_Params.

func NewRef_getStored_Params_List 

func NewRef_getStored_Params_List(s *capnp.Segment, sz int32) (Ref_getStored_Params_List, error)

NewRef_getStored_Params creates a new list of Ref_getStored_Params.

type Ref_getStored_Results 

type Ref_getStored_Results capnp.Struct

func NewRef_getStored_Results 

func NewRef_getStored_Results(s *capnp.Segment) (Ref_getStored_Results, error)

func NewRootRef_getStored_Results 

func NewRootRef_getStored_Results(s *capnp.Segment) (Ref_getStored_Results, error)

func ReadRootRef_getStored_Results 

func ReadRootRef_getStored_Results(msg *capnp.Message) (Ref_getStored_Results, error)

func (Ref_getStored_Results) DecodeFromPtr 

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

func (Ref_getStored_Results) EncodeAsPtr 

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

func (Ref_getStored_Results) HasStoredValue 

func (s Ref_getStored_Results) HasStoredValue() bool

func (Ref_getStored_Results) IsValid 

func (s Ref_getStored_Results) IsValid() bool

func (Ref_getStored_Results) Message 

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

func (Ref_getStored_Results) NewStoredValue 

func (s Ref_getStored_Results) NewStoredValue() (Stored, error)

NewStoredValue sets the storedValue field to a newly allocated Stored struct, preferring placement in s's segment.

func (Ref_getStored_Results) Segment 

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

func (Ref_getStored_Results) SetStoredValue 

func (s Ref_getStored_Results) SetStoredValue(v Stored) error

func (Ref_getStored_Results) StoredValue 

func (s Ref_getStored_Results) StoredValue() (Stored, error)

func (Ref_getStored_Results) String 

func (s Ref_getStored_Results) String() string

func (Ref_getStored_Results) ToPtr 

func (s Ref_getStored_Results) ToPtr() capnp.Ptr

type Ref_getStored_Results_Future 

type Ref_getStored_Results_Future struct{ *capnp.Future }

Ref_getStored_Results_Future is a wrapper for a Ref_getStored_Results promised by a client call.

func (Ref_getStored_Results_Future) StoredValue 

func (p Ref_getStored_Results_Future) StoredValue() Stored_Future

func (Ref_getStored_Results_Future) Struct 

func (f Ref_getStored_Results_Future) Struct() (Ref_getStored_Results, error)

type Ref_getStored_Results_List 

type Ref_getStored_Results_List = capnp.StructList[Ref_getStored_Results]

Ref_getStored_Results_List is a list of Ref_getStored_Results.

func NewRef_getStored_Results_List 

func NewRef_getStored_Results_List(s *capnp.Segment, sz int32) (Ref_getStored_Results_List, error)

NewRef_getStored_Results creates a new list of Ref_getStored_Results.

type RootApi 

type RootApi capnp.Client

func RootApi_ServerToClient 

func RootApi_ServerToClient(s RootApi_Server) RootApi

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

func (RootApi) AddRef 

func (c RootApi) AddRef() RootApi

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 (RootApi) BlobMap 

func (c RootApi) BlobMap(ctx context.Context, params func(RootApi_blobMap_Params) error) (RootApi_blobMap_Results_Future, capnp.ReleaseFunc)

func (RootApi) DecodeFromPtr 

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

func (RootApi) EncodeAsPtr 

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

func (RootApi) GetFlowLimiter 

func (c RootApi) GetFlowLimiter() fc.FlowLimiter

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

func (RootApi) IsSame 

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

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

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

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

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

func (RootApi) Root 

func (c RootApi) Root(ctx context.Context, params func(RootApi_root_Params) error) (RootApi_root_Results_Future, capnp.ReleaseFunc)

func (RootApi) SetFlowLimiter 

func (c RootApi) 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 (RootApi) Storage 

func (c RootApi) Storage(ctx context.Context, params func(RootApi_storage_Params) error) (RootApi_storage_Results_Future, capnp.ReleaseFunc)

func (RootApi) String 

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

func (c RootApi) WaitStreaming() error

type RootApi_List 

type RootApi_List = capnp.CapList[RootApi]

RootApi_List is a list of RootApi.

func NewRootApi_List 

func NewRootApi_List(s *capnp.Segment, sz int32) (RootApi_List, error)

NewRootApi creates a new list of RootApi.

type RootApi_Server 

type RootApi_Server interface {
	BlobMap(context.Context, RootApi_blobMap) error

	Root(context.Context, RootApi_root) error

	Storage(context.Context, RootApi_storage) error
}

A RootApi_Server is a RootApi with a local implementation.

type RootApi_blobMap 

type RootApi_blobMap struct {
	*server.Call
}

RootApi_blobMap holds the state for a server call to RootApi.blobMap. See server.Call for documentation.

func (RootApi_blobMap) AllocResults 

func (c RootApi_blobMap) AllocResults() (RootApi_blobMap_Results, error)

AllocResults allocates the results struct.

func (RootApi_blobMap) Args 

func (c RootApi_blobMap) Args() RootApi_blobMap_Params

Args returns the call's arguments.

type RootApi_blobMap_Params 

type RootApi_blobMap_Params capnp.Struct

func NewRootApi_blobMap_Params 

func NewRootApi_blobMap_Params(s *capnp.Segment) (RootApi_blobMap_Params, error)

func NewRootRootApi_blobMap_Params 

func NewRootRootApi_blobMap_Params(s *capnp.Segment) (RootApi_blobMap_Params, error)

func ReadRootRootApi_blobMap_Params 

func ReadRootRootApi_blobMap_Params(msg *capnp.Message) (RootApi_blobMap_Params, error)

func (RootApi_blobMap_Params) DecodeFromPtr 

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

func (RootApi_blobMap_Params) EncodeAsPtr 

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

func (RootApi_blobMap_Params) IsValid 

func (s RootApi_blobMap_Params) IsValid() bool

func (RootApi_blobMap_Params) Message 

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

func (RootApi_blobMap_Params) Segment 

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

func (RootApi_blobMap_Params) String 

func (s RootApi_blobMap_Params) String() string

func (RootApi_blobMap_Params) ToPtr 

func (s RootApi_blobMap_Params) ToPtr() capnp.Ptr

type RootApi_blobMap_Params_Future 

type RootApi_blobMap_Params_Future struct{ *capnp.Future }

RootApi_blobMap_Params_Future is a wrapper for a RootApi_blobMap_Params promised by a client call.

func (RootApi_blobMap_Params_Future) Struct 

func (f RootApi_blobMap_Params_Future) Struct() (RootApi_blobMap_Params, error)

type RootApi_blobMap_Params_List 

type RootApi_blobMap_Params_List = capnp.StructList[RootApi_blobMap_Params]

RootApi_blobMap_Params_List is a list of RootApi_blobMap_Params.

func NewRootApi_blobMap_Params_List 

func NewRootApi_blobMap_Params_List(s *capnp.Segment, sz int32) (RootApi_blobMap_Params_List, error)

NewRootApi_blobMap_Params creates a new list of RootApi_blobMap_Params.

type RootApi_blobMap_Results 

type RootApi_blobMap_Results capnp.Struct

func NewRootApi_blobMap_Results 

func NewRootApi_blobMap_Results(s *capnp.Segment) (RootApi_blobMap_Results, error)

func NewRootRootApi_blobMap_Results 

func NewRootRootApi_blobMap_Results(s *capnp.Segment) (RootApi_blobMap_Results, error)

func ReadRootRootApi_blobMap_Results 

func ReadRootRootApi_blobMap_Results(msg *capnp.Message) (RootApi_blobMap_Results, error)

func (RootApi_blobMap_Results) DecodeFromPtr 

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

func (RootApi_blobMap_Results) EncodeAsPtr 

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

func (RootApi_blobMap_Results) HasMap 

func (s RootApi_blobMap_Results) HasMap() bool

func (RootApi_blobMap_Results) IsValid 

func (s RootApi_blobMap_Results) IsValid() bool

func (RootApi_blobMap_Results) Map 

func (s RootApi_blobMap_Results) Map() Map

func (RootApi_blobMap_Results) Message 

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

func (RootApi_blobMap_Results) Segment 

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

func (RootApi_blobMap_Results) SetMap 

func (s RootApi_blobMap_Results) SetMap(v Map) error

func (RootApi_blobMap_Results) String 

func (s RootApi_blobMap_Results) String() string

func (RootApi_blobMap_Results) ToPtr 

func (s RootApi_blobMap_Results) ToPtr() capnp.Ptr

type RootApi_blobMap_Results_Future 

type RootApi_blobMap_Results_Future struct{ *capnp.Future }

RootApi_blobMap_Results_Future is a wrapper for a RootApi_blobMap_Results promised by a client call.

func (RootApi_blobMap_Results_Future) Map 

func (p RootApi_blobMap_Results_Future) Map() Map

func (RootApi_blobMap_Results_Future) Struct 

func (f RootApi_blobMap_Results_Future) Struct() (RootApi_blobMap_Results, error)

type RootApi_blobMap_Results_List 

type RootApi_blobMap_Results_List = capnp.StructList[RootApi_blobMap_Results]

RootApi_blobMap_Results_List is a list of RootApi_blobMap_Results.

func NewRootApi_blobMap_Results_List 

func NewRootApi_blobMap_Results_List(s *capnp.Segment, sz int32) (RootApi_blobMap_Results_List, error)

NewRootApi_blobMap_Results creates a new list of RootApi_blobMap_Results.

type RootApi_root 

type RootApi_root struct {
	*server.Call
}

RootApi_root holds the state for a server call to RootApi.root. See server.Call for documentation.

func (RootApi_root) AllocResults 

func (c RootApi_root) AllocResults() (RootApi_root_Results, error)

AllocResults allocates the results struct.

func (RootApi_root) Args 

func (c RootApi_root) Args() RootApi_root_Params

Args returns the call's arguments.

type RootApi_root_Params 

type RootApi_root_Params capnp.Struct

func NewRootApi_root_Params 

func NewRootApi_root_Params(s *capnp.Segment) (RootApi_root_Params, error)

func NewRootRootApi_root_Params 

func NewRootRootApi_root_Params(s *capnp.Segment) (RootApi_root_Params, error)

func ReadRootRootApi_root_Params 

func ReadRootRootApi_root_Params(msg *capnp.Message) (RootApi_root_Params, error)

func (RootApi_root_Params) DecodeFromPtr 

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

func (RootApi_root_Params) EncodeAsPtr 

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

func (RootApi_root_Params) IsValid 

func (s RootApi_root_Params) IsValid() bool

func (RootApi_root_Params) Message 

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

func (RootApi_root_Params) Segment 

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

func (RootApi_root_Params) String 

func (s RootApi_root_Params) String() string

func (RootApi_root_Params) ToPtr 

func (s RootApi_root_Params) ToPtr() capnp.Ptr

type RootApi_root_Params_Future 

type RootApi_root_Params_Future struct{ *capnp.Future }

RootApi_root_Params_Future is a wrapper for a RootApi_root_Params promised by a client call.

func (RootApi_root_Params_Future) Struct 

func (f RootApi_root_Params_Future) Struct() (RootApi_root_Params, error)

type RootApi_root_Params_List 

type RootApi_root_Params_List = capnp.StructList[RootApi_root_Params]

RootApi_root_Params_List is a list of RootApi_root_Params.

func NewRootApi_root_Params_List 

func NewRootApi_root_Params_List(s *capnp.Segment, sz int32) (RootApi_root_Params_List, error)

NewRootApi_root_Params creates a new list of RootApi_root_Params.

type RootApi_root_Results 

type RootApi_root_Results capnp.Struct

func NewRootApi_root_Results 

func NewRootApi_root_Results(s *capnp.Segment) (RootApi_root_Results, error)

func NewRootRootApi_root_Results 

func NewRootRootApi_root_Results(s *capnp.Segment) (RootApi_root_Results, error)

func ReadRootRootApi_root_Results 

func ReadRootRootApi_root_Results(msg *capnp.Message) (RootApi_root_Results, error)

func (RootApi_root_Results) DecodeFromPtr 

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

func (RootApi_root_Results) EncodeAsPtr 

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

func (RootApi_root_Results) HasRoot 

func (s RootApi_root_Results) HasRoot() bool

func (RootApi_root_Results) IsValid 

func (s RootApi_root_Results) IsValid() bool

func (RootApi_root_Results) Message 

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

func (RootApi_root_Results) Root 

func (s RootApi_root_Results) Root() RootPtr

func (RootApi_root_Results) Segment 

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

func (RootApi_root_Results) SetRoot 

func (s RootApi_root_Results) SetRoot(v RootPtr) error

func (RootApi_root_Results) String 

func (s RootApi_root_Results) String() string

func (RootApi_root_Results) ToPtr 

func (s RootApi_root_Results) ToPtr() capnp.Ptr

type RootApi_root_Results_Future 

type RootApi_root_Results_Future struct{ *capnp.Future }

RootApi_root_Results_Future is a wrapper for a RootApi_root_Results promised by a client call.

func (RootApi_root_Results_Future) Root 

func (p RootApi_root_Results_Future) Root() RootPtr

func (RootApi_root_Results_Future) Struct 

func (f RootApi_root_Results_Future) Struct() (RootApi_root_Results, error)

type RootApi_root_Results_List 

type RootApi_root_Results_List = capnp.StructList[RootApi_root_Results]

RootApi_root_Results_List is a list of RootApi_root_Results.

func NewRootApi_root_Results_List 

func NewRootApi_root_Results_List(s *capnp.Segment, sz int32) (RootApi_root_Results_List, error)

NewRootApi_root_Results creates a new list of RootApi_root_Results.

type RootApi_storage 

type RootApi_storage struct {
	*server.Call
}

RootApi_storage holds the state for a server call to RootApi.storage. See server.Call for documentation.

func (RootApi_storage) AllocResults 

func (c RootApi_storage) AllocResults() (RootApi_storage_Results, error)

AllocResults allocates the results struct.

func (RootApi_storage) Args 

func (c RootApi_storage) Args() RootApi_storage_Params

Args returns the call's arguments.

type RootApi_storage_Params 

type RootApi_storage_Params capnp.Struct

func NewRootApi_storage_Params 

func NewRootApi_storage_Params(s *capnp.Segment) (RootApi_storage_Params, error)

func NewRootRootApi_storage_Params 

func NewRootRootApi_storage_Params(s *capnp.Segment) (RootApi_storage_Params, error)

func ReadRootRootApi_storage_Params 

func ReadRootRootApi_storage_Params(msg *capnp.Message) (RootApi_storage_Params, error)

func (RootApi_storage_Params) DecodeFromPtr 

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

func (RootApi_storage_Params) EncodeAsPtr 

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

func (RootApi_storage_Params) IsValid 

func (s RootApi_storage_Params) IsValid() bool

func (RootApi_storage_Params) Message 

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

func (RootApi_storage_Params) Segment 

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

func (RootApi_storage_Params) String 

func (s RootApi_storage_Params) String() string

func (RootApi_storage_Params) ToPtr 

func (s RootApi_storage_Params) ToPtr() capnp.Ptr

type RootApi_storage_Params_Future 

type RootApi_storage_Params_Future struct{ *capnp.Future }

RootApi_storage_Params_Future is a wrapper for a RootApi_storage_Params promised by a client call.

func (RootApi_storage_Params_Future) Struct 

func (f RootApi_storage_Params_Future) Struct() (RootApi_storage_Params, error)

type RootApi_storage_Params_List 

type RootApi_storage_Params_List = capnp.StructList[RootApi_storage_Params]

RootApi_storage_Params_List is a list of RootApi_storage_Params.

func NewRootApi_storage_Params_List 

func NewRootApi_storage_Params_List(s *capnp.Segment, sz int32) (RootApi_storage_Params_List, error)

NewRootApi_storage_Params creates a new list of RootApi_storage_Params.

type RootApi_storage_Results 

type RootApi_storage_Results capnp.Struct

func NewRootApi_storage_Results 

func NewRootApi_storage_Results(s *capnp.Segment) (RootApi_storage_Results, error)

func NewRootRootApi_storage_Results 

func NewRootRootApi_storage_Results(s *capnp.Segment) (RootApi_storage_Results, error)

func ReadRootRootApi_storage_Results 

func ReadRootRootApi_storage_Results(msg *capnp.Message) (RootApi_storage_Results, error)

func (RootApi_storage_Results) DecodeFromPtr 

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

func (RootApi_storage_Results) EncodeAsPtr 

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

func (RootApi_storage_Results) HasStorage 

func (s RootApi_storage_Results) HasStorage() bool

func (RootApi_storage_Results) IsValid 

func (s RootApi_storage_Results) IsValid() bool

func (RootApi_storage_Results) Message 

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

func (RootApi_storage_Results) Segment 

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

func (RootApi_storage_Results) SetStorage 

func (s RootApi_storage_Results) SetStorage(v Storage) error

func (RootApi_storage_Results) Storage 

func (s RootApi_storage_Results) Storage() Storage

func (RootApi_storage_Results) String 

func (s RootApi_storage_Results) String() string

func (RootApi_storage_Results) ToPtr 

func (s RootApi_storage_Results) ToPtr() capnp.Ptr

type RootApi_storage_Results_Future 

type RootApi_storage_Results_Future struct{ *capnp.Future }

RootApi_storage_Results_Future is a wrapper for a RootApi_storage_Results promised by a client call.

func (RootApi_storage_Results_Future) Storage 

func (p RootApi_storage_Results_Future) Storage() Storage

func (RootApi_storage_Results_Future) Struct 

func (f RootApi_storage_Results_Future) Struct() (RootApi_storage_Results, error)

type RootApi_storage_Results_List 

type RootApi_storage_Results_List = capnp.StructList[RootApi_storage_Results]

RootApi_storage_Results_List is a list of RootApi_storage_Results.

func NewRootApi_storage_Results_List 

func NewRootApi_storage_Results_List(s *capnp.Segment, sz int32) (RootApi_storage_Results_List, error)

NewRootApi_storage_Results creates a new list of RootApi_storage_Results.

type RootPtr 

type RootPtr capnp.Client

func RootPtr_ServerToClient 

func RootPtr_ServerToClient(s RootPtr_Server) RootPtr

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

func (RootPtr) AddRef 

func (c RootPtr) AddRef() RootPtr

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

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

func (RootPtr) EncodeAsPtr 

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

func (RootPtr) Get 

func (c RootPtr) Get(ctx context.Context, params func(Getter_get_Params) error) (Getter_get_Results_Future, capnp.ReleaseFunc)

func (RootPtr) GetFlowLimiter 

func (c RootPtr) GetFlowLimiter() fc.FlowLimiter

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

func (RootPtr) IsSame 

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

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

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

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

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

func (RootPtr) Set 

func (c RootPtr) Set(ctx context.Context, params func(Setter_set_Params) error) (Setter_set_Results_Future, capnp.ReleaseFunc)

func (RootPtr) SetFlowLimiter 

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

func (c RootPtr) 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 (RootPtr) TxGet 

func (c RootPtr) TxGet(ctx context.Context, params func(TxCell_txGet_Params) error) (TxCell_txGet_Results_Future, capnp.ReleaseFunc)

func (RootPtr) WaitStreaming 

func (c RootPtr) WaitStreaming() error

type RootPtr_List 

type RootPtr_List = capnp.CapList[RootPtr]

RootPtr_List is a list of RootPtr.

func NewRootPtr_List 

func NewRootPtr_List(s *capnp.Segment, sz int32) (RootPtr_List, error)

NewRootPtr creates a new list of RootPtr.

type RootPtr_Server 

type RootPtr_Server interface {
	TxGet(context.Context, TxCell_txGet) error

	Set(context.Context, Setter_set) error

	Get(context.Context, Getter_get) error
}

A RootPtr_Server is a RootPtr with a local implementation.

type Setter 

type Setter capnp.Client

func Setter_ServerToClient 

func Setter_ServerToClient(s Setter_Server) Setter

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

func (Setter) AddRef 

func (c Setter) AddRef() Setter

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

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

func (Setter) EncodeAsPtr 

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

func (Setter) GetFlowLimiter 

func (c Setter) GetFlowLimiter() fc.FlowLimiter

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

func (Setter) IsSame 

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

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

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

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

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

func (Setter) Set 

func (c Setter) Set(ctx context.Context, params func(Setter_set_Params) error) (Setter_set_Results_Future, capnp.ReleaseFunc)

func (Setter) SetFlowLimiter 

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

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

func (c Setter) WaitStreaming() error

type Setter_List 

type Setter_List = capnp.CapList[Setter]

Setter_List is a list of Setter.

func NewSetter_List 

func NewSetter_List(s *capnp.Segment, sz int32) (Setter_List, error)

NewSetter creates a new list of Setter.

type Setter_Server 

type Setter_Server interface {
	Set(context.Context, Setter_set) error
}

A Setter_Server is a Setter with a local implementation.

type Setter_set 

type Setter_set struct {
	*server.Call
}

Setter_set holds the state for a server call to Setter.set. See server.Call for documentation.

func (Setter_set) AllocResults 

func (c Setter_set) AllocResults() (Setter_set_Results, error)

AllocResults allocates the results struct.

func (Setter_set) Args 

func (c Setter_set) Args() Setter_set_Params

Args returns the call's arguments.

type Setter_set_Params 

type Setter_set_Params capnp.Struct

func NewRootSetter_set_Params 

func NewRootSetter_set_Params(s *capnp.Segment) (Setter_set_Params, error)

func NewSetter_set_Params 

func NewSetter_set_Params(s *capnp.Segment) (Setter_set_Params, error)

func ReadRootSetter_set_Params 

func ReadRootSetter_set_Params(msg *capnp.Message) (Setter_set_Params, error)

func (Setter_set_Params) DecodeFromPtr 

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

func (Setter_set_Params) EncodeAsPtr 

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

func (Setter_set_Params) HasValue 

func (s Setter_set_Params) HasValue() bool

func (Setter_set_Params) IsValid 

func (s Setter_set_Params) IsValid() bool

func (Setter_set_Params) Message 

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

func (Setter_set_Params) Segment 

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

func (Setter_set_Params) SetValue 

func (s Setter_set_Params) SetValue(v capnp.Ptr) error

func (Setter_set_Params) String 

func (s Setter_set_Params) String() string

func (Setter_set_Params) ToPtr 

func (s Setter_set_Params) ToPtr() capnp.Ptr

func (Setter_set_Params) Value 

func (s Setter_set_Params) Value() (capnp.Ptr, error)

type Setter_set_Params_Future 

type Setter_set_Params_Future struct{ *capnp.Future }

Setter_set_Params_Future is a wrapper for a Setter_set_Params promised by a client call.

func (Setter_set_Params_Future) Struct 

func (f Setter_set_Params_Future) Struct() (Setter_set_Params, error)

func (Setter_set_Params_Future) Value 

func (p Setter_set_Params_Future) Value() *capnp.Future

type Setter_set_Params_List 

type Setter_set_Params_List = capnp.StructList[Setter_set_Params]

Setter_set_Params_List is a list of Setter_set_Params.

func NewSetter_set_Params_List 

func NewSetter_set_Params_List(s *capnp.Segment, sz int32) (Setter_set_Params_List, error)

NewSetter_set_Params creates a new list of Setter_set_Params.

type Setter_set_Results 

type Setter_set_Results capnp.Struct

func NewRootSetter_set_Results 

func NewRootSetter_set_Results(s *capnp.Segment) (Setter_set_Results, error)

func NewSetter_set_Results 

func NewSetter_set_Results(s *capnp.Segment) (Setter_set_Results, error)

func ReadRootSetter_set_Results 

func ReadRootSetter_set_Results(msg *capnp.Message) (Setter_set_Results, error)

func (Setter_set_Results) DecodeFromPtr 

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

func (Setter_set_Results) EncodeAsPtr 

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

func (Setter_set_Results) IsValid 

func (s Setter_set_Results) IsValid() bool

func (Setter_set_Results) Message 

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

func (Setter_set_Results) Segment 

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

func (Setter_set_Results) String 

func (s Setter_set_Results) String() string

func (Setter_set_Results) ToPtr 

func (s Setter_set_Results) ToPtr() capnp.Ptr

type Setter_set_Results_Future 

type Setter_set_Results_Future struct{ *capnp.Future }

Setter_set_Results_Future is a wrapper for a Setter_set_Results promised by a client call.

func (Setter_set_Results_Future) Struct 

func (f Setter_set_Results_Future) Struct() (Setter_set_Results, error)

type Setter_set_Results_List 

type Setter_set_Results_List = capnp.StructList[Setter_set_Results]

Setter_set_Results_List is a list of Setter_set_Results.

func NewSetter_set_Results_List 

func NewSetter_set_Results_List(s *capnp.Segment, sz int32) (Setter_set_Results_List, error)

NewSetter_set_Results creates a new list of Setter_set_Results.

type Storage 

type Storage capnp.Client

func Storage_ServerToClient 

func Storage_ServerToClient(s Storage_Server) Storage

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

func (Storage) AddRef 

func (c Storage) AddRef() Storage

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

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

func (Storage) EncodeAsPtr 

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

func (Storage) GetFlowLimiter 

func (c Storage) GetFlowLimiter() fc.FlowLimiter

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

func (Storage) IsSame 

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

func (c Storage) 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 (Storage) Put 

func (c Storage) Put(ctx context.Context, params func(Storage_put_Params) error) (Storage_put_Results_Future, capnp.ReleaseFunc)

func (Storage) Release 

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

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

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

func (Storage) SetFlowLimiter 

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

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

func (c Storage) WaitStreaming() error

type Storage_List 

type Storage_List = capnp.CapList[Storage]

Storage_List is a list of Storage.

func NewStorage_List 

func NewStorage_List(s *capnp.Segment, sz int32) (Storage_List, error)

NewStorage creates a new list of Storage.

type Storage_Server 

type Storage_Server interface {
	Put(context.Context, Storage_put) error
}

A Storage_Server is a Storage with a local implementation.

type Storage_put 

type Storage_put struct {
	*server.Call
}

Storage_put holds the state for a server call to Storage.put. See server.Call for documentation.

func (Storage_put) AllocResults 

func (c Storage_put) AllocResults() (Storage_put_Results, error)

AllocResults allocates the results struct.

func (Storage_put) Args 

func (c Storage_put) Args() Storage_put_Params

Args returns the call's arguments.

type Storage_put_Params 

type Storage_put_Params capnp.Struct

func NewRootStorage_put_Params 

func NewRootStorage_put_Params(s *capnp.Segment) (Storage_put_Params, error)

func NewStorage_put_Params 

func NewStorage_put_Params(s *capnp.Segment) (Storage_put_Params, error)

func ReadRootStorage_put_Params 

func ReadRootStorage_put_Params(msg *capnp.Message) (Storage_put_Params, error)

func (Storage_put_Params) DecodeFromPtr 

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

func (Storage_put_Params) EncodeAsPtr 

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

func (Storage_put_Params) HasValue 

func (s Storage_put_Params) HasValue() bool

func (Storage_put_Params) IsValid 

func (s Storage_put_Params) IsValid() bool

func (Storage_put_Params) Message 

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

func (Storage_put_Params) Segment 

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

func (Storage_put_Params) SetValue 

func (s Storage_put_Params) SetValue(v capnp.Ptr) error

func (Storage_put_Params) String 

func (s Storage_put_Params) String() string

func (Storage_put_Params) ToPtr 

func (s Storage_put_Params) ToPtr() capnp.Ptr

func (Storage_put_Params) Value 

func (s Storage_put_Params) Value() (capnp.Ptr, error)

type Storage_put_Params_Future 

type Storage_put_Params_Future struct{ *capnp.Future }

Storage_put_Params_Future is a wrapper for a Storage_put_Params promised by a client call.

func (Storage_put_Params_Future) Struct 

func (f Storage_put_Params_Future) Struct() (Storage_put_Params, error)

func (Storage_put_Params_Future) Value 

func (p Storage_put_Params_Future) Value() *capnp.Future

type Storage_put_Params_List 

type Storage_put_Params_List = capnp.StructList[Storage_put_Params]

Storage_put_Params_List is a list of Storage_put_Params.

func NewStorage_put_Params_List 

func NewStorage_put_Params_List(s *capnp.Segment, sz int32) (Storage_put_Params_List, error)

NewStorage_put_Params creates a new list of Storage_put_Params.

type Storage_put_Results 

type Storage_put_Results capnp.Struct

func NewRootStorage_put_Results 

func NewRootStorage_put_Results(s *capnp.Segment) (Storage_put_Results, error)

func NewStorage_put_Results 

func NewStorage_put_Results(s *capnp.Segment) (Storage_put_Results, error)

func ReadRootStorage_put_Results 

func ReadRootStorage_put_Results(msg *capnp.Message) (Storage_put_Results, error)

func (Storage_put_Results) DecodeFromPtr 

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

func (Storage_put_Results) EncodeAsPtr 

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

func (Storage_put_Results) HasRef 

func (s Storage_put_Results) HasRef() bool

func (Storage_put_Results) IsValid 

func (s Storage_put_Results) IsValid() bool

func (Storage_put_Results) Message 

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

func (Storage_put_Results) Ref 

func (s Storage_put_Results) Ref() Ref

func (Storage_put_Results) Segment 

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

func (Storage_put_Results) SetRef 

func (s Storage_put_Results) SetRef(v Ref) error

func (Storage_put_Results) String 

func (s Storage_put_Results) String() string

func (Storage_put_Results) ToPtr 

func (s Storage_put_Results) ToPtr() capnp.Ptr

type Storage_put_Results_Future 

type Storage_put_Results_Future struct{ *capnp.Future }

Storage_put_Results_Future is a wrapper for a Storage_put_Results promised by a client call.

func (Storage_put_Results_Future) Ref 

func (p Storage_put_Results_Future) Ref() Ref

func (Storage_put_Results_Future) Struct 

func (f Storage_put_Results_Future) Struct() (Storage_put_Results, error)

type Storage_put_Results_List 

type Storage_put_Results_List = capnp.StructList[Storage_put_Results]

Storage_put_Results_List is a list of Storage_put_Results.

func NewStorage_put_Results_List 

func NewStorage_put_Results_List(s *capnp.Segment, sz int32) (Storage_put_Results_List, error)

NewStorage_put_Results creates a new list of Storage_put_Results.

type Stored 

type Stored capnp.Struct

func NewRootStored 

func NewRootStored(s *capnp.Segment) (Stored, error)

func NewStored 

func NewStored(s *capnp.Segment) (Stored, error)

func ReadRootStored 

func ReadRootStored(msg *capnp.Message) (Stored, error)

func (Stored) Data 

func (s Stored) Data() (capnp.Ptr, error)

func (Stored) DecodeFromPtr 

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

func (Stored) EncodeAsPtr 

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

func (Stored) HasData 

func (s Stored) HasData() bool

func (Stored) HasRefs 

func (s Stored) HasRefs() bool

func (Stored) IsValid 

func (s Stored) IsValid() bool

func (Stored) Message 

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

func (Stored) NewRefs 

func (s Stored) NewRefs(n int32) (ContentId_List, error)

NewRefs sets the refs field to a newly allocated ContentId_List, preferring placement in s's segment.

func (Stored) Refs 

func (s Stored) Refs() (ContentId_List, error)

func (Stored) Segment 

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

func (Stored) SetData 

func (s Stored) SetData(v capnp.Ptr) error

func (Stored) SetRefs 

func (s Stored) SetRefs(v ContentId_List) error

func (Stored) String 

func (s Stored) String() string

func (Stored) ToPtr 

func (s Stored) ToPtr() capnp.Ptr

type Stored_Future 

type Stored_Future struct{ *capnp.Future }

Stored_Future is a wrapper for a Stored promised by a client call.

func (Stored_Future) Data 

func (p Stored_Future) Data() *capnp.Future

func (Stored_Future) Struct 

func (f Stored_Future) Struct() (Stored, error)

type Stored_List 

type Stored_List = capnp.StructList[Stored]

Stored_List is a list of Stored.

func NewStored_List 

func NewStored_List(s *capnp.Segment, sz int32) (Stored_List, error)

NewStored creates a new list of Stored.

type TxCell 

type TxCell capnp.Client

func TxCell_ServerToClient 

func TxCell_ServerToClient(s TxCell_Server) TxCell

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

func (TxCell) AddRef 

func (c TxCell) AddRef() TxCell

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

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

func (TxCell) EncodeAsPtr 

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

func (TxCell) Get 

func (c TxCell) Get(ctx context.Context, params func(Getter_get_Params) error) (Getter_get_Results_Future, capnp.ReleaseFunc)

func (TxCell) GetFlowLimiter 

func (c TxCell) GetFlowLimiter() fc.FlowLimiter

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

func (TxCell) IsSame 

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

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

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

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

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

func (TxCell) Set 

func (c TxCell) Set(ctx context.Context, params func(Setter_set_Params) error) (Setter_set_Results_Future, capnp.ReleaseFunc)

func (TxCell) SetFlowLimiter 

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

func (c TxCell) 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 (TxCell) TxGet 

func (c TxCell) TxGet(ctx context.Context, params func(TxCell_txGet_Params) error) (TxCell_txGet_Results_Future, capnp.ReleaseFunc)

func (TxCell) WaitStreaming 

func (c TxCell) WaitStreaming() error

type TxCell_List 

type TxCell_List = capnp.CapList[TxCell]

TxCell_List is a list of TxCell.

func NewTxCell_List 

func NewTxCell_List(s *capnp.Segment, sz int32) (TxCell_List, error)

NewTxCell creates a new list of TxCell.

type TxCell_Server 

type TxCell_Server interface {
	TxGet(context.Context, TxCell_txGet) error

	Set(context.Context, Setter_set) error

	Get(context.Context, Getter_get) error
}

A TxCell_Server is a TxCell with a local implementation.

type TxCell_txGet 

type TxCell_txGet struct {
	*server.Call
}

TxCell_txGet holds the state for a server call to TxCell.txGet. See server.Call for documentation.

func (TxCell_txGet) AllocResults 

func (c TxCell_txGet) AllocResults() (TxCell_txGet_Results, error)

AllocResults allocates the results struct.

func (TxCell_txGet) Args 

func (c TxCell_txGet) Args() TxCell_txGet_Params

Args returns the call's arguments.

type TxCell_txGet_Params 

type TxCell_txGet_Params capnp.Struct

func NewRootTxCell_txGet_Params 

func NewRootTxCell_txGet_Params(s *capnp.Segment) (TxCell_txGet_Params, error)

func NewTxCell_txGet_Params 

func NewTxCell_txGet_Params(s *capnp.Segment) (TxCell_txGet_Params, error)

func ReadRootTxCell_txGet_Params 

func ReadRootTxCell_txGet_Params(msg *capnp.Message) (TxCell_txGet_Params, error)

func (TxCell_txGet_Params) DecodeFromPtr 

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

func (TxCell_txGet_Params) EncodeAsPtr 

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

func (TxCell_txGet_Params) IsValid 

func (s TxCell_txGet_Params) IsValid() bool

func (TxCell_txGet_Params) Message 

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

func (TxCell_txGet_Params) Segment 

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

func (TxCell_txGet_Params) String 

func (s TxCell_txGet_Params) String() string

func (TxCell_txGet_Params) ToPtr 

func (s TxCell_txGet_Params) ToPtr() capnp.Ptr

type TxCell_txGet_Params_Future 

type TxCell_txGet_Params_Future struct{ *capnp.Future }

TxCell_txGet_Params_Future is a wrapper for a TxCell_txGet_Params promised by a client call.

func (TxCell_txGet_Params_Future) Struct 

func (f TxCell_txGet_Params_Future) Struct() (TxCell_txGet_Params, error)

type TxCell_txGet_Params_List 

type TxCell_txGet_Params_List = capnp.StructList[TxCell_txGet_Params]

TxCell_txGet_Params_List is a list of TxCell_txGet_Params.

func NewTxCell_txGet_Params_List 

func NewTxCell_txGet_Params_List(s *capnp.Segment, sz int32) (TxCell_txGet_Params_List, error)

NewTxCell_txGet_Params creates a new list of TxCell_txGet_Params.

type TxCell_txGet_Results 

type TxCell_txGet_Results capnp.Struct

func NewRootTxCell_txGet_Results 

func NewRootTxCell_txGet_Results(s *capnp.Segment) (TxCell_txGet_Results, error)

func NewTxCell_txGet_Results 

func NewTxCell_txGet_Results(s *capnp.Segment) (TxCell_txGet_Results, error)

func ReadRootTxCell_txGet_Results 

func ReadRootTxCell_txGet_Results(msg *capnp.Message) (TxCell_txGet_Results, error)

func (TxCell_txGet_Results) DecodeFromPtr 

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

func (TxCell_txGet_Results) EncodeAsPtr 

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

func (TxCell_txGet_Results) HasSetter 

func (s TxCell_txGet_Results) HasSetter() bool

func (TxCell_txGet_Results) HasValue 

func (s TxCell_txGet_Results) HasValue() bool

func (TxCell_txGet_Results) IsValid 

func (s TxCell_txGet_Results) IsValid() bool

func (TxCell_txGet_Results) Message 

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

func (TxCell_txGet_Results) Segment 

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

func (TxCell_txGet_Results) SetSetter 

func (s TxCell_txGet_Results) SetSetter(v Setter) error

func (TxCell_txGet_Results) SetValue 

func (s TxCell_txGet_Results) SetValue(v capnp.Ptr) error

func (TxCell_txGet_Results) Setter 

func (s TxCell_txGet_Results) Setter() Setter

func (TxCell_txGet_Results) String 

func (s TxCell_txGet_Results) String() string

func (TxCell_txGet_Results) ToPtr 

func (s TxCell_txGet_Results) ToPtr() capnp.Ptr

func (TxCell_txGet_Results) Value 

func (s TxCell_txGet_Results) Value() (capnp.Ptr, error)

type TxCell_txGet_Results_Future 

type TxCell_txGet_Results_Future struct{ *capnp.Future }

TxCell_txGet_Results_Future is a wrapper for a TxCell_txGet_Results promised by a client call.

func (TxCell_txGet_Results_Future) Setter 

func (p TxCell_txGet_Results_Future) Setter() Setter

func (TxCell_txGet_Results_Future) Struct 

func (f TxCell_txGet_Results_Future) Struct() (TxCell_txGet_Results, error)

func (TxCell_txGet_Results_Future) Value 

func (p TxCell_txGet_Results_Future) Value() *capnp.Future

type TxCell_txGet_Results_List 

type TxCell_txGet_Results_List = capnp.StructList[TxCell_txGet_Results]

TxCell_txGet_Results_List is a list of TxCell_txGet_Results.

func NewTxCell_txGet_Results_List 

func NewTxCell_txGet_Results_List(s *capnp.Segment, sz int32) (TxCell_txGet_Results_List, error)

NewTxCell_txGet_Results creates a new list of TxCell_txGet_Results.

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.