channel

package
v0.1.0-alpha.1 Latest Latest
Warning

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

 Go to latest Published: Aug 18, 2023 License: Apache-2.0, MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const Chan_TypeID = 0x95c89fe7d966f751

Chan_TypeID is the unique identifier for the type Chan.

View Source 
const Chan_newRecver_Params_TypeID = 0x891b1d7a66ab36b5

Chan_newRecver_Params_TypeID is the unique identifier for the type Chan_newRecver_Params.

View Source 
const Chan_newRecver_Results_TypeID = 0x9f8a81c20d0e72c9

Chan_newRecver_Results_TypeID is the unique identifier for the type Chan_newRecver_Results.

View Source 
const Chan_newSendCloser_Params_TypeID = 0xe76adde17bd7c3df

Chan_newSendCloser_Params_TypeID is the unique identifier for the type Chan_newSendCloser_Params.

View Source 
const Chan_newSendCloser_Results_TypeID = 0xcbbc3fcd0d01a855

Chan_newSendCloser_Results_TypeID is the unique identifier for the type Chan_newSendCloser_Results.

View Source 
const Closer_TypeID = 0xfad0e4b80d3779c3

Closer_TypeID is the unique identifier for the type Closer.

View Source 
const Closer_close_Params_TypeID = 0xfd07d8a1cc36583c

Closer_close_Params_TypeID is the unique identifier for the type Closer_close_Params.

View Source 
const Closer_close_Results_TypeID = 0xcbee5caf8b7af4ea

Closer_close_Results_TypeID is the unique identifier for the type Closer_close_Results.

View Source 
const Recver_TypeID = 0xdf05a90d671c0c07

Recver_TypeID is the unique identifier for the type Recver.

View Source 
const Recver_recv_Params_TypeID = 0xdd377ddc0d2426ea

Recver_recv_Params_TypeID is the unique identifier for the type Recver_recv_Params.

View Source 
const Recver_recv_Results_TypeID = 0xb0e88f4d0a3a1694

Recver_recv_Results_TypeID is the unique identifier for the type Recver_recv_Results.

View Source 
const SendCloser_TypeID = 0xe9a7d19a7d14e94e

SendCloser_TypeID is the unique identifier for the type SendCloser.

View Source 
const SendCloser_newCloser_Params_TypeID = 0xe48d9443d96ba68d

SendCloser_newCloser_Params_TypeID is the unique identifier for the type SendCloser_newCloser_Params.

View Source 
const SendCloser_newCloser_Results_TypeID = 0xf1dd4079b7c319f1

SendCloser_newCloser_Results_TypeID is the unique identifier for the type SendCloser_newCloser_Results.

View Source 
const SendCloser_newSender_Params_TypeID = 0xbb370dcc71a43ba9

SendCloser_newSender_Params_TypeID is the unique identifier for the type SendCloser_newSender_Params.

View Source 
const SendCloser_newSender_Results_TypeID = 0xca7110014301ab81

SendCloser_newSender_Results_TypeID is the unique identifier for the type SendCloser_newSender_Results.

View Source 
const Sender_TypeID = 0xe8bbed1438ea16ee

Sender_TypeID is the unique identifier for the type Sender.

View Source 
const Sender_send_Params_TypeID = 0x8166bc9c3ded78ca

Sender_send_Params_TypeID is the unique identifier for the type Sender_send_Params.

View Source 
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 RegisterSchema(reg *schemas.Registry)

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 

type Chan capnp.Client

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 

func (c Chan) AddRef() Chan

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

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

func (Chan) EncodeAsPtr 

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

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 

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

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

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

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

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 

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

func (c Chan) WaitStreaming() error

type Chan_List 

type Chan_List = capnp.CapList[Chan]

Chan_List is a list of Chan.

func NewChan_List 

func NewChan_List(s *capnp.Segment, sz int32) (Chan_List, error)

NewChan creates a new list of Chan.

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 

type Chan_newRecver struct {
	*server.Call
}

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 

type Chan_newRecver_Params capnp.Struct

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 

type Chan_newRecver_Params_Future struct{ *capnp.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 

type Chan_newRecver_Results capnp.Struct

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 

type Chan_newRecver_Results_Future struct{ *capnp.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 

type Chan_newSendCloser struct {
	*server.Call
}

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 

type Chan_newSendCloser_Params capnp.Struct

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 

type Chan_newSendCloser_Params_Future struct{ *capnp.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 

type Chan_newSendCloser_Results capnp.Struct

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 

type Chan_newSendCloser_Results_Future struct{ *capnp.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 

type Closer capnp.Client

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 

func (c Closer) AddRef() Closer

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

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

func (Closer) EncodeAsPtr 

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

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 

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

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

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

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 

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

func (c Closer) WaitStreaming() error

type Closer_List 

type Closer_List = capnp.CapList[Closer]

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 

type Closer_close struct {
	*server.Call
}

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 

type Closer_close_Params capnp.Struct

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 

type Closer_close_Params_Future struct{ *capnp.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 

type Closer_close_Results capnp.Struct

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 

type Closer_close_Results_Future struct{ *capnp.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 

type Recver capnp.Client

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 

func (c Recver) AddRef() Recver

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

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

func (Recver) EncodeAsPtr 

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

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 

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

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

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

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 

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

func (c Recver) WaitStreaming() error

type Recver_List 

type Recver_List = capnp.CapList[Recver]

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 

type Recver_recv struct {
	*server.Call
}

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 

type Recver_recv_Params capnp.Struct

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 

type Recver_recv_Params_Future struct{ *capnp.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 

type Recver_recv_Results capnp.Struct

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) SetValue 

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

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

func (Recver_recv_Results) Value 

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

type Recver_recv_Results_Future 

type Recver_recv_Results_Future struct{ *capnp.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 

type SendCloser capnp.Client

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 

type SendCloser_newCloser struct {
	*server.Call
}

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 

type SendCloser_newCloser_Params capnp.Struct

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 

type SendCloser_newCloser_Params_Future struct{ *capnp.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 

type SendCloser_newCloser_Results capnp.Struct

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 

type SendCloser_newCloser_Results_Future struct{ *capnp.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 

type SendCloser_newSender struct {
	*server.Call
}

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 

type SendCloser_newSender_Params capnp.Struct

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 

type SendCloser_newSender_Params_Future struct{ *capnp.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 

type SendCloser_newSender_Results capnp.Struct

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 

type SendCloser_newSender_Results_Future struct{ *capnp.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 

type Sender capnp.Client

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 

func (c Sender) AddRef() Sender

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

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

func (Sender) EncodeAsPtr 

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

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 

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

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

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

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 

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

func (c Sender) WaitStreaming() error

type Sender_List 

type Sender_List = capnp.CapList[Sender]

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 

type Sender_send struct {
	*server.Call
}

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 

type Sender_send_Params capnp.Struct

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) SetValue 

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

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

func (Sender_send_Params) Value 

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

type Sender_send_Params_Future 

type Sender_send_Params_Future struct{ *capnp.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 

type Sender_send_Results capnp.Struct

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 

type Sender_send_Results_Future struct{ *capnp.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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.