testcapnp

package
v3.0.0-alpha-29 Latest Latest
Warning

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

 Go to latest Published: May 16, 2023 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const CapArgsTest_TypeID = 0xb86bce7f916a10cc

CapArgsTest_TypeID is the unique identifier for the type CapArgsTest.

View Source 
const CapArgsTest_call_Params_TypeID = 0x80087e4e698768a2

CapArgsTest_call_Params_TypeID is the unique identifier for the type CapArgsTest_call_Params.

View Source 
const CapArgsTest_call_Results_TypeID = 0x96fbc50dc2f0200d

CapArgsTest_call_Results_TypeID is the unique identifier for the type CapArgsTest_call_Results.

View Source 
const CapArgsTest_self_Params_TypeID = 0xe2553e5a663abb7d

CapArgsTest_self_Params_TypeID is the unique identifier for the type CapArgsTest_self_Params.

View Source 
const CapArgsTest_self_Results_TypeID = 0x9746cc05cbff1132

CapArgsTest_self_Results_TypeID is the unique identifier for the type CapArgsTest_self_Results.

View Source 
const EmptyProvider_TypeID = 0xea38d4d6dca1e80e

EmptyProvider_TypeID is the unique identifier for the type EmptyProvider.

View Source 
const EmptyProvider_getEmpty_Params_TypeID = 0x9a27082d77b8c289

EmptyProvider_getEmpty_Params_TypeID is the unique identifier for the type EmptyProvider_getEmpty_Params.

View Source 
const EmptyProvider_getEmpty_Results_TypeID = 0x93281cc60d6060cd

EmptyProvider_getEmpty_Results_TypeID is the unique identifier for the type EmptyProvider_getEmpty_Results.

View Source 
const Empty_TypeID = 0xc8b14e937b2cb741

Empty_TypeID is the unique identifier for the type Empty.

View Source 
const PingPongProvider_TypeID = 0x95b6142577e93239

PingPongProvider_TypeID is the unique identifier for the type PingPongProvider.

View Source 
const PingPongProvider_pingPong_Params_TypeID = 0xd4e835c17f1ef32c

PingPongProvider_pingPong_Params_TypeID is the unique identifier for the type PingPongProvider_pingPong_Params.

View Source 
const PingPongProvider_pingPong_Results_TypeID = 0xf269473b6db8d0eb

PingPongProvider_pingPong_Results_TypeID is the unique identifier for the type PingPongProvider_pingPong_Results.

View Source 
const PingPong_TypeID = 0xf004c474c2f8ee7a

PingPong_TypeID is the unique identifier for the type PingPong.

View Source 
const PingPong_echoNum_Params_TypeID = 0xd797e0a99edf0921

PingPong_echoNum_Params_TypeID is the unique identifier for the type PingPong_echoNum_Params.

View Source 
const PingPong_echoNum_Results_TypeID = 0x85ddfd96db252600

PingPong_echoNum_Results_TypeID is the unique identifier for the type PingPong_echoNum_Results.

View Source 
const StreamTest_TypeID = 0xbb3ca85b01eea465

StreamTest_TypeID is the unique identifier for the type StreamTest.

View Source 
const StreamTest_push_Params_TypeID = 0xf838dca6c8721bdb

StreamTest_push_Params_TypeID is the unique identifier for the type StreamTest_push_Params.

Variables

This section is empty.

Functions

func CapArgsTest_Methods 

func CapArgsTest_Methods(methods []server.Method, s CapArgsTest_Server) []server.Method

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

func CapArgsTest_NewServer 

func CapArgsTest_NewServer(s CapArgsTest_Server) *server.Server

CapArgsTest_NewServer creates a new Server from an implementation of CapArgsTest_Server.

func EmptyProvider_Methods 

func EmptyProvider_Methods(methods []server.Method, s EmptyProvider_Server) []server.Method

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

func EmptyProvider_NewServer 

func EmptyProvider_NewServer(s EmptyProvider_Server) *server.Server

EmptyProvider_NewServer creates a new Server from an implementation of EmptyProvider_Server.

func Empty_Methods 

func Empty_Methods(methods []server.Method, s Empty_Server) []server.Method

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

func Empty_NewServer 

func Empty_NewServer(s Empty_Server) *server.Server

Empty_NewServer creates a new Server from an implementation of Empty_Server.

func PingPongProvider_Methods 

func PingPongProvider_Methods(methods []server.Method, s PingPongProvider_Server) []server.Method

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

func PingPongProvider_NewServer 

func PingPongProvider_NewServer(s PingPongProvider_Server) *server.Server

PingPongProvider_NewServer creates a new Server from an implementation of PingPongProvider_Server.

func PingPong_Methods 

func PingPong_Methods(methods []server.Method, s PingPong_Server) []server.Method

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

func PingPong_NewServer 

func PingPong_NewServer(s PingPong_Server) *server.Server

PingPong_NewServer creates a new Server from an implementation of PingPong_Server.

func RegisterSchema 

func RegisterSchema(reg *schemas.Registry)

func StreamTest_Methods 

func StreamTest_Methods(methods []server.Method, s StreamTest_Server) []server.Method

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

func StreamTest_NewServer 

func StreamTest_NewServer(s StreamTest_Server) *server.Server

StreamTest_NewServer creates a new Server from an implementation of StreamTest_Server.

Types

type CapArgsTest 

type CapArgsTest capnp.Client

func CapArgsTest_ServerToClient 

func CapArgsTest_ServerToClient(s CapArgsTest_Server) CapArgsTest

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

func (CapArgsTest) AddRef 

func (c CapArgsTest) AddRef() CapArgsTest

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 (CapArgsTest) Call 

func (c CapArgsTest) Call(ctx context.Context, params func(CapArgsTest_call_Params) error) (CapArgsTest_call_Results_Future, capnp.ReleaseFunc)

func (CapArgsTest) DecodeFromPtr 

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

func (CapArgsTest) EncodeAsPtr 

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

func (CapArgsTest) GetFlowLimiter 

func (c CapArgsTest) GetFlowLimiter() fc.FlowLimiter

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

func (CapArgsTest) IsSame 

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

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

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

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

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

func (CapArgsTest) Self 

func (c CapArgsTest) Self(ctx context.Context, params func(CapArgsTest_self_Params) error) (CapArgsTest_self_Results_Future, capnp.ReleaseFunc)

func (CapArgsTest) SetFlowLimiter 

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

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

func (c CapArgsTest) WaitStreaming() error

type CapArgsTest_List 

type CapArgsTest_List = capnp.CapList[CapArgsTest]

CapArgsTest_List is a list of CapArgsTest.

func NewCapArgsTest_List 

func NewCapArgsTest_List(s *capnp.Segment, sz int32) (CapArgsTest_List, error)

NewCapArgsTest creates a new list of CapArgsTest.

type CapArgsTest_Server 

type CapArgsTest_Server interface {
	Call(context.Context, CapArgsTest_call) error

	Self(context.Context, CapArgsTest_self) error
}

A CapArgsTest_Server is a CapArgsTest with a local implementation.

type CapArgsTest_call 

type CapArgsTest_call struct {
	*server.Call
}

CapArgsTest_call holds the state for a server call to CapArgsTest.call. See server.Call for documentation.

func (CapArgsTest_call) AllocResults 

func (c CapArgsTest_call) AllocResults() (CapArgsTest_call_Results, error)

AllocResults allocates the results struct.

func (CapArgsTest_call) Args 

func (c CapArgsTest_call) Args() CapArgsTest_call_Params

Args returns the call's arguments.

type CapArgsTest_call_Params 

type CapArgsTest_call_Params capnp.Struct

func NewCapArgsTest_call_Params 

func NewCapArgsTest_call_Params(s *capnp.Segment) (CapArgsTest_call_Params, error)

func NewRootCapArgsTest_call_Params 

func NewRootCapArgsTest_call_Params(s *capnp.Segment) (CapArgsTest_call_Params, error)

func ReadRootCapArgsTest_call_Params 

func ReadRootCapArgsTest_call_Params(msg *capnp.Message) (CapArgsTest_call_Params, error)

func (CapArgsTest_call_Params) Cap 

func (s CapArgsTest_call_Params) Cap() capnp.Client

func (CapArgsTest_call_Params) DecodeFromPtr 

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

func (CapArgsTest_call_Params) EncodeAsPtr 

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

func (CapArgsTest_call_Params) HasCap 

func (s CapArgsTest_call_Params) HasCap() bool

func (CapArgsTest_call_Params) IsValid 

func (s CapArgsTest_call_Params) IsValid() bool

func (CapArgsTest_call_Params) Message 

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

func (CapArgsTest_call_Params) Segment 

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

func (CapArgsTest_call_Params) SetCap 

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

func (CapArgsTest_call_Params) String 

func (s CapArgsTest_call_Params) String() string

func (CapArgsTest_call_Params) ToPtr 

func (s CapArgsTest_call_Params) ToPtr() capnp.Ptr

type CapArgsTest_call_Params_Future 

type CapArgsTest_call_Params_Future struct{ *capnp.Future }

CapArgsTest_call_Params_Future is a wrapper for a CapArgsTest_call_Params promised by a client call.

func (CapArgsTest_call_Params_Future) Cap 

func (p CapArgsTest_call_Params_Future) Cap() capnp.Client

func (CapArgsTest_call_Params_Future) Struct 

func (f CapArgsTest_call_Params_Future) Struct() (CapArgsTest_call_Params, error)

type CapArgsTest_call_Params_List 

type CapArgsTest_call_Params_List = capnp.StructList[CapArgsTest_call_Params]

CapArgsTest_call_Params_List is a list of CapArgsTest_call_Params.

func NewCapArgsTest_call_Params_List 

func NewCapArgsTest_call_Params_List(s *capnp.Segment, sz int32) (CapArgsTest_call_Params_List, error)

NewCapArgsTest_call_Params creates a new list of CapArgsTest_call_Params.

type CapArgsTest_call_Results 

type CapArgsTest_call_Results capnp.Struct

func NewCapArgsTest_call_Results 

func NewCapArgsTest_call_Results(s *capnp.Segment) (CapArgsTest_call_Results, error)

func NewRootCapArgsTest_call_Results 

func NewRootCapArgsTest_call_Results(s *capnp.Segment) (CapArgsTest_call_Results, error)

func ReadRootCapArgsTest_call_Results 

func ReadRootCapArgsTest_call_Results(msg *capnp.Message) (CapArgsTest_call_Results, error)

func (CapArgsTest_call_Results) DecodeFromPtr 

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

func (CapArgsTest_call_Results) EncodeAsPtr 

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

func (CapArgsTest_call_Results) IsValid 

func (s CapArgsTest_call_Results) IsValid() bool

func (CapArgsTest_call_Results) Message 

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

func (CapArgsTest_call_Results) Segment 

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

func (CapArgsTest_call_Results) String 

func (s CapArgsTest_call_Results) String() string

func (CapArgsTest_call_Results) ToPtr 

func (s CapArgsTest_call_Results) ToPtr() capnp.Ptr

type CapArgsTest_call_Results_Future 

type CapArgsTest_call_Results_Future struct{ *capnp.Future }

CapArgsTest_call_Results_Future is a wrapper for a CapArgsTest_call_Results promised by a client call.

func (CapArgsTest_call_Results_Future) Struct 

func (f CapArgsTest_call_Results_Future) Struct() (CapArgsTest_call_Results, error)

type CapArgsTest_call_Results_List 

type CapArgsTest_call_Results_List = capnp.StructList[CapArgsTest_call_Results]

CapArgsTest_call_Results_List is a list of CapArgsTest_call_Results.

func NewCapArgsTest_call_Results_List 

func NewCapArgsTest_call_Results_List(s *capnp.Segment, sz int32) (CapArgsTest_call_Results_List, error)

NewCapArgsTest_call_Results creates a new list of CapArgsTest_call_Results.

type CapArgsTest_self 

type CapArgsTest_self struct {
	*server.Call
}

CapArgsTest_self holds the state for a server call to CapArgsTest.self. See server.Call for documentation.

func (CapArgsTest_self) AllocResults 

func (c CapArgsTest_self) AllocResults() (CapArgsTest_self_Results, error)

AllocResults allocates the results struct.

func (CapArgsTest_self) Args 

func (c CapArgsTest_self) Args() CapArgsTest_self_Params

Args returns the call's arguments.

type CapArgsTest_self_Params 

type CapArgsTest_self_Params capnp.Struct

func NewCapArgsTest_self_Params 

func NewCapArgsTest_self_Params(s *capnp.Segment) (CapArgsTest_self_Params, error)

func NewRootCapArgsTest_self_Params 

func NewRootCapArgsTest_self_Params(s *capnp.Segment) (CapArgsTest_self_Params, error)

func ReadRootCapArgsTest_self_Params 

func ReadRootCapArgsTest_self_Params(msg *capnp.Message) (CapArgsTest_self_Params, error)

func (CapArgsTest_self_Params) DecodeFromPtr 

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

func (CapArgsTest_self_Params) EncodeAsPtr 

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

func (CapArgsTest_self_Params) IsValid 

func (s CapArgsTest_self_Params) IsValid() bool

func (CapArgsTest_self_Params) Message 

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

func (CapArgsTest_self_Params) Segment 

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

func (CapArgsTest_self_Params) String 

func (s CapArgsTest_self_Params) String() string

func (CapArgsTest_self_Params) ToPtr 

func (s CapArgsTest_self_Params) ToPtr() capnp.Ptr

type CapArgsTest_self_Params_Future 

type CapArgsTest_self_Params_Future struct{ *capnp.Future }

CapArgsTest_self_Params_Future is a wrapper for a CapArgsTest_self_Params promised by a client call.

func (CapArgsTest_self_Params_Future) Struct 

func (f CapArgsTest_self_Params_Future) Struct() (CapArgsTest_self_Params, error)

type CapArgsTest_self_Params_List 

type CapArgsTest_self_Params_List = capnp.StructList[CapArgsTest_self_Params]

CapArgsTest_self_Params_List is a list of CapArgsTest_self_Params.

func NewCapArgsTest_self_Params_List 

func NewCapArgsTest_self_Params_List(s *capnp.Segment, sz int32) (CapArgsTest_self_Params_List, error)

NewCapArgsTest_self_Params creates a new list of CapArgsTest_self_Params.

type CapArgsTest_self_Results 

type CapArgsTest_self_Results capnp.Struct

func NewCapArgsTest_self_Results 

func NewCapArgsTest_self_Results(s *capnp.Segment) (CapArgsTest_self_Results, error)

func NewRootCapArgsTest_self_Results 

func NewRootCapArgsTest_self_Results(s *capnp.Segment) (CapArgsTest_self_Results, error)

func ReadRootCapArgsTest_self_Results 

func ReadRootCapArgsTest_self_Results(msg *capnp.Message) (CapArgsTest_self_Results, error)

func (CapArgsTest_self_Results) DecodeFromPtr 

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

func (CapArgsTest_self_Results) EncodeAsPtr 

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

func (CapArgsTest_self_Results) HasSelf 

func (s CapArgsTest_self_Results) HasSelf() bool

func (CapArgsTest_self_Results) IsValid 

func (s CapArgsTest_self_Results) IsValid() bool

func (CapArgsTest_self_Results) Message 

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

func (CapArgsTest_self_Results) Segment 

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

func (CapArgsTest_self_Results) Self 

func (s CapArgsTest_self_Results) Self() CapArgsTest

func (CapArgsTest_self_Results) SetSelf 

func (s CapArgsTest_self_Results) SetSelf(v CapArgsTest) error

func (CapArgsTest_self_Results) String 

func (s CapArgsTest_self_Results) String() string

func (CapArgsTest_self_Results) ToPtr 

func (s CapArgsTest_self_Results) ToPtr() capnp.Ptr

type CapArgsTest_self_Results_Future 

type CapArgsTest_self_Results_Future struct{ *capnp.Future }

CapArgsTest_self_Results_Future is a wrapper for a CapArgsTest_self_Results promised by a client call.

func (CapArgsTest_self_Results_Future) Self 

func (p CapArgsTest_self_Results_Future) Self() CapArgsTest

func (CapArgsTest_self_Results_Future) Struct 

func (f CapArgsTest_self_Results_Future) Struct() (CapArgsTest_self_Results, error)

type CapArgsTest_self_Results_List 

type CapArgsTest_self_Results_List = capnp.StructList[CapArgsTest_self_Results]

CapArgsTest_self_Results_List is a list of CapArgsTest_self_Results.

func NewCapArgsTest_self_Results_List 

func NewCapArgsTest_self_Results_List(s *capnp.Segment, sz int32) (CapArgsTest_self_Results_List, error)

NewCapArgsTest_self_Results creates a new list of CapArgsTest_self_Results.

type Empty 

type Empty capnp.Client

func Empty_ServerToClient 

func Empty_ServerToClient(s Empty_Server) Empty

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

func (Empty) AddRef 

func (c Empty) AddRef() Empty

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

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

func (Empty) EncodeAsPtr 

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

func (Empty) GetFlowLimiter 

func (c Empty) GetFlowLimiter() fc.FlowLimiter

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

func (Empty) IsSame 

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

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

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

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

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

func (Empty) SetFlowLimiter 

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

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

func (c Empty) WaitStreaming() error

type EmptyProvider 

type EmptyProvider capnp.Client

func EmptyProvider_ServerToClient 

func EmptyProvider_ServerToClient(s EmptyProvider_Server) EmptyProvider

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

func (EmptyProvider) AddRef 

func (c EmptyProvider) AddRef() EmptyProvider

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

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

func (EmptyProvider) EncodeAsPtr 

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

func (EmptyProvider) GetEmpty 

func (c EmptyProvider) GetEmpty(ctx context.Context, params func(EmptyProvider_getEmpty_Params) error) (EmptyProvider_getEmpty_Results_Future, capnp.ReleaseFunc)

func (EmptyProvider) GetFlowLimiter 

func (c EmptyProvider) GetFlowLimiter() fc.FlowLimiter

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

func (EmptyProvider) IsSame 

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

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

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

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

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

func (EmptyProvider) SetFlowLimiter 

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

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

func (c EmptyProvider) WaitStreaming() error

type EmptyProvider_List 

type EmptyProvider_List = capnp.CapList[EmptyProvider]

EmptyProvider_List is a list of EmptyProvider.

func NewEmptyProvider_List 

func NewEmptyProvider_List(s *capnp.Segment, sz int32) (EmptyProvider_List, error)

NewEmptyProvider creates a new list of EmptyProvider.

type EmptyProvider_Server 

type EmptyProvider_Server interface {
	GetEmpty(context.Context, EmptyProvider_getEmpty) error
}

A EmptyProvider_Server is a EmptyProvider with a local implementation.

type EmptyProvider_getEmpty 

type EmptyProvider_getEmpty struct {
	*server.Call
}

EmptyProvider_getEmpty holds the state for a server call to EmptyProvider.getEmpty. See server.Call for documentation.

func (EmptyProvider_getEmpty) AllocResults 

func (c EmptyProvider_getEmpty) AllocResults() (EmptyProvider_getEmpty_Results, error)

AllocResults allocates the results struct.

func (EmptyProvider_getEmpty) Args 

func (c EmptyProvider_getEmpty) Args() EmptyProvider_getEmpty_Params

Args returns the call's arguments.

type EmptyProvider_getEmpty_Params 

type EmptyProvider_getEmpty_Params capnp.Struct

func NewEmptyProvider_getEmpty_Params 

func NewEmptyProvider_getEmpty_Params(s *capnp.Segment) (EmptyProvider_getEmpty_Params, error)

func NewRootEmptyProvider_getEmpty_Params 

func NewRootEmptyProvider_getEmpty_Params(s *capnp.Segment) (EmptyProvider_getEmpty_Params, error)

func ReadRootEmptyProvider_getEmpty_Params 

func ReadRootEmptyProvider_getEmpty_Params(msg *capnp.Message) (EmptyProvider_getEmpty_Params, error)

func (EmptyProvider_getEmpty_Params) DecodeFromPtr 

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

func (EmptyProvider_getEmpty_Params) EncodeAsPtr 

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

func (EmptyProvider_getEmpty_Params) IsValid 

func (s EmptyProvider_getEmpty_Params) IsValid() bool

func (EmptyProvider_getEmpty_Params) Message 

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

func (EmptyProvider_getEmpty_Params) Segment 

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

func (EmptyProvider_getEmpty_Params) String 

func (s EmptyProvider_getEmpty_Params) String() string

func (EmptyProvider_getEmpty_Params) ToPtr 

func (s EmptyProvider_getEmpty_Params) ToPtr() capnp.Ptr

type EmptyProvider_getEmpty_Params_Future 

type EmptyProvider_getEmpty_Params_Future struct{ *capnp.Future }

EmptyProvider_getEmpty_Params_Future is a wrapper for a EmptyProvider_getEmpty_Params promised by a client call.

func (EmptyProvider_getEmpty_Params_Future) Struct 

func (f EmptyProvider_getEmpty_Params_Future) Struct() (EmptyProvider_getEmpty_Params, error)

type EmptyProvider_getEmpty_Params_List 

type EmptyProvider_getEmpty_Params_List = capnp.StructList[EmptyProvider_getEmpty_Params]

EmptyProvider_getEmpty_Params_List is a list of EmptyProvider_getEmpty_Params.

func NewEmptyProvider_getEmpty_Params_List 

func NewEmptyProvider_getEmpty_Params_List(s *capnp.Segment, sz int32) (EmptyProvider_getEmpty_Params_List, error)

NewEmptyProvider_getEmpty_Params creates a new list of EmptyProvider_getEmpty_Params.

type EmptyProvider_getEmpty_Results 

type EmptyProvider_getEmpty_Results capnp.Struct

func NewEmptyProvider_getEmpty_Results 

func NewEmptyProvider_getEmpty_Results(s *capnp.Segment) (EmptyProvider_getEmpty_Results, error)

func NewRootEmptyProvider_getEmpty_Results 

func NewRootEmptyProvider_getEmpty_Results(s *capnp.Segment) (EmptyProvider_getEmpty_Results, error)

func ReadRootEmptyProvider_getEmpty_Results 

func ReadRootEmptyProvider_getEmpty_Results(msg *capnp.Message) (EmptyProvider_getEmpty_Results, error)

func (EmptyProvider_getEmpty_Results) DecodeFromPtr 

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

func (EmptyProvider_getEmpty_Results) Empty 

func (s EmptyProvider_getEmpty_Results) Empty() Empty

func (EmptyProvider_getEmpty_Results) EncodeAsPtr 

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

func (EmptyProvider_getEmpty_Results) HasEmpty 

func (s EmptyProvider_getEmpty_Results) HasEmpty() bool

func (EmptyProvider_getEmpty_Results) IsValid 

func (s EmptyProvider_getEmpty_Results) IsValid() bool

func (EmptyProvider_getEmpty_Results) Message 

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

func (EmptyProvider_getEmpty_Results) Segment 

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

func (EmptyProvider_getEmpty_Results) SetEmpty 

func (s EmptyProvider_getEmpty_Results) SetEmpty(v Empty) error

func (EmptyProvider_getEmpty_Results) String 

func (s EmptyProvider_getEmpty_Results) String() string

func (EmptyProvider_getEmpty_Results) ToPtr 

func (s EmptyProvider_getEmpty_Results) ToPtr() capnp.Ptr

type EmptyProvider_getEmpty_Results_Future 

type EmptyProvider_getEmpty_Results_Future struct{ *capnp.Future }

EmptyProvider_getEmpty_Results_Future is a wrapper for a EmptyProvider_getEmpty_Results promised by a client call.

func (EmptyProvider_getEmpty_Results_Future) Empty 

func (p EmptyProvider_getEmpty_Results_Future) Empty() Empty

func (EmptyProvider_getEmpty_Results_Future) Struct 

func (f EmptyProvider_getEmpty_Results_Future) Struct() (EmptyProvider_getEmpty_Results, error)

type EmptyProvider_getEmpty_Results_List 

type EmptyProvider_getEmpty_Results_List = capnp.StructList[EmptyProvider_getEmpty_Results]

EmptyProvider_getEmpty_Results_List is a list of EmptyProvider_getEmpty_Results.

func NewEmptyProvider_getEmpty_Results_List 

func NewEmptyProvider_getEmpty_Results_List(s *capnp.Segment, sz int32) (EmptyProvider_getEmpty_Results_List, error)

NewEmptyProvider_getEmpty_Results creates a new list of EmptyProvider_getEmpty_Results.

type Empty_List 

type Empty_List = capnp.CapList[Empty]

Empty_List is a list of Empty.

func NewEmpty_List 

func NewEmpty_List(s *capnp.Segment, sz int32) (Empty_List, error)

NewEmpty creates a new list of Empty.

type Empty_Server 

type Empty_Server interface {
}

A Empty_Server is a Empty with a local implementation.

type PingPong 

type PingPong capnp.Client

func PingPong_ServerToClient 

func PingPong_ServerToClient(s PingPong_Server) PingPong

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

func (PingPong) AddRef 

func (c PingPong) AddRef() PingPong

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

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

func (PingPong) EchoNum 

func (c PingPong) EchoNum(ctx context.Context, params func(PingPong_echoNum_Params) error) (PingPong_echoNum_Results_Future, capnp.ReleaseFunc)

func (PingPong) EncodeAsPtr 

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

func (PingPong) GetFlowLimiter 

func (c PingPong) GetFlowLimiter() fc.FlowLimiter

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

func (PingPong) IsSame 

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

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

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

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

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

func (PingPong) SetFlowLimiter 

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

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

func (c PingPong) WaitStreaming() error

type PingPongProvider 

type PingPongProvider capnp.Client

func PingPongProvider_ServerToClient 

func PingPongProvider_ServerToClient(s PingPongProvider_Server) PingPongProvider

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

func (PingPongProvider) AddRef 

func (c PingPongProvider) AddRef() PingPongProvider

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

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

func (PingPongProvider) EncodeAsPtr 

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

func (PingPongProvider) GetFlowLimiter 

func (c PingPongProvider) GetFlowLimiter() fc.FlowLimiter

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

func (PingPongProvider) IsSame 

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

func (c PingPongProvider) 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 (PingPongProvider) PingPong 

func (c PingPongProvider) PingPong(ctx context.Context, params func(PingPongProvider_pingPong_Params) error) (PingPongProvider_pingPong_Results_Future, capnp.ReleaseFunc)

func (PingPongProvider) Release 

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

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

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

func (PingPongProvider) SetFlowLimiter 

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

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

func (c PingPongProvider) WaitStreaming() error

type PingPongProvider_List 

type PingPongProvider_List = capnp.CapList[PingPongProvider]

PingPongProvider_List is a list of PingPongProvider.

func NewPingPongProvider_List 

func NewPingPongProvider_List(s *capnp.Segment, sz int32) (PingPongProvider_List, error)

NewPingPongProvider creates a new list of PingPongProvider.

type PingPongProvider_Server 

type PingPongProvider_Server interface {
	PingPong(context.Context, PingPongProvider_pingPong) error
}

A PingPongProvider_Server is a PingPongProvider with a local implementation.

type PingPongProvider_pingPong 

type PingPongProvider_pingPong struct {
	*server.Call
}

PingPongProvider_pingPong holds the state for a server call to PingPongProvider.pingPong. See server.Call for documentation.

func (PingPongProvider_pingPong) AllocResults 

func (c PingPongProvider_pingPong) AllocResults() (PingPongProvider_pingPong_Results, error)

AllocResults allocates the results struct.

func (PingPongProvider_pingPong) Args 

func (c PingPongProvider_pingPong) Args() PingPongProvider_pingPong_Params

Args returns the call's arguments.

type PingPongProvider_pingPong_Params 

type PingPongProvider_pingPong_Params capnp.Struct

func NewPingPongProvider_pingPong_Params 

func NewPingPongProvider_pingPong_Params(s *capnp.Segment) (PingPongProvider_pingPong_Params, error)

func NewRootPingPongProvider_pingPong_Params 

func NewRootPingPongProvider_pingPong_Params(s *capnp.Segment) (PingPongProvider_pingPong_Params, error)

func ReadRootPingPongProvider_pingPong_Params 

func ReadRootPingPongProvider_pingPong_Params(msg *capnp.Message) (PingPongProvider_pingPong_Params, error)

func (PingPongProvider_pingPong_Params) DecodeFromPtr 

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

func (PingPongProvider_pingPong_Params) EncodeAsPtr 

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

func (PingPongProvider_pingPong_Params) IsValid 

func (s PingPongProvider_pingPong_Params) IsValid() bool

func (PingPongProvider_pingPong_Params) Message 

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

func (PingPongProvider_pingPong_Params) Segment 

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

func (PingPongProvider_pingPong_Params) String 

func (s PingPongProvider_pingPong_Params) String() string

func (PingPongProvider_pingPong_Params) ToPtr 

func (s PingPongProvider_pingPong_Params) ToPtr() capnp.Ptr

type PingPongProvider_pingPong_Params_Future 

type PingPongProvider_pingPong_Params_Future struct{ *capnp.Future }

PingPongProvider_pingPong_Params_Future is a wrapper for a PingPongProvider_pingPong_Params promised by a client call.

func (PingPongProvider_pingPong_Params_Future) Struct 

func (f PingPongProvider_pingPong_Params_Future) Struct() (PingPongProvider_pingPong_Params, error)

type PingPongProvider_pingPong_Params_List 

type PingPongProvider_pingPong_Params_List = capnp.StructList[PingPongProvider_pingPong_Params]

PingPongProvider_pingPong_Params_List is a list of PingPongProvider_pingPong_Params.

func NewPingPongProvider_pingPong_Params_List 

func NewPingPongProvider_pingPong_Params_List(s *capnp.Segment, sz int32) (PingPongProvider_pingPong_Params_List, error)

NewPingPongProvider_pingPong_Params creates a new list of PingPongProvider_pingPong_Params.

type PingPongProvider_pingPong_Results 

type PingPongProvider_pingPong_Results capnp.Struct

func NewPingPongProvider_pingPong_Results 

func NewPingPongProvider_pingPong_Results(s *capnp.Segment) (PingPongProvider_pingPong_Results, error)

func NewRootPingPongProvider_pingPong_Results 

func NewRootPingPongProvider_pingPong_Results(s *capnp.Segment) (PingPongProvider_pingPong_Results, error)

func ReadRootPingPongProvider_pingPong_Results 

func ReadRootPingPongProvider_pingPong_Results(msg *capnp.Message) (PingPongProvider_pingPong_Results, error)

func (PingPongProvider_pingPong_Results) DecodeFromPtr 

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

func (PingPongProvider_pingPong_Results) EncodeAsPtr 

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

func (PingPongProvider_pingPong_Results) HasPingPong 

func (s PingPongProvider_pingPong_Results) HasPingPong() bool

func (PingPongProvider_pingPong_Results) IsValid 

func (s PingPongProvider_pingPong_Results) IsValid() bool

func (PingPongProvider_pingPong_Results) Message 

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

func (PingPongProvider_pingPong_Results) PingPong 

func (s PingPongProvider_pingPong_Results) PingPong() PingPong

func (PingPongProvider_pingPong_Results) Segment 

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

func (PingPongProvider_pingPong_Results) SetPingPong 

func (s PingPongProvider_pingPong_Results) SetPingPong(v PingPong) error

func (PingPongProvider_pingPong_Results) String 

func (s PingPongProvider_pingPong_Results) String() string

func (PingPongProvider_pingPong_Results) ToPtr 

func (s PingPongProvider_pingPong_Results) ToPtr() capnp.Ptr

type PingPongProvider_pingPong_Results_Future 

type PingPongProvider_pingPong_Results_Future struct{ *capnp.Future }

PingPongProvider_pingPong_Results_Future is a wrapper for a PingPongProvider_pingPong_Results promised by a client call.

func (PingPongProvider_pingPong_Results_Future) PingPong 

func (p PingPongProvider_pingPong_Results_Future) PingPong() PingPong

func (PingPongProvider_pingPong_Results_Future) Struct 

func (f PingPongProvider_pingPong_Results_Future) Struct() (PingPongProvider_pingPong_Results, error)

type PingPongProvider_pingPong_Results_List 

type PingPongProvider_pingPong_Results_List = capnp.StructList[PingPongProvider_pingPong_Results]

PingPongProvider_pingPong_Results_List is a list of PingPongProvider_pingPong_Results.

func NewPingPongProvider_pingPong_Results_List 

func NewPingPongProvider_pingPong_Results_List(s *capnp.Segment, sz int32) (PingPongProvider_pingPong_Results_List, error)

NewPingPongProvider_pingPong_Results creates a new list of PingPongProvider_pingPong_Results.

type PingPong_List 

type PingPong_List = capnp.CapList[PingPong]

PingPong_List is a list of PingPong.

func NewPingPong_List 

func NewPingPong_List(s *capnp.Segment, sz int32) (PingPong_List, error)

NewPingPong creates a new list of PingPong.

type PingPong_Server 

type PingPong_Server interface {
	EchoNum(context.Context, PingPong_echoNum) error
}

A PingPong_Server is a PingPong with a local implementation.

type PingPong_echoNum 

type PingPong_echoNum struct {
	*server.Call
}

PingPong_echoNum holds the state for a server call to PingPong.echoNum. See server.Call for documentation.

func (PingPong_echoNum) AllocResults 

func (c PingPong_echoNum) AllocResults() (PingPong_echoNum_Results, error)

AllocResults allocates the results struct.

func (PingPong_echoNum) Args 

func (c PingPong_echoNum) Args() PingPong_echoNum_Params

Args returns the call's arguments.

type PingPong_echoNum_Params 

type PingPong_echoNum_Params capnp.Struct

func NewPingPong_echoNum_Params 

func NewPingPong_echoNum_Params(s *capnp.Segment) (PingPong_echoNum_Params, error)

func NewRootPingPong_echoNum_Params 

func NewRootPingPong_echoNum_Params(s *capnp.Segment) (PingPong_echoNum_Params, error)

func ReadRootPingPong_echoNum_Params 

func ReadRootPingPong_echoNum_Params(msg *capnp.Message) (PingPong_echoNum_Params, error)

func (PingPong_echoNum_Params) DecodeFromPtr 

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

func (PingPong_echoNum_Params) EncodeAsPtr 

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

func (PingPong_echoNum_Params) IsValid 

func (s PingPong_echoNum_Params) IsValid() bool

func (PingPong_echoNum_Params) Message 

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

func (PingPong_echoNum_Params) N 

func (s PingPong_echoNum_Params) N() int64

func (PingPong_echoNum_Params) Segment 

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

func (PingPong_echoNum_Params) SetN 

func (s PingPong_echoNum_Params) SetN(v int64)

func (PingPong_echoNum_Params) String 

func (s PingPong_echoNum_Params) String() string

func (PingPong_echoNum_Params) ToPtr 

func (s PingPong_echoNum_Params) ToPtr() capnp.Ptr

type PingPong_echoNum_Params_Future 

type PingPong_echoNum_Params_Future struct{ *capnp.Future }

PingPong_echoNum_Params_Future is a wrapper for a PingPong_echoNum_Params promised by a client call.

func (PingPong_echoNum_Params_Future) Struct 

func (f PingPong_echoNum_Params_Future) Struct() (PingPong_echoNum_Params, error)

type PingPong_echoNum_Params_List 

type PingPong_echoNum_Params_List = capnp.StructList[PingPong_echoNum_Params]

PingPong_echoNum_Params_List is a list of PingPong_echoNum_Params.

func NewPingPong_echoNum_Params_List 

func NewPingPong_echoNum_Params_List(s *capnp.Segment, sz int32) (PingPong_echoNum_Params_List, error)

NewPingPong_echoNum_Params creates a new list of PingPong_echoNum_Params.

type PingPong_echoNum_Results 

type PingPong_echoNum_Results capnp.Struct

func NewPingPong_echoNum_Results 

func NewPingPong_echoNum_Results(s *capnp.Segment) (PingPong_echoNum_Results, error)

func NewRootPingPong_echoNum_Results 

func NewRootPingPong_echoNum_Results(s *capnp.Segment) (PingPong_echoNum_Results, error)

func ReadRootPingPong_echoNum_Results 

func ReadRootPingPong_echoNum_Results(msg *capnp.Message) (PingPong_echoNum_Results, error)

func (PingPong_echoNum_Results) DecodeFromPtr 

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

func (PingPong_echoNum_Results) EncodeAsPtr 

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

func (PingPong_echoNum_Results) IsValid 

func (s PingPong_echoNum_Results) IsValid() bool

func (PingPong_echoNum_Results) Message 

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

func (PingPong_echoNum_Results) N 

func (s PingPong_echoNum_Results) N() int64

func (PingPong_echoNum_Results) Segment 

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

func (PingPong_echoNum_Results) SetN 

func (s PingPong_echoNum_Results) SetN(v int64)

func (PingPong_echoNum_Results) String 

func (s PingPong_echoNum_Results) String() string

func (PingPong_echoNum_Results) ToPtr 

func (s PingPong_echoNum_Results) ToPtr() capnp.Ptr

type PingPong_echoNum_Results_Future 

type PingPong_echoNum_Results_Future struct{ *capnp.Future }

PingPong_echoNum_Results_Future is a wrapper for a PingPong_echoNum_Results promised by a client call.

func (PingPong_echoNum_Results_Future) Struct 

func (f PingPong_echoNum_Results_Future) Struct() (PingPong_echoNum_Results, error)

type PingPong_echoNum_Results_List 

type PingPong_echoNum_Results_List = capnp.StructList[PingPong_echoNum_Results]

PingPong_echoNum_Results_List is a list of PingPong_echoNum_Results.

func NewPingPong_echoNum_Results_List 

func NewPingPong_echoNum_Results_List(s *capnp.Segment, sz int32) (PingPong_echoNum_Results_List, error)

NewPingPong_echoNum_Results creates a new list of PingPong_echoNum_Results.

type StreamTest 

type StreamTest capnp.Client

func StreamTest_ServerToClient 

func StreamTest_ServerToClient(s StreamTest_Server) StreamTest

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

func (StreamTest) AddRef 

func (c StreamTest) AddRef() StreamTest

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

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

func (StreamTest) EncodeAsPtr 

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

func (StreamTest) GetFlowLimiter 

func (c StreamTest) GetFlowLimiter() fc.FlowLimiter

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

func (StreamTest) IsSame 

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

func (c StreamTest) 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 (StreamTest) Push 

func (c StreamTest) Push(ctx context.Context, params func(StreamTest_push_Params) error) error

func (StreamTest) Release 

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

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

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

func (StreamTest) SetFlowLimiter 

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

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

func (c StreamTest) WaitStreaming() error

type StreamTest_List 

type StreamTest_List = capnp.CapList[StreamTest]

StreamTest_List is a list of StreamTest.

func NewStreamTest_List 

func NewStreamTest_List(s *capnp.Segment, sz int32) (StreamTest_List, error)

NewStreamTest creates a new list of StreamTest.

type StreamTest_Server 

type StreamTest_Server interface {
	Push(context.Context, StreamTest_push) error
}

A StreamTest_Server is a StreamTest with a local implementation.

type StreamTest_push 

type StreamTest_push struct {
	*server.Call
}

StreamTest_push holds the state for a server call to StreamTest.push. See server.Call for documentation.

func (StreamTest_push) AllocResults 

func (c StreamTest_push) AllocResults() (stream.StreamResult, error)

AllocResults allocates the results struct.

func (StreamTest_push) Args 

func (c StreamTest_push) Args() StreamTest_push_Params

Args returns the call's arguments.

type StreamTest_push_Params 

type StreamTest_push_Params capnp.Struct

func NewRootStreamTest_push_Params 

func NewRootStreamTest_push_Params(s *capnp.Segment) (StreamTest_push_Params, error)

func NewStreamTest_push_Params 

func NewStreamTest_push_Params(s *capnp.Segment) (StreamTest_push_Params, error)

func ReadRootStreamTest_push_Params 

func ReadRootStreamTest_push_Params(msg *capnp.Message) (StreamTest_push_Params, error)

func (StreamTest_push_Params) Data 

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

func (StreamTest_push_Params) DecodeFromPtr 

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

func (StreamTest_push_Params) EncodeAsPtr 

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

func (StreamTest_push_Params) HasData 

func (s StreamTest_push_Params) HasData() bool

func (StreamTest_push_Params) IsValid 

func (s StreamTest_push_Params) IsValid() bool

func (StreamTest_push_Params) Message 

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

func (StreamTest_push_Params) Segment 

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

func (StreamTest_push_Params) SetData 

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

func (StreamTest_push_Params) String 

func (s StreamTest_push_Params) String() string

func (StreamTest_push_Params) ToPtr 

func (s StreamTest_push_Params) ToPtr() capnp.Ptr

type StreamTest_push_Params_Future 

type StreamTest_push_Params_Future struct{ *capnp.Future }

StreamTest_push_Params_Future is a wrapper for a StreamTest_push_Params promised by a client call.

func (StreamTest_push_Params_Future) Struct 

func (f StreamTest_push_Params_Future) Struct() (StreamTest_push_Params, error)

type StreamTest_push_Params_List 

type StreamTest_push_Params_List = capnp.StructList[StreamTest_push_Params]

StreamTest_push_Params_List is a list of StreamTest_push_Params.

func NewStreamTest_push_Params_List 

func NewStreamTest_push_Params_List(s *capnp.Segment, sz int32) (StreamTest_push_Params_List, error)

NewStreamTest_push_Params creates a new list of StreamTest_push_Params.

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.