channel

package
v0.0.1-beta.30 Latest Latest
Warning

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

 Go to latest Published: Jan 15, 2023 License: Apache-2.0, MIT Imports: 8 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 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 PeekRecver_TypeID = 0x9a4abff8ccb5093c

PeekRecver_TypeID is the unique identifier for the type PeekRecver.

View Source 
const PeekableChan_TypeID = 0xb527cbca9bbd8178

PeekableChan_TypeID is the unique identifier for the type PeekableChan.

View Source 
const Peeker_TypeID = 0xe95c7f9f41bf520a

Peeker_TypeID is the unique identifier for the type Peeker.

View Source 
const Peeker_peek_Params_TypeID = 0xaf261efa7a102288

Peeker_peek_Params_TypeID is the unique identifier for the type Peeker_peek_Params.

View Source 
const Peeker_peek_Results_TypeID = 0xb42eee8bed32bea0

Peeker_peek_Results_TypeID is the unique identifier for the type Peeker_peek_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 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.

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 PeekRecver_Methods 

func PeekRecver_Methods(methods []server.Method, s PeekRecver_Server) []server.Method

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

func PeekRecver_NewServer 

func PeekRecver_NewServer(s PeekRecver_Server) *server.Server

PeekRecver_NewServer creates a new Server from an implementation of PeekRecver_Server.

func PeekableChan_Methods 

func PeekableChan_Methods(methods []server.Method, s PeekableChan_Server) []server.Method

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

func PeekableChan_NewServer 

func PeekableChan_NewServer(s PeekableChan_Server) *server.Server

PeekableChan_NewServer creates a new Server from an implementation of PeekableChan_Server.

func Peeker_Methods 

func Peeker_Methods(methods []server.Method, s Peeker_Server) []server.Method

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

func Peeker_NewServer 

func Peeker_NewServer(s Peeker_Server) *server.Server

Peeker_NewServer creates a new Server from an implementation of Peeker_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 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) 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) (stream.StreamResult_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.

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 {
	Send(context.Context, Sender_send) error

	Close(context.Context, Closer_close) error

	Recv(context.Context, Recver_recv) error
}

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.

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
}

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 PeekRecver 

type PeekRecver capnp.Client

func PeekRecver_ServerToClient 

func PeekRecver_ServerToClient(s PeekRecver_Server) PeekRecver

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

func (PeekRecver) AddRef 

func (c PeekRecver) AddRef() PeekRecver

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

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

func (PeekRecver) EncodeAsPtr 

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

func (PeekRecver) GetFlowLimiter 

func (c PeekRecver) GetFlowLimiter() fc.FlowLimiter

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

func (PeekRecver) IsSame 

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

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

func (c PeekRecver) Peek(ctx context.Context, params func(Peeker_peek_Params) error) (Peeker_peek_Results_Future, capnp.ReleaseFunc)

func (PeekRecver) Recv 

func (c PeekRecver) Recv(ctx context.Context, params func(Recver_recv_Params) error) (Recver_recv_Results_Future, capnp.ReleaseFunc)

func (PeekRecver) Release 

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

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

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

func (PeekRecver) SetFlowLimiter 

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

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

type PeekRecver_List 

type PeekRecver_List = capnp.CapList[PeekRecver]

PeekRecver_List is a list of PeekRecver.

func NewPeekRecver_List 

func NewPeekRecver_List(s *capnp.Segment, sz int32) (PeekRecver_List, error)

NewPeekRecver creates a new list of PeekRecver.

type PeekRecver_Server 

type PeekRecver_Server interface {
	Peek(context.Context, Peeker_peek) error

	Recv(context.Context, Recver_recv) error
}

type PeekableChan 

type PeekableChan capnp.Client

func PeekableChan_ServerToClient 

func PeekableChan_ServerToClient(s PeekableChan_Server) PeekableChan

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

func (PeekableChan) AddRef 

func (c PeekableChan) AddRef() PeekableChan

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 (PeekableChan) Close 

func (c PeekableChan) Close(ctx context.Context, params func(Closer_close_Params) error) (Closer_close_Results_Future, capnp.ReleaseFunc)

func (PeekableChan) DecodeFromPtr 

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

func (PeekableChan) EncodeAsPtr 

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

func (PeekableChan) GetFlowLimiter 

func (c PeekableChan) GetFlowLimiter() fc.FlowLimiter

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

func (PeekableChan) IsSame 

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

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

func (c PeekableChan) Peek(ctx context.Context, params func(Peeker_peek_Params) error) (Peeker_peek_Results_Future, capnp.ReleaseFunc)

func (PeekableChan) Recv 

func (c PeekableChan) Recv(ctx context.Context, params func(Recver_recv_Params) error) (Recver_recv_Results_Future, capnp.ReleaseFunc)

func (PeekableChan) Release 

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

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

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

func (PeekableChan) Send 

func (c PeekableChan) Send(ctx context.Context, params func(Sender_send_Params) error) (stream.StreamResult_Future, capnp.ReleaseFunc)

func (PeekableChan) SetFlowLimiter 

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

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

type PeekableChan_List 

type PeekableChan_List = capnp.CapList[PeekableChan]

PeekableChan_List is a list of PeekableChan.

func NewPeekableChan_List 

func NewPeekableChan_List(s *capnp.Segment, sz int32) (PeekableChan_List, error)

NewPeekableChan creates a new list of PeekableChan.

type PeekableChan_Server 

type PeekableChan_Server interface {
	Send(context.Context, Sender_send) error

	Close(context.Context, Closer_close) error

	Peek(context.Context, Peeker_peek) error

	Recv(context.Context, Recver_recv) error
}

type Peeker 

type Peeker capnp.Client

func Peeker_ServerToClient 

func Peeker_ServerToClient(s Peeker_Server) Peeker

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

func (Peeker) AddRef 

func (c Peeker) AddRef() Peeker

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

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

func (Peeker) EncodeAsPtr 

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

func (Peeker) GetFlowLimiter 

func (c Peeker) GetFlowLimiter() fc.FlowLimiter

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

func (Peeker) IsSame 

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

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

func (c Peeker) Peek(ctx context.Context, params func(Peeker_peek_Params) error) (Peeker_peek_Results_Future, capnp.ReleaseFunc)

func (Peeker) Release 

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

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

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

func (Peeker) SetFlowLimiter 

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

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

type Peeker_List 

type Peeker_List = capnp.CapList[Peeker]

Peeker_List is a list of Peeker.

func NewPeeker_List 

func NewPeeker_List(s *capnp.Segment, sz int32) (Peeker_List, error)

NewPeeker creates a new list of Peeker.

type Peeker_Server 

type Peeker_Server interface {
	Peek(context.Context, Peeker_peek) error
}

type Peeker_peek 

type Peeker_peek struct {
	*server.Call
}

Peeker_peek holds the state for a server call to Peeker.peek. See server.Call for documentation.

func (Peeker_peek) AllocResults 

func (c Peeker_peek) AllocResults() (Peeker_peek_Results, error)

AllocResults allocates the results struct.

func (Peeker_peek) Args 

func (c Peeker_peek) Args() Peeker_peek_Params

Args returns the call's arguments.

type Peeker_peek_Params 

type Peeker_peek_Params capnp.Struct

func NewPeeker_peek_Params 

func NewPeeker_peek_Params(s *capnp.Segment) (Peeker_peek_Params, error)

func NewRootPeeker_peek_Params 

func NewRootPeeker_peek_Params(s *capnp.Segment) (Peeker_peek_Params, error)

func ReadRootPeeker_peek_Params 

func ReadRootPeeker_peek_Params(msg *capnp.Message) (Peeker_peek_Params, error)

func (Peeker_peek_Params) DecodeFromPtr 

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

func (Peeker_peek_Params) EncodeAsPtr 

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

func (Peeker_peek_Params) IsValid 

func (s Peeker_peek_Params) IsValid() bool

func (Peeker_peek_Params) Message 

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

func (Peeker_peek_Params) Segment 

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

func (Peeker_peek_Params) String 

func (s Peeker_peek_Params) String() string

func (Peeker_peek_Params) ToPtr 

func (s Peeker_peek_Params) ToPtr() capnp.Ptr

type Peeker_peek_Params_Future 

type Peeker_peek_Params_Future struct{ *capnp.Future }

Peeker_peek_Params_Future is a wrapper for a Peeker_peek_Params promised by a client call.

func (Peeker_peek_Params_Future) Struct 

func (f Peeker_peek_Params_Future) Struct() (Peeker_peek_Params, error)

type Peeker_peek_Params_List 

type Peeker_peek_Params_List = capnp.StructList[Peeker_peek_Params]

Peeker_peek_Params_List is a list of Peeker_peek_Params.

func NewPeeker_peek_Params_List 

func NewPeeker_peek_Params_List(s *capnp.Segment, sz int32) (Peeker_peek_Params_List, error)

NewPeeker_peek_Params creates a new list of Peeker_peek_Params.

type Peeker_peek_Results 

type Peeker_peek_Results capnp.Struct

func NewPeeker_peek_Results 

func NewPeeker_peek_Results(s *capnp.Segment) (Peeker_peek_Results, error)

func NewRootPeeker_peek_Results 

func NewRootPeeker_peek_Results(s *capnp.Segment) (Peeker_peek_Results, error)

func ReadRootPeeker_peek_Results 

func ReadRootPeeker_peek_Results(msg *capnp.Message) (Peeker_peek_Results, error)

func (Peeker_peek_Results) DecodeFromPtr 

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

func (Peeker_peek_Results) EncodeAsPtr 

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

func (Peeker_peek_Results) HasValue 

func (s Peeker_peek_Results) HasValue() bool

func (Peeker_peek_Results) IsValid 

func (s Peeker_peek_Results) IsValid() bool

func (Peeker_peek_Results) Message 

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

func (Peeker_peek_Results) Segment 

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

func (Peeker_peek_Results) SetValue 

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

func (Peeker_peek_Results) String 

func (s Peeker_peek_Results) String() string

func (Peeker_peek_Results) ToPtr 

func (s Peeker_peek_Results) ToPtr() capnp.Ptr

func (Peeker_peek_Results) Value 

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

type Peeker_peek_Results_Future 

type Peeker_peek_Results_Future struct{ *capnp.Future }

Peeker_peek_Results_Future is a wrapper for a Peeker_peek_Results promised by a client call.

func (Peeker_peek_Results_Future) Struct 

func (f Peeker_peek_Results_Future) Struct() (Peeker_peek_Results, error)

func (Peeker_peek_Results_Future) Value 

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

type Peeker_peek_Results_List 

type Peeker_peek_Results_List = capnp.StructList[Peeker_peek_Results]

Peeker_peek_Results_List is a list of Peeker_peek_Results.

func NewPeeker_peek_Results_List 

func NewPeeker_peek_Results_List(s *capnp.Segment, sz int32) (Peeker_peek_Results_List, error)

NewPeeker_peek_Results creates a new list of Peeker_peek_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.

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
}

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) 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) (stream.StreamResult_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.

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 {
	Send(context.Context, Sender_send) error

	Close(context.Context, Closer_close) error
}

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) (stream.StreamResult_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.

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
}

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() (stream.StreamResult, 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.

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.