Documentation ¶
Index ¶
- Constants
- func Chan_Methods(methods []server.Method, s Chan_Server) []server.Method
- func Chan_NewServer(s Chan_Server) *server.Server
- func Closer_Methods(methods []server.Method, s Closer_Server) []server.Method
- func Closer_NewServer(s Closer_Server) *server.Server
- func Recver_Methods(methods []server.Method, s Recver_Server) []server.Method
- func Recver_NewServer(s Recver_Server) *server.Server
- func RegisterSchema(reg *schemas.Registry)
- func SendCloser_Methods(methods []server.Method, s SendCloser_Server) []server.Method
- func SendCloser_NewServer(s SendCloser_Server) *server.Server
- func Sender_Methods(methods []server.Method, s Sender_Server) []server.Method
- func Sender_NewServer(s Sender_Server) *server.Server
- type Chan
- func (c Chan) AddRef() Chan
- func (c Chan) Close(ctx context.Context, params func(Closer_close_Params) error) (Closer_close_Results_Future, capnp.ReleaseFunc)
- func (Chan) DecodeFromPtr(p capnp.Ptr) Chan
- func (c Chan) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (c Chan) GetFlowLimiter() fc.FlowLimiter
- func (c Chan) IsSame(other Chan) bool
- func (c Chan) IsValid() bool
- func (c Chan) NewCloser(ctx context.Context, params func(SendCloser_newCloser_Params) error) (SendCloser_newCloser_Results_Future, capnp.ReleaseFunc)
- func (c Chan) NewRecver(ctx context.Context, params func(Chan_newRecver_Params) error) (Chan_newRecver_Results_Future, capnp.ReleaseFunc)
- func (c Chan) NewSendCloser(ctx context.Context, params func(Chan_newSendCloser_Params) error) (Chan_newSendCloser_Results_Future, capnp.ReleaseFunc)
- func (c Chan) NewSender(ctx context.Context, params func(SendCloser_newSender_Params) error) (SendCloser_newSender_Results_Future, capnp.ReleaseFunc)
- func (c Chan) Recv(ctx context.Context, params func(Recver_recv_Params) error) (Recver_recv_Results_Future, capnp.ReleaseFunc)
- func (c Chan) Release()
- func (c Chan) Resolve(ctx context.Context) error
- func (c Chan) Send(ctx context.Context, params func(Sender_send_Params) error) (Sender_send_Results_Future, capnp.ReleaseFunc)
- func (c Chan) SetFlowLimiter(lim fc.FlowLimiter)
- func (c Chan) String() string
- func (c Chan) WaitStreaming() error
- type Chan_List
- type Chan_Server
- type Chan_newRecver
- type Chan_newRecver_Params
- func (Chan_newRecver_Params) DecodeFromPtr(p capnp.Ptr) Chan_newRecver_Params
- func (s Chan_newRecver_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Chan_newRecver_Params) IsValid() bool
- func (s Chan_newRecver_Params) Message() *capnp.Message
- func (s Chan_newRecver_Params) Segment() *capnp.Segment
- func (s Chan_newRecver_Params) String() string
- func (s Chan_newRecver_Params) ToPtr() capnp.Ptr
- type Chan_newRecver_Params_Future
- type Chan_newRecver_Params_List
- type Chan_newRecver_Results
- func (Chan_newRecver_Results) DecodeFromPtr(p capnp.Ptr) Chan_newRecver_Results
- func (s Chan_newRecver_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Chan_newRecver_Results) HasRecver() bool
- func (s Chan_newRecver_Results) IsValid() bool
- func (s Chan_newRecver_Results) Message() *capnp.Message
- func (s Chan_newRecver_Results) Recver() Recver
- func (s Chan_newRecver_Results) Segment() *capnp.Segment
- func (s Chan_newRecver_Results) SetRecver(v Recver) error
- func (s Chan_newRecver_Results) String() string
- func (s Chan_newRecver_Results) ToPtr() capnp.Ptr
- type Chan_newRecver_Results_Future
- type Chan_newRecver_Results_List
- type Chan_newSendCloser
- type Chan_newSendCloser_Params
- func (Chan_newSendCloser_Params) DecodeFromPtr(p capnp.Ptr) Chan_newSendCloser_Params
- func (s Chan_newSendCloser_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Chan_newSendCloser_Params) IsValid() bool
- func (s Chan_newSendCloser_Params) Message() *capnp.Message
- func (s Chan_newSendCloser_Params) Segment() *capnp.Segment
- func (s Chan_newSendCloser_Params) String() string
- func (s Chan_newSendCloser_Params) ToPtr() capnp.Ptr
- type Chan_newSendCloser_Params_Future
- type Chan_newSendCloser_Params_List
- type Chan_newSendCloser_Results
- func (Chan_newSendCloser_Results) DecodeFromPtr(p capnp.Ptr) Chan_newSendCloser_Results
- func (s Chan_newSendCloser_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Chan_newSendCloser_Results) HasSendCloser() bool
- func (s Chan_newSendCloser_Results) IsValid() bool
- func (s Chan_newSendCloser_Results) Message() *capnp.Message
- func (s Chan_newSendCloser_Results) Segment() *capnp.Segment
- func (s Chan_newSendCloser_Results) SendCloser() SendCloser
- func (s Chan_newSendCloser_Results) SetSendCloser(v SendCloser) error
- func (s Chan_newSendCloser_Results) String() string
- func (s Chan_newSendCloser_Results) ToPtr() capnp.Ptr
- type Chan_newSendCloser_Results_Future
- type Chan_newSendCloser_Results_List
- type Closer
- func (c Closer) AddRef() Closer
- func (c Closer) Close(ctx context.Context, params func(Closer_close_Params) error) (Closer_close_Results_Future, capnp.ReleaseFunc)
- func (Closer) DecodeFromPtr(p capnp.Ptr) Closer
- func (c Closer) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (c Closer) GetFlowLimiter() fc.FlowLimiter
- func (c Closer) IsSame(other Closer) bool
- func (c Closer) IsValid() bool
- func (c Closer) Release()
- func (c Closer) Resolve(ctx context.Context) error
- func (c Closer) SetFlowLimiter(lim fc.FlowLimiter)
- func (c Closer) String() string
- func (c Closer) WaitStreaming() error
- type Closer_List
- type Closer_Server
- type Closer_close
- type Closer_close_Params
- func (Closer_close_Params) DecodeFromPtr(p capnp.Ptr) Closer_close_Params
- func (s Closer_close_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Closer_close_Params) IsValid() bool
- func (s Closer_close_Params) Message() *capnp.Message
- func (s Closer_close_Params) Segment() *capnp.Segment
- func (s Closer_close_Params) String() string
- func (s Closer_close_Params) ToPtr() capnp.Ptr
- type Closer_close_Params_Future
- type Closer_close_Params_List
- type Closer_close_Results
- func (Closer_close_Results) DecodeFromPtr(p capnp.Ptr) Closer_close_Results
- func (s Closer_close_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Closer_close_Results) IsValid() bool
- func (s Closer_close_Results) Message() *capnp.Message
- func (s Closer_close_Results) Segment() *capnp.Segment
- func (s Closer_close_Results) String() string
- func (s Closer_close_Results) ToPtr() capnp.Ptr
- type Closer_close_Results_Future
- type Closer_close_Results_List
- type Recver
- func (c Recver) AddRef() Recver
- func (Recver) DecodeFromPtr(p capnp.Ptr) Recver
- func (c Recver) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (c Recver) GetFlowLimiter() fc.FlowLimiter
- func (c Recver) IsSame(other Recver) bool
- func (c Recver) IsValid() bool
- func (c Recver) Recv(ctx context.Context, params func(Recver_recv_Params) error) (Recver_recv_Results_Future, capnp.ReleaseFunc)
- func (c Recver) Release()
- func (c Recver) Resolve(ctx context.Context) error
- func (c Recver) SetFlowLimiter(lim fc.FlowLimiter)
- func (c Recver) String() string
- func (c Recver) WaitStreaming() error
- type Recver_List
- type Recver_Server
- type Recver_recv
- type Recver_recv_Params
- func (Recver_recv_Params) DecodeFromPtr(p capnp.Ptr) Recver_recv_Params
- func (s Recver_recv_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Recver_recv_Params) IsValid() bool
- func (s Recver_recv_Params) Message() *capnp.Message
- func (s Recver_recv_Params) Segment() *capnp.Segment
- func (s Recver_recv_Params) String() string
- func (s Recver_recv_Params) ToPtr() capnp.Ptr
- type Recver_recv_Params_Future
- type Recver_recv_Params_List
- type Recver_recv_Results
- func (Recver_recv_Results) DecodeFromPtr(p capnp.Ptr) Recver_recv_Results
- func (s Recver_recv_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Recver_recv_Results) HasValue() bool
- func (s Recver_recv_Results) IsValid() bool
- func (s Recver_recv_Results) Message() *capnp.Message
- func (s Recver_recv_Results) Segment() *capnp.Segment
- func (s Recver_recv_Results) SetValue(v capnp.Ptr) error
- func (s Recver_recv_Results) String() string
- func (s Recver_recv_Results) ToPtr() capnp.Ptr
- func (s Recver_recv_Results) Value() (capnp.Ptr, error)
- type Recver_recv_Results_Future
- type Recver_recv_Results_List
- type SendCloser
- func (c SendCloser) AddRef() SendCloser
- func (c SendCloser) Close(ctx context.Context, params func(Closer_close_Params) error) (Closer_close_Results_Future, capnp.ReleaseFunc)
- func (SendCloser) DecodeFromPtr(p capnp.Ptr) SendCloser
- func (c SendCloser) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (c SendCloser) GetFlowLimiter() fc.FlowLimiter
- func (c SendCloser) IsSame(other SendCloser) bool
- func (c SendCloser) IsValid() bool
- func (c SendCloser) NewCloser(ctx context.Context, params func(SendCloser_newCloser_Params) error) (SendCloser_newCloser_Results_Future, capnp.ReleaseFunc)
- func (c SendCloser) NewSender(ctx context.Context, params func(SendCloser_newSender_Params) error) (SendCloser_newSender_Results_Future, capnp.ReleaseFunc)
- func (c SendCloser) Release()
- func (c SendCloser) Resolve(ctx context.Context) error
- func (c SendCloser) Send(ctx context.Context, params func(Sender_send_Params) error) (Sender_send_Results_Future, capnp.ReleaseFunc)
- func (c SendCloser) SetFlowLimiter(lim fc.FlowLimiter)
- func (c SendCloser) String() string
- func (c SendCloser) WaitStreaming() error
- type SendCloser_List
- type SendCloser_Server
- type SendCloser_newCloser
- type SendCloser_newCloser_Params
- func (SendCloser_newCloser_Params) DecodeFromPtr(p capnp.Ptr) SendCloser_newCloser_Params
- func (s SendCloser_newCloser_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s SendCloser_newCloser_Params) IsValid() bool
- func (s SendCloser_newCloser_Params) Message() *capnp.Message
- func (s SendCloser_newCloser_Params) Segment() *capnp.Segment
- func (s SendCloser_newCloser_Params) String() string
- func (s SendCloser_newCloser_Params) ToPtr() capnp.Ptr
- type SendCloser_newCloser_Params_Future
- type SendCloser_newCloser_Params_List
- type SendCloser_newCloser_Results
- func (s SendCloser_newCloser_Results) Closer() Closer
- func (SendCloser_newCloser_Results) DecodeFromPtr(p capnp.Ptr) SendCloser_newCloser_Results
- func (s SendCloser_newCloser_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s SendCloser_newCloser_Results) HasCloser() bool
- func (s SendCloser_newCloser_Results) IsValid() bool
- func (s SendCloser_newCloser_Results) Message() *capnp.Message
- func (s SendCloser_newCloser_Results) Segment() *capnp.Segment
- func (s SendCloser_newCloser_Results) SetCloser(v Closer) error
- func (s SendCloser_newCloser_Results) String() string
- func (s SendCloser_newCloser_Results) ToPtr() capnp.Ptr
- type SendCloser_newCloser_Results_Future
- type SendCloser_newCloser_Results_List
- type SendCloser_newSender
- type SendCloser_newSender_Params
- func (SendCloser_newSender_Params) DecodeFromPtr(p capnp.Ptr) SendCloser_newSender_Params
- func (s SendCloser_newSender_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s SendCloser_newSender_Params) IsValid() bool
- func (s SendCloser_newSender_Params) Message() *capnp.Message
- func (s SendCloser_newSender_Params) Segment() *capnp.Segment
- func (s SendCloser_newSender_Params) String() string
- func (s SendCloser_newSender_Params) ToPtr() capnp.Ptr
- type SendCloser_newSender_Params_Future
- type SendCloser_newSender_Params_List
- type SendCloser_newSender_Results
- func (SendCloser_newSender_Results) DecodeFromPtr(p capnp.Ptr) SendCloser_newSender_Results
- func (s SendCloser_newSender_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s SendCloser_newSender_Results) HasSender() bool
- func (s SendCloser_newSender_Results) IsValid() bool
- func (s SendCloser_newSender_Results) Message() *capnp.Message
- func (s SendCloser_newSender_Results) Segment() *capnp.Segment
- func (s SendCloser_newSender_Results) Sender() Sender
- func (s SendCloser_newSender_Results) SetSender(v Sender) error
- func (s SendCloser_newSender_Results) String() string
- func (s SendCloser_newSender_Results) ToPtr() capnp.Ptr
- type SendCloser_newSender_Results_Future
- type SendCloser_newSender_Results_List
- type Sender
- func (c Sender) AddRef() Sender
- func (Sender) DecodeFromPtr(p capnp.Ptr) Sender
- func (c Sender) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (c Sender) GetFlowLimiter() fc.FlowLimiter
- func (c Sender) IsSame(other Sender) bool
- func (c Sender) IsValid() bool
- func (c Sender) Release()
- func (c Sender) Resolve(ctx context.Context) error
- func (c Sender) Send(ctx context.Context, params func(Sender_send_Params) error) (Sender_send_Results_Future, capnp.ReleaseFunc)
- func (c Sender) SetFlowLimiter(lim fc.FlowLimiter)
- func (c Sender) String() string
- func (c Sender) WaitStreaming() error
- type Sender_List
- type Sender_Server
- type Sender_send
- type Sender_send_Params
- func (Sender_send_Params) DecodeFromPtr(p capnp.Ptr) Sender_send_Params
- func (s Sender_send_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Sender_send_Params) HasValue() bool
- func (s Sender_send_Params) IsValid() bool
- func (s Sender_send_Params) Message() *capnp.Message
- func (s Sender_send_Params) Segment() *capnp.Segment
- func (s Sender_send_Params) SetValue(v capnp.Ptr) error
- func (s Sender_send_Params) String() string
- func (s Sender_send_Params) ToPtr() capnp.Ptr
- func (s Sender_send_Params) Value() (capnp.Ptr, error)
- type Sender_send_Params_Future
- type Sender_send_Params_List
- type Sender_send_Results
- func (Sender_send_Results) DecodeFromPtr(p capnp.Ptr) Sender_send_Results
- func (s Sender_send_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Sender_send_Results) IsValid() bool
- func (s Sender_send_Results) Message() *capnp.Message
- func (s Sender_send_Results) Segment() *capnp.Segment
- func (s Sender_send_Results) String() string
- func (s Sender_send_Results) ToPtr() capnp.Ptr
- type Sender_send_Results_Future
- type Sender_send_Results_List
Constants ¶
const Chan_TypeID = 0x95c89fe7d966f751
Chan_TypeID is the unique identifier for the type Chan.
const Chan_newRecver_Params_TypeID = 0x891b1d7a66ab36b5
Chan_newRecver_Params_TypeID is the unique identifier for the type Chan_newRecver_Params.
const Chan_newRecver_Results_TypeID = 0x9f8a81c20d0e72c9
Chan_newRecver_Results_TypeID is the unique identifier for the type Chan_newRecver_Results.
const Chan_newSendCloser_Params_TypeID = 0xe76adde17bd7c3df
Chan_newSendCloser_Params_TypeID is the unique identifier for the type Chan_newSendCloser_Params.
const Chan_newSendCloser_Results_TypeID = 0xcbbc3fcd0d01a855
Chan_newSendCloser_Results_TypeID is the unique identifier for the type Chan_newSendCloser_Results.
const Closer_TypeID = 0xfad0e4b80d3779c3
Closer_TypeID is the unique identifier for the type Closer.
const Closer_close_Params_TypeID = 0xfd07d8a1cc36583c
Closer_close_Params_TypeID is the unique identifier for the type Closer_close_Params.
const Closer_close_Results_TypeID = 0xcbee5caf8b7af4ea
Closer_close_Results_TypeID is the unique identifier for the type Closer_close_Results.
const Recver_TypeID = 0xdf05a90d671c0c07
Recver_TypeID is the unique identifier for the type Recver.
const Recver_recv_Params_TypeID = 0xdd377ddc0d2426ea
Recver_recv_Params_TypeID is the unique identifier for the type Recver_recv_Params.
const Recver_recv_Results_TypeID = 0xb0e88f4d0a3a1694
Recver_recv_Results_TypeID is the unique identifier for the type Recver_recv_Results.
const SendCloser_TypeID = 0xe9a7d19a7d14e94e
SendCloser_TypeID is the unique identifier for the type SendCloser.
const SendCloser_newCloser_Params_TypeID = 0xe48d9443d96ba68d
SendCloser_newCloser_Params_TypeID is the unique identifier for the type SendCloser_newCloser_Params.
const SendCloser_newCloser_Results_TypeID = 0xf1dd4079b7c319f1
SendCloser_newCloser_Results_TypeID is the unique identifier for the type SendCloser_newCloser_Results.
const SendCloser_newSender_Params_TypeID = 0xbb370dcc71a43ba9
SendCloser_newSender_Params_TypeID is the unique identifier for the type SendCloser_newSender_Params.
const SendCloser_newSender_Results_TypeID = 0xca7110014301ab81
SendCloser_newSender_Results_TypeID is the unique identifier for the type SendCloser_newSender_Results.
const Sender_TypeID = 0xe8bbed1438ea16ee
Sender_TypeID is the unique identifier for the type Sender.
const Sender_send_Params_TypeID = 0x8166bc9c3ded78ca
Sender_send_Params_TypeID is the unique identifier for the type Sender_send_Params.
const Sender_send_Results_TypeID = 0xbb3101eccc20b4eb
Sender_send_Results_TypeID is the unique identifier for the type Sender_send_Results.
Variables ¶
This section is empty.
Functions ¶
func Chan_Methods ¶
func Chan_Methods(methods []server.Method, s Chan_Server) []server.Method
Chan_Methods appends Methods to a slice that invoke the methods on s. This can be used to create a more complicated Server.
func Chan_NewServer ¶
func Chan_NewServer(s Chan_Server) *server.Server
Chan_NewServer creates a new Server from an implementation of Chan_Server.
func Closer_Methods ¶
func Closer_Methods(methods []server.Method, s Closer_Server) []server.Method
Closer_Methods appends Methods to a slice that invoke the methods on s. This can be used to create a more complicated Server.
func Closer_NewServer ¶
func Closer_NewServer(s Closer_Server) *server.Server
Closer_NewServer creates a new Server from an implementation of Closer_Server.
func Recver_Methods ¶
func Recver_Methods(methods []server.Method, s Recver_Server) []server.Method
Recver_Methods appends Methods to a slice that invoke the methods on s. This can be used to create a more complicated Server.
func Recver_NewServer ¶
func Recver_NewServer(s Recver_Server) *server.Server
Recver_NewServer creates a new Server from an implementation of Recver_Server.
func RegisterSchema ¶
func SendCloser_Methods ¶
func SendCloser_Methods(methods []server.Method, s SendCloser_Server) []server.Method
SendCloser_Methods appends Methods to a slice that invoke the methods on s. This can be used to create a more complicated Server.
func SendCloser_NewServer ¶
func SendCloser_NewServer(s SendCloser_Server) *server.Server
SendCloser_NewServer creates a new Server from an implementation of SendCloser_Server.
func Sender_Methods ¶
func Sender_Methods(methods []server.Method, s Sender_Server) []server.Method
Sender_Methods appends Methods to a slice that invoke the methods on s. This can be used to create a more complicated Server.
func Sender_NewServer ¶
func Sender_NewServer(s Sender_Server) *server.Server
Sender_NewServer creates a new Server from an implementation of Sender_Server.
Types ¶
type Chan ¶
func Chan_ServerToClient ¶
func Chan_ServerToClient(s Chan_Server) Chan
Chan_ServerToClient creates a new Client from an implementation of Chan_Server. The caller is responsible for calling Release on the returned Client.
func (Chan) 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 (Chan) Close ¶
func (c Chan) Close(ctx context.Context, params func(Closer_close_Params) error) (Closer_close_Results_Future, capnp.ReleaseFunc)
func (Chan) GetFlowLimiter ¶
func (c Chan) GetFlowLimiter() fc.FlowLimiter
Get the current flowcontrol.FlowLimiter used to manage flow control for this client.
func (Chan) 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 (Chan) 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 (Chan) NewCloser ¶
func (c Chan) NewCloser(ctx context.Context, params func(SendCloser_newCloser_Params) error) (SendCloser_newCloser_Results_Future, capnp.ReleaseFunc)
func (Chan) NewRecver ¶
func (c Chan) NewRecver(ctx context.Context, params func(Chan_newRecver_Params) error) (Chan_newRecver_Results_Future, capnp.ReleaseFunc)
func (Chan) NewSendCloser ¶
func (c Chan) NewSendCloser(ctx context.Context, params func(Chan_newSendCloser_Params) error) (Chan_newSendCloser_Results_Future, capnp.ReleaseFunc)
func (Chan) NewSender ¶
func (c Chan) NewSender(ctx context.Context, params func(SendCloser_newSender_Params) error) (SendCloser_newSender_Results_Future, capnp.ReleaseFunc)
func (Chan) Recv ¶
func (c Chan) Recv(ctx context.Context, params func(Recver_recv_Params) error) (Recver_recv_Results_Future, capnp.ReleaseFunc)
func (Chan) Release ¶
func (c Chan) 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 (Chan) Send ¶
func (c Chan) Send(ctx context.Context, params func(Sender_send_Params) error) (Sender_send_Results_Future, capnp.ReleaseFunc)
func (Chan) SetFlowLimiter ¶
func (c Chan) 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 (Chan) 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 (Chan) WaitStreaming ¶
type Chan_Server ¶
type Chan_Server interface { NewSendCloser(context.Context, Chan_newSendCloser) error NewRecver(context.Context, Chan_newRecver) error NewSender(context.Context, SendCloser_newSender) error NewCloser(context.Context, SendCloser_newCloser) error Send(context.Context, Sender_send) error Close(context.Context, Closer_close) error Recv(context.Context, Recver_recv) error }
A Chan_Server is a Chan with a local implementation.
type Chan_newRecver ¶
Chan_newRecver holds the state for a server call to Chan.newRecver. See server.Call for documentation.
func (Chan_newRecver) AllocResults ¶
func (c Chan_newRecver) AllocResults() (Chan_newRecver_Results, error)
AllocResults allocates the results struct.
func (Chan_newRecver) Args ¶
func (c Chan_newRecver) Args() Chan_newRecver_Params
Args returns the call's arguments.
type Chan_newRecver_Params ¶
func NewChan_newRecver_Params ¶
func NewChan_newRecver_Params(s *capnp.Segment) (Chan_newRecver_Params, error)
func NewRootChan_newRecver_Params ¶
func NewRootChan_newRecver_Params(s *capnp.Segment) (Chan_newRecver_Params, error)
func ReadRootChan_newRecver_Params ¶
func ReadRootChan_newRecver_Params(msg *capnp.Message) (Chan_newRecver_Params, error)
func (Chan_newRecver_Params) DecodeFromPtr ¶
func (Chan_newRecver_Params) DecodeFromPtr(p capnp.Ptr) Chan_newRecver_Params
func (Chan_newRecver_Params) EncodeAsPtr ¶
func (s Chan_newRecver_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Chan_newRecver_Params) IsValid ¶
func (s Chan_newRecver_Params) IsValid() bool
func (Chan_newRecver_Params) Message ¶
func (s Chan_newRecver_Params) Message() *capnp.Message
func (Chan_newRecver_Params) Segment ¶
func (s Chan_newRecver_Params) Segment() *capnp.Segment
func (Chan_newRecver_Params) String ¶
func (s Chan_newRecver_Params) String() string
func (Chan_newRecver_Params) ToPtr ¶
func (s Chan_newRecver_Params) ToPtr() capnp.Ptr
type Chan_newRecver_Params_Future ¶
Chan_newRecver_Params_Future is a wrapper for a Chan_newRecver_Params promised by a client call.
func (Chan_newRecver_Params_Future) Struct ¶
func (f Chan_newRecver_Params_Future) Struct() (Chan_newRecver_Params, error)
type Chan_newRecver_Params_List ¶
type Chan_newRecver_Params_List = capnp.StructList[Chan_newRecver_Params]
Chan_newRecver_Params_List is a list of Chan_newRecver_Params.
func NewChan_newRecver_Params_List ¶
func NewChan_newRecver_Params_List(s *capnp.Segment, sz int32) (Chan_newRecver_Params_List, error)
NewChan_newRecver_Params creates a new list of Chan_newRecver_Params.
type Chan_newRecver_Results ¶
func NewChan_newRecver_Results ¶
func NewChan_newRecver_Results(s *capnp.Segment) (Chan_newRecver_Results, error)
func NewRootChan_newRecver_Results ¶
func NewRootChan_newRecver_Results(s *capnp.Segment) (Chan_newRecver_Results, error)
func ReadRootChan_newRecver_Results ¶
func ReadRootChan_newRecver_Results(msg *capnp.Message) (Chan_newRecver_Results, error)
func (Chan_newRecver_Results) DecodeFromPtr ¶
func (Chan_newRecver_Results) DecodeFromPtr(p capnp.Ptr) Chan_newRecver_Results
func (Chan_newRecver_Results) EncodeAsPtr ¶
func (s Chan_newRecver_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Chan_newRecver_Results) HasRecver ¶
func (s Chan_newRecver_Results) HasRecver() bool
func (Chan_newRecver_Results) IsValid ¶
func (s Chan_newRecver_Results) IsValid() bool
func (Chan_newRecver_Results) Message ¶
func (s Chan_newRecver_Results) Message() *capnp.Message
func (Chan_newRecver_Results) Recver ¶
func (s Chan_newRecver_Results) Recver() Recver
func (Chan_newRecver_Results) Segment ¶
func (s Chan_newRecver_Results) Segment() *capnp.Segment
func (Chan_newRecver_Results) SetRecver ¶
func (s Chan_newRecver_Results) SetRecver(v Recver) error
func (Chan_newRecver_Results) String ¶
func (s Chan_newRecver_Results) String() string
func (Chan_newRecver_Results) ToPtr ¶
func (s Chan_newRecver_Results) ToPtr() capnp.Ptr
type Chan_newRecver_Results_Future ¶
Chan_newRecver_Results_Future is a wrapper for a Chan_newRecver_Results promised by a client call.
func (Chan_newRecver_Results_Future) Recver ¶
func (p Chan_newRecver_Results_Future) Recver() Recver
func (Chan_newRecver_Results_Future) Struct ¶
func (f Chan_newRecver_Results_Future) Struct() (Chan_newRecver_Results, error)
type Chan_newRecver_Results_List ¶
type Chan_newRecver_Results_List = capnp.StructList[Chan_newRecver_Results]
Chan_newRecver_Results_List is a list of Chan_newRecver_Results.
func NewChan_newRecver_Results_List ¶
func NewChan_newRecver_Results_List(s *capnp.Segment, sz int32) (Chan_newRecver_Results_List, error)
NewChan_newRecver_Results creates a new list of Chan_newRecver_Results.
type Chan_newSendCloser ¶
Chan_newSendCloser holds the state for a server call to Chan.newSendCloser. See server.Call for documentation.
func (Chan_newSendCloser) AllocResults ¶
func (c Chan_newSendCloser) AllocResults() (Chan_newSendCloser_Results, error)
AllocResults allocates the results struct.
func (Chan_newSendCloser) Args ¶
func (c Chan_newSendCloser) Args() Chan_newSendCloser_Params
Args returns the call's arguments.
type Chan_newSendCloser_Params ¶
func NewChan_newSendCloser_Params ¶
func NewChan_newSendCloser_Params(s *capnp.Segment) (Chan_newSendCloser_Params, error)
func NewRootChan_newSendCloser_Params ¶
func NewRootChan_newSendCloser_Params(s *capnp.Segment) (Chan_newSendCloser_Params, error)
func ReadRootChan_newSendCloser_Params ¶
func ReadRootChan_newSendCloser_Params(msg *capnp.Message) (Chan_newSendCloser_Params, error)
func (Chan_newSendCloser_Params) DecodeFromPtr ¶
func (Chan_newSendCloser_Params) DecodeFromPtr(p capnp.Ptr) Chan_newSendCloser_Params
func (Chan_newSendCloser_Params) EncodeAsPtr ¶
func (s Chan_newSendCloser_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Chan_newSendCloser_Params) IsValid ¶
func (s Chan_newSendCloser_Params) IsValid() bool
func (Chan_newSendCloser_Params) Message ¶
func (s Chan_newSendCloser_Params) Message() *capnp.Message
func (Chan_newSendCloser_Params) Segment ¶
func (s Chan_newSendCloser_Params) Segment() *capnp.Segment
func (Chan_newSendCloser_Params) String ¶
func (s Chan_newSendCloser_Params) String() string
func (Chan_newSendCloser_Params) ToPtr ¶
func (s Chan_newSendCloser_Params) ToPtr() capnp.Ptr
type Chan_newSendCloser_Params_Future ¶
Chan_newSendCloser_Params_Future is a wrapper for a Chan_newSendCloser_Params promised by a client call.
func (Chan_newSendCloser_Params_Future) Struct ¶
func (f Chan_newSendCloser_Params_Future) Struct() (Chan_newSendCloser_Params, error)
type Chan_newSendCloser_Params_List ¶
type Chan_newSendCloser_Params_List = capnp.StructList[Chan_newSendCloser_Params]
Chan_newSendCloser_Params_List is a list of Chan_newSendCloser_Params.
func NewChan_newSendCloser_Params_List ¶
func NewChan_newSendCloser_Params_List(s *capnp.Segment, sz int32) (Chan_newSendCloser_Params_List, error)
NewChan_newSendCloser_Params creates a new list of Chan_newSendCloser_Params.
type Chan_newSendCloser_Results ¶
func NewChan_newSendCloser_Results ¶
func NewChan_newSendCloser_Results(s *capnp.Segment) (Chan_newSendCloser_Results, error)
func NewRootChan_newSendCloser_Results ¶
func NewRootChan_newSendCloser_Results(s *capnp.Segment) (Chan_newSendCloser_Results, error)
func ReadRootChan_newSendCloser_Results ¶
func ReadRootChan_newSendCloser_Results(msg *capnp.Message) (Chan_newSendCloser_Results, error)
func (Chan_newSendCloser_Results) DecodeFromPtr ¶
func (Chan_newSendCloser_Results) DecodeFromPtr(p capnp.Ptr) Chan_newSendCloser_Results
func (Chan_newSendCloser_Results) EncodeAsPtr ¶
func (s Chan_newSendCloser_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Chan_newSendCloser_Results) HasSendCloser ¶
func (s Chan_newSendCloser_Results) HasSendCloser() bool
func (Chan_newSendCloser_Results) IsValid ¶
func (s Chan_newSendCloser_Results) IsValid() bool
func (Chan_newSendCloser_Results) Message ¶
func (s Chan_newSendCloser_Results) Message() *capnp.Message
func (Chan_newSendCloser_Results) Segment ¶
func (s Chan_newSendCloser_Results) Segment() *capnp.Segment
func (Chan_newSendCloser_Results) SendCloser ¶
func (s Chan_newSendCloser_Results) SendCloser() SendCloser
func (Chan_newSendCloser_Results) SetSendCloser ¶
func (s Chan_newSendCloser_Results) SetSendCloser(v SendCloser) error
func (Chan_newSendCloser_Results) String ¶
func (s Chan_newSendCloser_Results) String() string
func (Chan_newSendCloser_Results) ToPtr ¶
func (s Chan_newSendCloser_Results) ToPtr() capnp.Ptr
type Chan_newSendCloser_Results_Future ¶
Chan_newSendCloser_Results_Future is a wrapper for a Chan_newSendCloser_Results promised by a client call.
func (Chan_newSendCloser_Results_Future) SendCloser ¶
func (p Chan_newSendCloser_Results_Future) SendCloser() SendCloser
func (Chan_newSendCloser_Results_Future) Struct ¶
func (f Chan_newSendCloser_Results_Future) Struct() (Chan_newSendCloser_Results, error)
type Chan_newSendCloser_Results_List ¶
type Chan_newSendCloser_Results_List = capnp.StructList[Chan_newSendCloser_Results]
Chan_newSendCloser_Results_List is a list of Chan_newSendCloser_Results.
func NewChan_newSendCloser_Results_List ¶
func NewChan_newSendCloser_Results_List(s *capnp.Segment, sz int32) (Chan_newSendCloser_Results_List, error)
NewChan_newSendCloser_Results creates a new list of Chan_newSendCloser_Results.
type Closer ¶
func Closer_ServerToClient ¶
func Closer_ServerToClient(s Closer_Server) Closer
Closer_ServerToClient creates a new Client from an implementation of Closer_Server. The caller is responsible for calling Release on the returned Client.
func (Closer) 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 (Closer) Close ¶
func (c Closer) Close(ctx context.Context, params func(Closer_close_Params) error) (Closer_close_Results_Future, capnp.ReleaseFunc)
func (Closer) GetFlowLimiter ¶
func (c Closer) GetFlowLimiter() fc.FlowLimiter
Get the current flowcontrol.FlowLimiter used to manage flow control for this client.
func (Closer) 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 (Closer) 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 (Closer) Release ¶
func (c Closer) 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 (Closer) Resolve ¶
Resolve blocks until the capability is fully resolved or the Context expires.
func (Closer) SetFlowLimiter ¶
func (c Closer) 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 (Closer) 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 (Closer) WaitStreaming ¶
type Closer_List ¶
Closer_List is a list of Closer.
func NewCloser_List ¶
func NewCloser_List(s *capnp.Segment, sz int32) (Closer_List, error)
NewCloser creates a new list of Closer.
type Closer_Server ¶
type Closer_Server interface {
Close(context.Context, Closer_close) error
}
A Closer_Server is a Closer with a local implementation.
type Closer_close ¶
Closer_close holds the state for a server call to Closer.close. See server.Call for documentation.
func (Closer_close) AllocResults ¶
func (c Closer_close) AllocResults() (Closer_close_Results, error)
AllocResults allocates the results struct.
func (Closer_close) Args ¶
func (c Closer_close) Args() Closer_close_Params
Args returns the call's arguments.
type Closer_close_Params ¶
func NewCloser_close_Params ¶
func NewCloser_close_Params(s *capnp.Segment) (Closer_close_Params, error)
func NewRootCloser_close_Params ¶
func NewRootCloser_close_Params(s *capnp.Segment) (Closer_close_Params, error)
func ReadRootCloser_close_Params ¶
func ReadRootCloser_close_Params(msg *capnp.Message) (Closer_close_Params, error)
func (Closer_close_Params) DecodeFromPtr ¶
func (Closer_close_Params) DecodeFromPtr(p capnp.Ptr) Closer_close_Params
func (Closer_close_Params) EncodeAsPtr ¶
func (s Closer_close_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Closer_close_Params) IsValid ¶
func (s Closer_close_Params) IsValid() bool
func (Closer_close_Params) Message ¶
func (s Closer_close_Params) Message() *capnp.Message
func (Closer_close_Params) Segment ¶
func (s Closer_close_Params) Segment() *capnp.Segment
func (Closer_close_Params) String ¶
func (s Closer_close_Params) String() string
func (Closer_close_Params) ToPtr ¶
func (s Closer_close_Params) ToPtr() capnp.Ptr
type Closer_close_Params_Future ¶
Closer_close_Params_Future is a wrapper for a Closer_close_Params promised by a client call.
func (Closer_close_Params_Future) Struct ¶
func (f Closer_close_Params_Future) Struct() (Closer_close_Params, error)
type Closer_close_Params_List ¶
type Closer_close_Params_List = capnp.StructList[Closer_close_Params]
Closer_close_Params_List is a list of Closer_close_Params.
func NewCloser_close_Params_List ¶
func NewCloser_close_Params_List(s *capnp.Segment, sz int32) (Closer_close_Params_List, error)
NewCloser_close_Params creates a new list of Closer_close_Params.
type Closer_close_Results ¶
func NewCloser_close_Results ¶
func NewCloser_close_Results(s *capnp.Segment) (Closer_close_Results, error)
func NewRootCloser_close_Results ¶
func NewRootCloser_close_Results(s *capnp.Segment) (Closer_close_Results, error)
func ReadRootCloser_close_Results ¶
func ReadRootCloser_close_Results(msg *capnp.Message) (Closer_close_Results, error)
func (Closer_close_Results) DecodeFromPtr ¶
func (Closer_close_Results) DecodeFromPtr(p capnp.Ptr) Closer_close_Results
func (Closer_close_Results) EncodeAsPtr ¶
func (s Closer_close_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Closer_close_Results) IsValid ¶
func (s Closer_close_Results) IsValid() bool
func (Closer_close_Results) Message ¶
func (s Closer_close_Results) Message() *capnp.Message
func (Closer_close_Results) Segment ¶
func (s Closer_close_Results) Segment() *capnp.Segment
func (Closer_close_Results) String ¶
func (s Closer_close_Results) String() string
func (Closer_close_Results) ToPtr ¶
func (s Closer_close_Results) ToPtr() capnp.Ptr
type Closer_close_Results_Future ¶
Closer_close_Results_Future is a wrapper for a Closer_close_Results promised by a client call.
func (Closer_close_Results_Future) Struct ¶
func (f Closer_close_Results_Future) Struct() (Closer_close_Results, error)
type Closer_close_Results_List ¶
type Closer_close_Results_List = capnp.StructList[Closer_close_Results]
Closer_close_Results_List is a list of Closer_close_Results.
func NewCloser_close_Results_List ¶
func NewCloser_close_Results_List(s *capnp.Segment, sz int32) (Closer_close_Results_List, error)
NewCloser_close_Results creates a new list of Closer_close_Results.
type Recver ¶
func Recver_ServerToClient ¶
func Recver_ServerToClient(s Recver_Server) Recver
Recver_ServerToClient creates a new Client from an implementation of Recver_Server. The caller is responsible for calling Release on the returned Client.
func (Recver) 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 (Recver) GetFlowLimiter ¶
func (c Recver) GetFlowLimiter() fc.FlowLimiter
Get the current flowcontrol.FlowLimiter used to manage flow control for this client.
func (Recver) 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 (Recver) 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 (Recver) Recv ¶
func (c Recver) Recv(ctx context.Context, params func(Recver_recv_Params) error) (Recver_recv_Results_Future, capnp.ReleaseFunc)
func (Recver) Release ¶
func (c Recver) 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 (Recver) Resolve ¶
Resolve blocks until the capability is fully resolved or the Context expires.
func (Recver) SetFlowLimiter ¶
func (c Recver) 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 (Recver) 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 (Recver) WaitStreaming ¶
type Recver_List ¶
Recver_List is a list of Recver.
func NewRecver_List ¶
func NewRecver_List(s *capnp.Segment, sz int32) (Recver_List, error)
NewRecver creates a new list of Recver.
type Recver_Server ¶
type Recver_Server interface {
Recv(context.Context, Recver_recv) error
}
A Recver_Server is a Recver with a local implementation.
type Recver_recv ¶
Recver_recv holds the state for a server call to Recver.recv. See server.Call for documentation.
func (Recver_recv) AllocResults ¶
func (c Recver_recv) AllocResults() (Recver_recv_Results, error)
AllocResults allocates the results struct.
func (Recver_recv) Args ¶
func (c Recver_recv) Args() Recver_recv_Params
Args returns the call's arguments.
type Recver_recv_Params ¶
func NewRecver_recv_Params ¶
func NewRecver_recv_Params(s *capnp.Segment) (Recver_recv_Params, error)
func NewRootRecver_recv_Params ¶
func NewRootRecver_recv_Params(s *capnp.Segment) (Recver_recv_Params, error)
func ReadRootRecver_recv_Params ¶
func ReadRootRecver_recv_Params(msg *capnp.Message) (Recver_recv_Params, error)
func (Recver_recv_Params) DecodeFromPtr ¶
func (Recver_recv_Params) DecodeFromPtr(p capnp.Ptr) Recver_recv_Params
func (Recver_recv_Params) EncodeAsPtr ¶
func (s Recver_recv_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Recver_recv_Params) IsValid ¶
func (s Recver_recv_Params) IsValid() bool
func (Recver_recv_Params) Message ¶
func (s Recver_recv_Params) Message() *capnp.Message
func (Recver_recv_Params) Segment ¶
func (s Recver_recv_Params) Segment() *capnp.Segment
func (Recver_recv_Params) String ¶
func (s Recver_recv_Params) String() string
func (Recver_recv_Params) ToPtr ¶
func (s Recver_recv_Params) ToPtr() capnp.Ptr
type Recver_recv_Params_Future ¶
Recver_recv_Params_Future is a wrapper for a Recver_recv_Params promised by a client call.
func (Recver_recv_Params_Future) Struct ¶
func (f Recver_recv_Params_Future) Struct() (Recver_recv_Params, error)
type Recver_recv_Params_List ¶
type Recver_recv_Params_List = capnp.StructList[Recver_recv_Params]
Recver_recv_Params_List is a list of Recver_recv_Params.
func NewRecver_recv_Params_List ¶
func NewRecver_recv_Params_List(s *capnp.Segment, sz int32) (Recver_recv_Params_List, error)
NewRecver_recv_Params creates a new list of Recver_recv_Params.
type Recver_recv_Results ¶
func NewRecver_recv_Results ¶
func NewRecver_recv_Results(s *capnp.Segment) (Recver_recv_Results, error)
func NewRootRecver_recv_Results ¶
func NewRootRecver_recv_Results(s *capnp.Segment) (Recver_recv_Results, error)
func ReadRootRecver_recv_Results ¶
func ReadRootRecver_recv_Results(msg *capnp.Message) (Recver_recv_Results, error)
func (Recver_recv_Results) DecodeFromPtr ¶
func (Recver_recv_Results) DecodeFromPtr(p capnp.Ptr) Recver_recv_Results
func (Recver_recv_Results) EncodeAsPtr ¶
func (s Recver_recv_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Recver_recv_Results) HasValue ¶
func (s Recver_recv_Results) HasValue() bool
func (Recver_recv_Results) IsValid ¶
func (s Recver_recv_Results) IsValid() bool
func (Recver_recv_Results) Message ¶
func (s Recver_recv_Results) Message() *capnp.Message
func (Recver_recv_Results) Segment ¶
func (s Recver_recv_Results) Segment() *capnp.Segment
func (Recver_recv_Results) String ¶
func (s Recver_recv_Results) String() string
func (Recver_recv_Results) ToPtr ¶
func (s Recver_recv_Results) ToPtr() capnp.Ptr
type Recver_recv_Results_Future ¶
Recver_recv_Results_Future is a wrapper for a Recver_recv_Results promised by a client call.
func (Recver_recv_Results_Future) Struct ¶
func (f Recver_recv_Results_Future) Struct() (Recver_recv_Results, error)
func (Recver_recv_Results_Future) Value ¶
func (p Recver_recv_Results_Future) Value() *capnp.Future
type Recver_recv_Results_List ¶
type Recver_recv_Results_List = capnp.StructList[Recver_recv_Results]
Recver_recv_Results_List is a list of Recver_recv_Results.
func NewRecver_recv_Results_List ¶
func NewRecver_recv_Results_List(s *capnp.Segment, sz int32) (Recver_recv_Results_List, error)
NewRecver_recv_Results creates a new list of Recver_recv_Results.
type SendCloser ¶
func SendCloser_ServerToClient ¶
func SendCloser_ServerToClient(s SendCloser_Server) SendCloser
SendCloser_ServerToClient creates a new Client from an implementation of SendCloser_Server. The caller is responsible for calling Release on the returned Client.
func (SendCloser) AddRef ¶
func (c SendCloser) AddRef() SendCloser
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 (SendCloser) Close ¶
func (c SendCloser) Close(ctx context.Context, params func(Closer_close_Params) error) (Closer_close_Results_Future, capnp.ReleaseFunc)
func (SendCloser) DecodeFromPtr ¶
func (SendCloser) DecodeFromPtr(p capnp.Ptr) SendCloser
func (SendCloser) EncodeAsPtr ¶
func (c SendCloser) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (SendCloser) GetFlowLimiter ¶
func (c SendCloser) GetFlowLimiter() fc.FlowLimiter
Get the current flowcontrol.FlowLimiter used to manage flow control for this client.
func (SendCloser) IsSame ¶
func (c SendCloser) IsSame(other SendCloser) 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 (SendCloser) IsValid ¶
func (c SendCloser) 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 (SendCloser) NewCloser ¶
func (c SendCloser) NewCloser(ctx context.Context, params func(SendCloser_newCloser_Params) error) (SendCloser_newCloser_Results_Future, capnp.ReleaseFunc)
func (SendCloser) NewSender ¶
func (c SendCloser) NewSender(ctx context.Context, params func(SendCloser_newSender_Params) error) (SendCloser_newSender_Results_Future, capnp.ReleaseFunc)
func (SendCloser) Release ¶
func (c SendCloser) 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 (SendCloser) Resolve ¶
func (c SendCloser) Resolve(ctx context.Context) error
Resolve blocks until the capability is fully resolved or the Context expires.
func (SendCloser) Send ¶
func (c SendCloser) Send(ctx context.Context, params func(Sender_send_Params) error) (Sender_send_Results_Future, capnp.ReleaseFunc)
func (SendCloser) SetFlowLimiter ¶
func (c SendCloser) 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 (SendCloser) String ¶
func (c SendCloser) 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 (SendCloser) WaitStreaming ¶
func (c SendCloser) WaitStreaming() error
type SendCloser_List ¶
type SendCloser_List = capnp.CapList[SendCloser]
SendCloser_List is a list of SendCloser.
func NewSendCloser_List ¶
func NewSendCloser_List(s *capnp.Segment, sz int32) (SendCloser_List, error)
NewSendCloser creates a new list of SendCloser.
type SendCloser_Server ¶
type SendCloser_Server interface { NewSender(context.Context, SendCloser_newSender) error NewCloser(context.Context, SendCloser_newCloser) error Send(context.Context, Sender_send) error Close(context.Context, Closer_close) error }
A SendCloser_Server is a SendCloser with a local implementation.
type SendCloser_newCloser ¶
SendCloser_newCloser holds the state for a server call to SendCloser.newCloser. See server.Call for documentation.
func (SendCloser_newCloser) AllocResults ¶
func (c SendCloser_newCloser) AllocResults() (SendCloser_newCloser_Results, error)
AllocResults allocates the results struct.
func (SendCloser_newCloser) Args ¶
func (c SendCloser_newCloser) Args() SendCloser_newCloser_Params
Args returns the call's arguments.
type SendCloser_newCloser_Params ¶
func NewRootSendCloser_newCloser_Params ¶
func NewRootSendCloser_newCloser_Params(s *capnp.Segment) (SendCloser_newCloser_Params, error)
func NewSendCloser_newCloser_Params ¶
func NewSendCloser_newCloser_Params(s *capnp.Segment) (SendCloser_newCloser_Params, error)
func ReadRootSendCloser_newCloser_Params ¶
func ReadRootSendCloser_newCloser_Params(msg *capnp.Message) (SendCloser_newCloser_Params, error)
func (SendCloser_newCloser_Params) DecodeFromPtr ¶
func (SendCloser_newCloser_Params) DecodeFromPtr(p capnp.Ptr) SendCloser_newCloser_Params
func (SendCloser_newCloser_Params) EncodeAsPtr ¶
func (s SendCloser_newCloser_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (SendCloser_newCloser_Params) IsValid ¶
func (s SendCloser_newCloser_Params) IsValid() bool
func (SendCloser_newCloser_Params) Message ¶
func (s SendCloser_newCloser_Params) Message() *capnp.Message
func (SendCloser_newCloser_Params) Segment ¶
func (s SendCloser_newCloser_Params) Segment() *capnp.Segment
func (SendCloser_newCloser_Params) String ¶
func (s SendCloser_newCloser_Params) String() string
func (SendCloser_newCloser_Params) ToPtr ¶
func (s SendCloser_newCloser_Params) ToPtr() capnp.Ptr
type SendCloser_newCloser_Params_Future ¶
SendCloser_newCloser_Params_Future is a wrapper for a SendCloser_newCloser_Params promised by a client call.
func (SendCloser_newCloser_Params_Future) Struct ¶
func (f SendCloser_newCloser_Params_Future) Struct() (SendCloser_newCloser_Params, error)
type SendCloser_newCloser_Params_List ¶
type SendCloser_newCloser_Params_List = capnp.StructList[SendCloser_newCloser_Params]
SendCloser_newCloser_Params_List is a list of SendCloser_newCloser_Params.
func NewSendCloser_newCloser_Params_List ¶
func NewSendCloser_newCloser_Params_List(s *capnp.Segment, sz int32) (SendCloser_newCloser_Params_List, error)
NewSendCloser_newCloser_Params creates a new list of SendCloser_newCloser_Params.
type SendCloser_newCloser_Results ¶
func NewRootSendCloser_newCloser_Results ¶
func NewRootSendCloser_newCloser_Results(s *capnp.Segment) (SendCloser_newCloser_Results, error)
func NewSendCloser_newCloser_Results ¶
func NewSendCloser_newCloser_Results(s *capnp.Segment) (SendCloser_newCloser_Results, error)
func ReadRootSendCloser_newCloser_Results ¶
func ReadRootSendCloser_newCloser_Results(msg *capnp.Message) (SendCloser_newCloser_Results, error)
func (SendCloser_newCloser_Results) Closer ¶
func (s SendCloser_newCloser_Results) Closer() Closer
func (SendCloser_newCloser_Results) DecodeFromPtr ¶
func (SendCloser_newCloser_Results) DecodeFromPtr(p capnp.Ptr) SendCloser_newCloser_Results
func (SendCloser_newCloser_Results) EncodeAsPtr ¶
func (s SendCloser_newCloser_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (SendCloser_newCloser_Results) HasCloser ¶
func (s SendCloser_newCloser_Results) HasCloser() bool
func (SendCloser_newCloser_Results) IsValid ¶
func (s SendCloser_newCloser_Results) IsValid() bool
func (SendCloser_newCloser_Results) Message ¶
func (s SendCloser_newCloser_Results) Message() *capnp.Message
func (SendCloser_newCloser_Results) Segment ¶
func (s SendCloser_newCloser_Results) Segment() *capnp.Segment
func (SendCloser_newCloser_Results) SetCloser ¶
func (s SendCloser_newCloser_Results) SetCloser(v Closer) error
func (SendCloser_newCloser_Results) String ¶
func (s SendCloser_newCloser_Results) String() string
func (SendCloser_newCloser_Results) ToPtr ¶
func (s SendCloser_newCloser_Results) ToPtr() capnp.Ptr
type SendCloser_newCloser_Results_Future ¶
SendCloser_newCloser_Results_Future is a wrapper for a SendCloser_newCloser_Results promised by a client call.
func (SendCloser_newCloser_Results_Future) Closer ¶
func (p SendCloser_newCloser_Results_Future) Closer() Closer
func (SendCloser_newCloser_Results_Future) Struct ¶
func (f SendCloser_newCloser_Results_Future) Struct() (SendCloser_newCloser_Results, error)
type SendCloser_newCloser_Results_List ¶
type SendCloser_newCloser_Results_List = capnp.StructList[SendCloser_newCloser_Results]
SendCloser_newCloser_Results_List is a list of SendCloser_newCloser_Results.
func NewSendCloser_newCloser_Results_List ¶
func NewSendCloser_newCloser_Results_List(s *capnp.Segment, sz int32) (SendCloser_newCloser_Results_List, error)
NewSendCloser_newCloser_Results creates a new list of SendCloser_newCloser_Results.
type SendCloser_newSender ¶
SendCloser_newSender holds the state for a server call to SendCloser.newSender. See server.Call for documentation.
func (SendCloser_newSender) AllocResults ¶
func (c SendCloser_newSender) AllocResults() (SendCloser_newSender_Results, error)
AllocResults allocates the results struct.
func (SendCloser_newSender) Args ¶
func (c SendCloser_newSender) Args() SendCloser_newSender_Params
Args returns the call's arguments.
type SendCloser_newSender_Params ¶
func NewRootSendCloser_newSender_Params ¶
func NewRootSendCloser_newSender_Params(s *capnp.Segment) (SendCloser_newSender_Params, error)
func NewSendCloser_newSender_Params ¶
func NewSendCloser_newSender_Params(s *capnp.Segment) (SendCloser_newSender_Params, error)
func ReadRootSendCloser_newSender_Params ¶
func ReadRootSendCloser_newSender_Params(msg *capnp.Message) (SendCloser_newSender_Params, error)
func (SendCloser_newSender_Params) DecodeFromPtr ¶
func (SendCloser_newSender_Params) DecodeFromPtr(p capnp.Ptr) SendCloser_newSender_Params
func (SendCloser_newSender_Params) EncodeAsPtr ¶
func (s SendCloser_newSender_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (SendCloser_newSender_Params) IsValid ¶
func (s SendCloser_newSender_Params) IsValid() bool
func (SendCloser_newSender_Params) Message ¶
func (s SendCloser_newSender_Params) Message() *capnp.Message
func (SendCloser_newSender_Params) Segment ¶
func (s SendCloser_newSender_Params) Segment() *capnp.Segment
func (SendCloser_newSender_Params) String ¶
func (s SendCloser_newSender_Params) String() string
func (SendCloser_newSender_Params) ToPtr ¶
func (s SendCloser_newSender_Params) ToPtr() capnp.Ptr
type SendCloser_newSender_Params_Future ¶
SendCloser_newSender_Params_Future is a wrapper for a SendCloser_newSender_Params promised by a client call.
func (SendCloser_newSender_Params_Future) Struct ¶
func (f SendCloser_newSender_Params_Future) Struct() (SendCloser_newSender_Params, error)
type SendCloser_newSender_Params_List ¶
type SendCloser_newSender_Params_List = capnp.StructList[SendCloser_newSender_Params]
SendCloser_newSender_Params_List is a list of SendCloser_newSender_Params.
func NewSendCloser_newSender_Params_List ¶
func NewSendCloser_newSender_Params_List(s *capnp.Segment, sz int32) (SendCloser_newSender_Params_List, error)
NewSendCloser_newSender_Params creates a new list of SendCloser_newSender_Params.
type SendCloser_newSender_Results ¶
func NewRootSendCloser_newSender_Results ¶
func NewRootSendCloser_newSender_Results(s *capnp.Segment) (SendCloser_newSender_Results, error)
func NewSendCloser_newSender_Results ¶
func NewSendCloser_newSender_Results(s *capnp.Segment) (SendCloser_newSender_Results, error)
func ReadRootSendCloser_newSender_Results ¶
func ReadRootSendCloser_newSender_Results(msg *capnp.Message) (SendCloser_newSender_Results, error)
func (SendCloser_newSender_Results) DecodeFromPtr ¶
func (SendCloser_newSender_Results) DecodeFromPtr(p capnp.Ptr) SendCloser_newSender_Results
func (SendCloser_newSender_Results) EncodeAsPtr ¶
func (s SendCloser_newSender_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (SendCloser_newSender_Results) HasSender ¶
func (s SendCloser_newSender_Results) HasSender() bool
func (SendCloser_newSender_Results) IsValid ¶
func (s SendCloser_newSender_Results) IsValid() bool
func (SendCloser_newSender_Results) Message ¶
func (s SendCloser_newSender_Results) Message() *capnp.Message
func (SendCloser_newSender_Results) Segment ¶
func (s SendCloser_newSender_Results) Segment() *capnp.Segment
func (SendCloser_newSender_Results) Sender ¶
func (s SendCloser_newSender_Results) Sender() Sender
func (SendCloser_newSender_Results) SetSender ¶
func (s SendCloser_newSender_Results) SetSender(v Sender) error
func (SendCloser_newSender_Results) String ¶
func (s SendCloser_newSender_Results) String() string
func (SendCloser_newSender_Results) ToPtr ¶
func (s SendCloser_newSender_Results) ToPtr() capnp.Ptr
type SendCloser_newSender_Results_Future ¶
SendCloser_newSender_Results_Future is a wrapper for a SendCloser_newSender_Results promised by a client call.
func (SendCloser_newSender_Results_Future) Sender ¶
func (p SendCloser_newSender_Results_Future) Sender() Sender
func (SendCloser_newSender_Results_Future) Struct ¶
func (f SendCloser_newSender_Results_Future) Struct() (SendCloser_newSender_Results, error)
type SendCloser_newSender_Results_List ¶
type SendCloser_newSender_Results_List = capnp.StructList[SendCloser_newSender_Results]
SendCloser_newSender_Results_List is a list of SendCloser_newSender_Results.
func NewSendCloser_newSender_Results_List ¶
func NewSendCloser_newSender_Results_List(s *capnp.Segment, sz int32) (SendCloser_newSender_Results_List, error)
NewSendCloser_newSender_Results creates a new list of SendCloser_newSender_Results.
type Sender ¶
func Sender_ServerToClient ¶
func Sender_ServerToClient(s Sender_Server) Sender
Sender_ServerToClient creates a new Client from an implementation of Sender_Server. The caller is responsible for calling Release on the returned Client.
func (Sender) 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 (Sender) GetFlowLimiter ¶
func (c Sender) GetFlowLimiter() fc.FlowLimiter
Get the current flowcontrol.FlowLimiter used to manage flow control for this client.
func (Sender) 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 (Sender) 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 (Sender) Release ¶
func (c Sender) 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 (Sender) Resolve ¶
Resolve blocks until the capability is fully resolved or the Context expires.
func (Sender) Send ¶
func (c Sender) Send(ctx context.Context, params func(Sender_send_Params) error) (Sender_send_Results_Future, capnp.ReleaseFunc)
func (Sender) SetFlowLimiter ¶
func (c Sender) 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 (Sender) 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 (Sender) WaitStreaming ¶
type Sender_List ¶
Sender_List is a list of Sender.
func NewSender_List ¶
func NewSender_List(s *capnp.Segment, sz int32) (Sender_List, error)
NewSender creates a new list of Sender.
type Sender_Server ¶
type Sender_Server interface {
Send(context.Context, Sender_send) error
}
A Sender_Server is a Sender with a local implementation.
type Sender_send ¶
Sender_send holds the state for a server call to Sender.send. See server.Call for documentation.
func (Sender_send) AllocResults ¶
func (c Sender_send) AllocResults() (Sender_send_Results, error)
AllocResults allocates the results struct.
func (Sender_send) Args ¶
func (c Sender_send) Args() Sender_send_Params
Args returns the call's arguments.
type Sender_send_Params ¶
func NewRootSender_send_Params ¶
func NewRootSender_send_Params(s *capnp.Segment) (Sender_send_Params, error)
func NewSender_send_Params ¶
func NewSender_send_Params(s *capnp.Segment) (Sender_send_Params, error)
func ReadRootSender_send_Params ¶
func ReadRootSender_send_Params(msg *capnp.Message) (Sender_send_Params, error)
func (Sender_send_Params) DecodeFromPtr ¶
func (Sender_send_Params) DecodeFromPtr(p capnp.Ptr) Sender_send_Params
func (Sender_send_Params) EncodeAsPtr ¶
func (s Sender_send_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Sender_send_Params) HasValue ¶
func (s Sender_send_Params) HasValue() bool
func (Sender_send_Params) IsValid ¶
func (s Sender_send_Params) IsValid() bool
func (Sender_send_Params) Message ¶
func (s Sender_send_Params) Message() *capnp.Message
func (Sender_send_Params) Segment ¶
func (s Sender_send_Params) Segment() *capnp.Segment
func (Sender_send_Params) String ¶
func (s Sender_send_Params) String() string
func (Sender_send_Params) ToPtr ¶
func (s Sender_send_Params) ToPtr() capnp.Ptr
type Sender_send_Params_Future ¶
Sender_send_Params_Future is a wrapper for a Sender_send_Params promised by a client call.
func (Sender_send_Params_Future) Struct ¶
func (f Sender_send_Params_Future) Struct() (Sender_send_Params, error)
func (Sender_send_Params_Future) Value ¶
func (p Sender_send_Params_Future) Value() *capnp.Future
type Sender_send_Params_List ¶
type Sender_send_Params_List = capnp.StructList[Sender_send_Params]
Sender_send_Params_List is a list of Sender_send_Params.
func NewSender_send_Params_List ¶
func NewSender_send_Params_List(s *capnp.Segment, sz int32) (Sender_send_Params_List, error)
NewSender_send_Params creates a new list of Sender_send_Params.
type Sender_send_Results ¶
func NewRootSender_send_Results ¶
func NewRootSender_send_Results(s *capnp.Segment) (Sender_send_Results, error)
func NewSender_send_Results ¶
func NewSender_send_Results(s *capnp.Segment) (Sender_send_Results, error)
func ReadRootSender_send_Results ¶
func ReadRootSender_send_Results(msg *capnp.Message) (Sender_send_Results, error)
func (Sender_send_Results) DecodeFromPtr ¶
func (Sender_send_Results) DecodeFromPtr(p capnp.Ptr) Sender_send_Results
func (Sender_send_Results) EncodeAsPtr ¶
func (s Sender_send_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Sender_send_Results) IsValid ¶
func (s Sender_send_Results) IsValid() bool
func (Sender_send_Results) Message ¶
func (s Sender_send_Results) Message() *capnp.Message
func (Sender_send_Results) Segment ¶
func (s Sender_send_Results) Segment() *capnp.Segment
func (Sender_send_Results) String ¶
func (s Sender_send_Results) String() string
func (Sender_send_Results) ToPtr ¶
func (s Sender_send_Results) ToPtr() capnp.Ptr
type Sender_send_Results_Future ¶
Sender_send_Results_Future is a wrapper for a Sender_send_Results promised by a client call.
func (Sender_send_Results_Future) Struct ¶
func (f Sender_send_Results_Future) Struct() (Sender_send_Results, error)
type Sender_send_Results_List ¶
type Sender_send_Results_List = capnp.StructList[Sender_send_Results]
Sender_send_Results_List is a list of Sender_send_Results.
func NewSender_send_Results_List ¶
func NewSender_send_Results_List(s *capnp.Segment, sz int32) (Sender_send_Results_List, error)
NewSender_send_Results creates a new list of Sender_send_Results.