Documentation ¶
Index ¶
- Constants
- func CapArgsTest_Methods(methods []server.Method, s CapArgsTest_Server) []server.Method
- func CapArgsTest_NewServer(s CapArgsTest_Server) *server.Server
- func EmptyProvider_Methods(methods []server.Method, s EmptyProvider_Server) []server.Method
- func EmptyProvider_NewServer(s EmptyProvider_Server) *server.Server
- func Empty_Methods(methods []server.Method, s Empty_Server) []server.Method
- func Empty_NewServer(s Empty_Server) *server.Server
- func PingPongProvider_Methods(methods []server.Method, s PingPongProvider_Server) []server.Method
- func PingPongProvider_NewServer(s PingPongProvider_Server) *server.Server
- func PingPong_Methods(methods []server.Method, s PingPong_Server) []server.Method
- func PingPong_NewServer(s PingPong_Server) *server.Server
- func RegisterSchema(reg *schemas.Registry)
- func StreamTest_Methods(methods []server.Method, s StreamTest_Server) []server.Method
- func StreamTest_NewServer(s StreamTest_Server) *server.Server
- type CapArgsTest
- func (c CapArgsTest) AddRef() CapArgsTest
- func (c CapArgsTest) Call(ctx context.Context, params func(CapArgsTest_call_Params) error) (CapArgsTest_call_Results_Future, capnp.ReleaseFunc)
- func (CapArgsTest) DecodeFromPtr(p capnp.Ptr) CapArgsTest
- func (c CapArgsTest) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (c CapArgsTest) GetFlowLimiter() fc.FlowLimiter
- func (c CapArgsTest) IsSame(other CapArgsTest) bool
- func (c CapArgsTest) IsValid() bool
- func (c CapArgsTest) Release()
- func (c CapArgsTest) Resolve(ctx context.Context) error
- func (c CapArgsTest) Self(ctx context.Context, params func(CapArgsTest_self_Params) error) (CapArgsTest_self_Results_Future, capnp.ReleaseFunc)
- func (c CapArgsTest) SetFlowLimiter(lim fc.FlowLimiter)
- func (c CapArgsTest) String() string
- func (c CapArgsTest) WaitStreaming() error
- type CapArgsTest_List
- type CapArgsTest_Server
- type CapArgsTest_call
- type CapArgsTest_call_Params
- func (s CapArgsTest_call_Params) Cap() capnp.Client
- func (CapArgsTest_call_Params) DecodeFromPtr(p capnp.Ptr) CapArgsTest_call_Params
- func (s CapArgsTest_call_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s CapArgsTest_call_Params) HasCap() bool
- func (s CapArgsTest_call_Params) IsValid() bool
- func (s CapArgsTest_call_Params) Message() *capnp.Message
- func (s CapArgsTest_call_Params) Segment() *capnp.Segment
- func (s CapArgsTest_call_Params) SetCap(c capnp.Client) error
- func (s CapArgsTest_call_Params) String() string
- func (s CapArgsTest_call_Params) ToPtr() capnp.Ptr
- type CapArgsTest_call_Params_Future
- type CapArgsTest_call_Params_List
- type CapArgsTest_call_Results
- func (CapArgsTest_call_Results) DecodeFromPtr(p capnp.Ptr) CapArgsTest_call_Results
- func (s CapArgsTest_call_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s CapArgsTest_call_Results) IsValid() bool
- func (s CapArgsTest_call_Results) Message() *capnp.Message
- func (s CapArgsTest_call_Results) Segment() *capnp.Segment
- func (s CapArgsTest_call_Results) String() string
- func (s CapArgsTest_call_Results) ToPtr() capnp.Ptr
- type CapArgsTest_call_Results_Future
- type CapArgsTest_call_Results_List
- type CapArgsTest_self
- type CapArgsTest_self_Params
- func (CapArgsTest_self_Params) DecodeFromPtr(p capnp.Ptr) CapArgsTest_self_Params
- func (s CapArgsTest_self_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s CapArgsTest_self_Params) IsValid() bool
- func (s CapArgsTest_self_Params) Message() *capnp.Message
- func (s CapArgsTest_self_Params) Segment() *capnp.Segment
- func (s CapArgsTest_self_Params) String() string
- func (s CapArgsTest_self_Params) ToPtr() capnp.Ptr
- type CapArgsTest_self_Params_Future
- type CapArgsTest_self_Params_List
- type CapArgsTest_self_Results
- func (CapArgsTest_self_Results) DecodeFromPtr(p capnp.Ptr) CapArgsTest_self_Results
- func (s CapArgsTest_self_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s CapArgsTest_self_Results) HasSelf() bool
- func (s CapArgsTest_self_Results) IsValid() bool
- func (s CapArgsTest_self_Results) Message() *capnp.Message
- func (s CapArgsTest_self_Results) Segment() *capnp.Segment
- func (s CapArgsTest_self_Results) Self() CapArgsTest
- func (s CapArgsTest_self_Results) SetSelf(v CapArgsTest) error
- func (s CapArgsTest_self_Results) String() string
- func (s CapArgsTest_self_Results) ToPtr() capnp.Ptr
- type CapArgsTest_self_Results_Future
- type CapArgsTest_self_Results_List
- type Empty
- func (c Empty) AddRef() Empty
- func (Empty) DecodeFromPtr(p capnp.Ptr) Empty
- func (c Empty) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (c Empty) GetFlowLimiter() fc.FlowLimiter
- func (c Empty) IsSame(other Empty) bool
- func (c Empty) IsValid() bool
- func (c Empty) Release()
- func (c Empty) Resolve(ctx context.Context) error
- func (c Empty) SetFlowLimiter(lim fc.FlowLimiter)
- func (c Empty) String() string
- func (c Empty) WaitStreaming() error
- type EmptyProvider
- func (c EmptyProvider) AddRef() EmptyProvider
- func (EmptyProvider) DecodeFromPtr(p capnp.Ptr) EmptyProvider
- func (c EmptyProvider) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (c EmptyProvider) GetEmpty(ctx context.Context, params func(EmptyProvider_getEmpty_Params) error) (EmptyProvider_getEmpty_Results_Future, capnp.ReleaseFunc)
- func (c EmptyProvider) GetFlowLimiter() fc.FlowLimiter
- func (c EmptyProvider) IsSame(other EmptyProvider) bool
- func (c EmptyProvider) IsValid() bool
- func (c EmptyProvider) Release()
- func (c EmptyProvider) Resolve(ctx context.Context) error
- func (c EmptyProvider) SetFlowLimiter(lim fc.FlowLimiter)
- func (c EmptyProvider) String() string
- func (c EmptyProvider) WaitStreaming() error
- type EmptyProvider_List
- type EmptyProvider_Server
- type EmptyProvider_getEmpty
- type EmptyProvider_getEmpty_Params
- func (EmptyProvider_getEmpty_Params) DecodeFromPtr(p capnp.Ptr) EmptyProvider_getEmpty_Params
- func (s EmptyProvider_getEmpty_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s EmptyProvider_getEmpty_Params) IsValid() bool
- func (s EmptyProvider_getEmpty_Params) Message() *capnp.Message
- func (s EmptyProvider_getEmpty_Params) Segment() *capnp.Segment
- func (s EmptyProvider_getEmpty_Params) String() string
- func (s EmptyProvider_getEmpty_Params) ToPtr() capnp.Ptr
- type EmptyProvider_getEmpty_Params_Future
- type EmptyProvider_getEmpty_Params_List
- type EmptyProvider_getEmpty_Results
- func NewEmptyProvider_getEmpty_Results(s *capnp.Segment) (EmptyProvider_getEmpty_Results, error)
- func NewRootEmptyProvider_getEmpty_Results(s *capnp.Segment) (EmptyProvider_getEmpty_Results, error)
- func ReadRootEmptyProvider_getEmpty_Results(msg *capnp.Message) (EmptyProvider_getEmpty_Results, error)
- func (EmptyProvider_getEmpty_Results) DecodeFromPtr(p capnp.Ptr) EmptyProvider_getEmpty_Results
- func (s EmptyProvider_getEmpty_Results) Empty() Empty
- func (s EmptyProvider_getEmpty_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s EmptyProvider_getEmpty_Results) HasEmpty() bool
- func (s EmptyProvider_getEmpty_Results) IsValid() bool
- func (s EmptyProvider_getEmpty_Results) Message() *capnp.Message
- func (s EmptyProvider_getEmpty_Results) Segment() *capnp.Segment
- func (s EmptyProvider_getEmpty_Results) SetEmpty(v Empty) error
- func (s EmptyProvider_getEmpty_Results) String() string
- func (s EmptyProvider_getEmpty_Results) ToPtr() capnp.Ptr
- type EmptyProvider_getEmpty_Results_Future
- type EmptyProvider_getEmpty_Results_List
- type Empty_List
- type Empty_Server
- type PingPong
- func (c PingPong) AddRef() PingPong
- func (PingPong) DecodeFromPtr(p capnp.Ptr) PingPong
- func (c PingPong) EchoNum(ctx context.Context, params func(PingPong_echoNum_Params) error) (PingPong_echoNum_Results_Future, capnp.ReleaseFunc)
- func (c PingPong) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (c PingPong) GetFlowLimiter() fc.FlowLimiter
- func (c PingPong) IsSame(other PingPong) bool
- func (c PingPong) IsValid() bool
- func (c PingPong) Release()
- func (c PingPong) Resolve(ctx context.Context) error
- func (c PingPong) SetFlowLimiter(lim fc.FlowLimiter)
- func (c PingPong) String() string
- func (c PingPong) WaitStreaming() error
- type PingPongProvider
- func (c PingPongProvider) AddRef() PingPongProvider
- func (PingPongProvider) DecodeFromPtr(p capnp.Ptr) PingPongProvider
- func (c PingPongProvider) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (c PingPongProvider) GetFlowLimiter() fc.FlowLimiter
- func (c PingPongProvider) IsSame(other PingPongProvider) bool
- func (c PingPongProvider) IsValid() bool
- func (c PingPongProvider) PingPong(ctx context.Context, params func(PingPongProvider_pingPong_Params) error) (PingPongProvider_pingPong_Results_Future, capnp.ReleaseFunc)
- func (c PingPongProvider) Release()
- func (c PingPongProvider) Resolve(ctx context.Context) error
- func (c PingPongProvider) SetFlowLimiter(lim fc.FlowLimiter)
- func (c PingPongProvider) String() string
- func (c PingPongProvider) WaitStreaming() error
- type PingPongProvider_List
- type PingPongProvider_Server
- type PingPongProvider_pingPong
- type PingPongProvider_pingPong_Params
- func NewPingPongProvider_pingPong_Params(s *capnp.Segment) (PingPongProvider_pingPong_Params, error)
- func NewRootPingPongProvider_pingPong_Params(s *capnp.Segment) (PingPongProvider_pingPong_Params, error)
- func ReadRootPingPongProvider_pingPong_Params(msg *capnp.Message) (PingPongProvider_pingPong_Params, error)
- func (PingPongProvider_pingPong_Params) DecodeFromPtr(p capnp.Ptr) PingPongProvider_pingPong_Params
- func (s PingPongProvider_pingPong_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s PingPongProvider_pingPong_Params) IsValid() bool
- func (s PingPongProvider_pingPong_Params) Message() *capnp.Message
- func (s PingPongProvider_pingPong_Params) Segment() *capnp.Segment
- func (s PingPongProvider_pingPong_Params) String() string
- func (s PingPongProvider_pingPong_Params) ToPtr() capnp.Ptr
- type PingPongProvider_pingPong_Params_Future
- type PingPongProvider_pingPong_Params_List
- type PingPongProvider_pingPong_Results
- func NewPingPongProvider_pingPong_Results(s *capnp.Segment) (PingPongProvider_pingPong_Results, error)
- func NewRootPingPongProvider_pingPong_Results(s *capnp.Segment) (PingPongProvider_pingPong_Results, error)
- func ReadRootPingPongProvider_pingPong_Results(msg *capnp.Message) (PingPongProvider_pingPong_Results, error)
- func (PingPongProvider_pingPong_Results) DecodeFromPtr(p capnp.Ptr) PingPongProvider_pingPong_Results
- func (s PingPongProvider_pingPong_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s PingPongProvider_pingPong_Results) HasPingPong() bool
- func (s PingPongProvider_pingPong_Results) IsValid() bool
- func (s PingPongProvider_pingPong_Results) Message() *capnp.Message
- func (s PingPongProvider_pingPong_Results) PingPong() PingPong
- func (s PingPongProvider_pingPong_Results) Segment() *capnp.Segment
- func (s PingPongProvider_pingPong_Results) SetPingPong(v PingPong) error
- func (s PingPongProvider_pingPong_Results) String() string
- func (s PingPongProvider_pingPong_Results) ToPtr() capnp.Ptr
- type PingPongProvider_pingPong_Results_Future
- type PingPongProvider_pingPong_Results_List
- type PingPong_List
- type PingPong_Server
- type PingPong_echoNum
- type PingPong_echoNum_Params
- func (PingPong_echoNum_Params) DecodeFromPtr(p capnp.Ptr) PingPong_echoNum_Params
- func (s PingPong_echoNum_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s PingPong_echoNum_Params) IsValid() bool
- func (s PingPong_echoNum_Params) Message() *capnp.Message
- func (s PingPong_echoNum_Params) N() int64
- func (s PingPong_echoNum_Params) Segment() *capnp.Segment
- func (s PingPong_echoNum_Params) SetN(v int64)
- func (s PingPong_echoNum_Params) String() string
- func (s PingPong_echoNum_Params) ToPtr() capnp.Ptr
- type PingPong_echoNum_Params_Future
- type PingPong_echoNum_Params_List
- type PingPong_echoNum_Results
- func (PingPong_echoNum_Results) DecodeFromPtr(p capnp.Ptr) PingPong_echoNum_Results
- func (s PingPong_echoNum_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s PingPong_echoNum_Results) IsValid() bool
- func (s PingPong_echoNum_Results) Message() *capnp.Message
- func (s PingPong_echoNum_Results) N() int64
- func (s PingPong_echoNum_Results) Segment() *capnp.Segment
- func (s PingPong_echoNum_Results) SetN(v int64)
- func (s PingPong_echoNum_Results) String() string
- func (s PingPong_echoNum_Results) ToPtr() capnp.Ptr
- type PingPong_echoNum_Results_Future
- type PingPong_echoNum_Results_List
- type StreamTest
- func (c StreamTest) AddRef() StreamTest
- func (StreamTest) DecodeFromPtr(p capnp.Ptr) StreamTest
- func (c StreamTest) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (c StreamTest) GetFlowLimiter() fc.FlowLimiter
- func (c StreamTest) IsSame(other StreamTest) bool
- func (c StreamTest) IsValid() bool
- func (c StreamTest) Push(ctx context.Context, params func(StreamTest_push_Params) error) error
- func (c StreamTest) Release()
- func (c StreamTest) Resolve(ctx context.Context) error
- func (c StreamTest) SetFlowLimiter(lim fc.FlowLimiter)
- func (c StreamTest) String() string
- func (c StreamTest) WaitStreaming() error
- type StreamTest_List
- type StreamTest_Server
- type StreamTest_push
- type StreamTest_push_Params
- func (s StreamTest_push_Params) Data() ([]byte, error)
- func (StreamTest_push_Params) DecodeFromPtr(p capnp.Ptr) StreamTest_push_Params
- func (s StreamTest_push_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s StreamTest_push_Params) HasData() bool
- func (s StreamTest_push_Params) IsValid() bool
- func (s StreamTest_push_Params) Message() *capnp.Message
- func (s StreamTest_push_Params) Segment() *capnp.Segment
- func (s StreamTest_push_Params) SetData(v []byte) error
- func (s StreamTest_push_Params) String() string
- func (s StreamTest_push_Params) ToPtr() capnp.Ptr
- type StreamTest_push_Params_Future
- type StreamTest_push_Params_List
Constants ¶
const CapArgsTest_TypeID = 0xb86bce7f916a10cc
CapArgsTest_TypeID is the unique identifier for the type CapArgsTest.
const CapArgsTest_call_Params_TypeID = 0x80087e4e698768a2
CapArgsTest_call_Params_TypeID is the unique identifier for the type CapArgsTest_call_Params.
const CapArgsTest_call_Results_TypeID = 0x96fbc50dc2f0200d
CapArgsTest_call_Results_TypeID is the unique identifier for the type CapArgsTest_call_Results.
const CapArgsTest_self_Params_TypeID = 0xe2553e5a663abb7d
CapArgsTest_self_Params_TypeID is the unique identifier for the type CapArgsTest_self_Params.
const CapArgsTest_self_Results_TypeID = 0x9746cc05cbff1132
CapArgsTest_self_Results_TypeID is the unique identifier for the type CapArgsTest_self_Results.
const EmptyProvider_TypeID = 0xea38d4d6dca1e80e
EmptyProvider_TypeID is the unique identifier for the type EmptyProvider.
const EmptyProvider_getEmpty_Params_TypeID = 0x9a27082d77b8c289
EmptyProvider_getEmpty_Params_TypeID is the unique identifier for the type EmptyProvider_getEmpty_Params.
const EmptyProvider_getEmpty_Results_TypeID = 0x93281cc60d6060cd
EmptyProvider_getEmpty_Results_TypeID is the unique identifier for the type EmptyProvider_getEmpty_Results.
const Empty_TypeID = 0xc8b14e937b2cb741
Empty_TypeID is the unique identifier for the type Empty.
const PingPongProvider_TypeID = 0x95b6142577e93239
PingPongProvider_TypeID is the unique identifier for the type PingPongProvider.
const PingPongProvider_pingPong_Params_TypeID = 0xd4e835c17f1ef32c
PingPongProvider_pingPong_Params_TypeID is the unique identifier for the type PingPongProvider_pingPong_Params.
const PingPongProvider_pingPong_Results_TypeID = 0xf269473b6db8d0eb
PingPongProvider_pingPong_Results_TypeID is the unique identifier for the type PingPongProvider_pingPong_Results.
const PingPong_TypeID = 0xf004c474c2f8ee7a
PingPong_TypeID is the unique identifier for the type PingPong.
const PingPong_echoNum_Params_TypeID = 0xd797e0a99edf0921
PingPong_echoNum_Params_TypeID is the unique identifier for the type PingPong_echoNum_Params.
const PingPong_echoNum_Results_TypeID = 0x85ddfd96db252600
PingPong_echoNum_Results_TypeID is the unique identifier for the type PingPong_echoNum_Results.
const StreamTest_TypeID = 0xbb3ca85b01eea465
StreamTest_TypeID is the unique identifier for the type StreamTest.
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 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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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) GetFlowLimiter ¶
func (c Empty) GetFlowLimiter() fc.FlowLimiter
Get the current flowcontrol.FlowLimiter used to manage flow control for this client.
func (Empty) IsSame ¶
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 ¶
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 ¶
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 ¶
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 ¶
type EmptyProvider ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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) EchoNum ¶
func (c PingPong) EchoNum(ctx context.Context, params func(PingPong_echoNum_Params) error) (PingPong_echoNum_Results_Future, capnp.ReleaseFunc)
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
type PingPongProvider ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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.