testcapnp

package
v3.0.0-alpha.10 Latest Latest
Warning

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

 Go to latest Published: Dec 5, 2022 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const CapArgsTest_TypeID = 0xb86bce7f916a10cc

CapArgsTest_TypeID is the unique identifier for the type CapArgsTest.

View Source 
const CapArgsTest_call_Params_TypeID = 0x80087e4e698768a2

CapArgsTest_call_Params_TypeID is the unique identifier for the type CapArgsTest_call_Params.

View Source 
const CapArgsTest_call_Results_TypeID = 0x96fbc50dc2f0200d

CapArgsTest_call_Results_TypeID is the unique identifier for the type CapArgsTest_call_Results.

View Source 
const CapArgsTest_self_Params_TypeID = 0xe2553e5a663abb7d

CapArgsTest_self_Params_TypeID is the unique identifier for the type CapArgsTest_self_Params.

View Source 
const CapArgsTest_self_Results_TypeID = 0x9746cc05cbff1132

CapArgsTest_self_Results_TypeID is the unique identifier for the type CapArgsTest_self_Results.

View Source 
const PingPong_TypeID = 0xf004c474c2f8ee7a

PingPong_TypeID is the unique identifier for the type PingPong.

View Source 
const PingPong_echoNum_Params_TypeID = 0xd797e0a99edf0921

PingPong_echoNum_Params_TypeID is the unique identifier for the type PingPong_echoNum_Params.

View Source 
const PingPong_echoNum_Results_TypeID = 0x85ddfd96db252600

PingPong_echoNum_Results_TypeID is the unique identifier for the type PingPong_echoNum_Results.

View Source 
const StreamTest_TypeID = 0xbb3ca85b01eea465

StreamTest_TypeID is the unique identifier for the type StreamTest.

View Source 
const StreamTest_push_Params_TypeID = 0xf838dca6c8721bdb

StreamTest_push_Params_TypeID is the unique identifier for the type StreamTest_push_Params.

Variables

This section is empty.

Functions

func CapArgsTest_Methods 

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

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

func CapArgsTest_NewServer 

func CapArgsTest_NewServer(s CapArgsTest_Server) *server.Server

CapArgsTest_NewServer creates a new Server from an implementation of CapArgsTest_Server.

func PingPong_Methods 

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

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

func PingPong_NewServer 

func PingPong_NewServer(s PingPong_Server) *server.Server

PingPong_NewServer creates a new Server from an implementation of PingPong_Server.

func StreamTest_Methods 

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

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

func StreamTest_NewServer 

func StreamTest_NewServer(s StreamTest_Server) *server.Server

StreamTest_NewServer creates a new Server from an implementation of StreamTest_Server.

Types

type CapArgsTest 

type CapArgsTest capnp.Client

func CapArgsTest_ServerToClient 

func CapArgsTest_ServerToClient(s CapArgsTest_Server) CapArgsTest

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

func (CapArgsTest) AddRef 

func (c CapArgsTest) AddRef() CapArgsTest

AddRef creates a new Client that refers to the same capability as c. If c is nil or has resolved to null, then AddRef returns nil.

func (CapArgsTest) Call 

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

func (CapArgsTest) DecodeFromPtr 

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

func (CapArgsTest) EncodeAsPtr 

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

func (CapArgsTest) GetFlowLimiter 

func (c CapArgsTest) GetFlowLimiter() fc.FlowLimiter

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

func (CapArgsTest) IsSame 

func (c CapArgsTest) IsSame(other CapArgsTest) bool

IsSame reports whether c and other refer to a capability created by the same call to NewClient. This can return false negatives if c or other are not fully resolved: use Resolve if this is an issue. If either c or other are released, then IsSame panics.

func (CapArgsTest) IsValid 

func (c CapArgsTest) IsValid() bool

IsValid reports whether c is a valid reference to a capability. A reference is invalid if it is nil, has resolved to null, or has been released.

func (CapArgsTest) Release 

func (c CapArgsTest) Release()

Release releases a capability reference. If this is the last reference to the capability, then the underlying resources associated with the capability will be released.

Release will panic if c has already been released, but not if c is nil or resolved to null.

func (CapArgsTest) Resolve 

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

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

func (CapArgsTest) Self 

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

func (CapArgsTest) SetFlowLimiter 

func (c CapArgsTest) SetFlowLimiter(lim fc.FlowLimiter)

Update the flowcontrol.FlowLimiter used to manage flow control for this client. This affects all future calls, but not calls already waiting to send. Passing nil sets the value to flowcontrol.NopLimiter, which is also the default.

func (CapArgsTest) String 

func (c CapArgsTest) String() string

String returns a string that identifies this capability for debugging purposes. Its format should not be depended on: in particular, it should not be used to compare clients. Use IsSame to compare clients for equality.

type CapArgsTest_List 

type CapArgsTest_List = capnp.CapList[CapArgsTest]

CapArgsTest_List is a list of CapArgsTest.

func NewCapArgsTest_List 

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

NewCapArgsTest creates a new list of CapArgsTest.

type CapArgsTest_Server 

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

	Self(context.Context, CapArgsTest_self) error
}

type CapArgsTest_call 

type CapArgsTest_call struct {
	*server.Call
}

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

func (CapArgsTest_call) AllocResults 

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

AllocResults allocates the results struct.

func (CapArgsTest_call) Args 

func (c CapArgsTest_call) Args() CapArgsTest_call_Params

Args returns the call's arguments.

type CapArgsTest_call_Params 

type CapArgsTest_call_Params capnp.Struct

func NewCapArgsTest_call_Params 

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

func NewRootCapArgsTest_call_Params 

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

func ReadRootCapArgsTest_call_Params 

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

func (CapArgsTest_call_Params) Cap 

func (s CapArgsTest_call_Params) Cap() capnp.Client

func (CapArgsTest_call_Params) DecodeFromPtr 

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

func (CapArgsTest_call_Params) EncodeAsPtr 

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

func (CapArgsTest_call_Params) HasCap 

func (s CapArgsTest_call_Params) HasCap() bool

func (CapArgsTest_call_Params) IsValid 

func (s CapArgsTest_call_Params) IsValid() bool

func (CapArgsTest_call_Params) Message 

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

func (CapArgsTest_call_Params) Segment 

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

func (CapArgsTest_call_Params) SetCap 

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

func (CapArgsTest_call_Params) String 

func (s CapArgsTest_call_Params) String() string

func (CapArgsTest_call_Params) ToPtr 

func (s CapArgsTest_call_Params) ToPtr() capnp.Ptr

type CapArgsTest_call_Params_Future 

type CapArgsTest_call_Params_Future struct{ *capnp.Future }

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

func (CapArgsTest_call_Params_Future) Cap 

func (p CapArgsTest_call_Params_Future) Cap() capnp.Client

func (CapArgsTest_call_Params_Future) Struct 

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

type CapArgsTest_call_Params_List 

type CapArgsTest_call_Params_List = capnp.StructList[CapArgsTest_call_Params]

CapArgsTest_call_Params_List is a list of CapArgsTest_call_Params.

func NewCapArgsTest_call_Params_List 

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

NewCapArgsTest_call_Params creates a new list of CapArgsTest_call_Params.

type CapArgsTest_call_Results 

type CapArgsTest_call_Results capnp.Struct

func NewCapArgsTest_call_Results 

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

func NewRootCapArgsTest_call_Results 

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

func ReadRootCapArgsTest_call_Results 

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

func (CapArgsTest_call_Results) DecodeFromPtr 

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

func (CapArgsTest_call_Results) EncodeAsPtr 

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

func (CapArgsTest_call_Results) IsValid 

func (s CapArgsTest_call_Results) IsValid() bool

func (CapArgsTest_call_Results) Message 

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

func (CapArgsTest_call_Results) Segment 

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

func (CapArgsTest_call_Results) String 

func (s CapArgsTest_call_Results) String() string

func (CapArgsTest_call_Results) ToPtr 

func (s CapArgsTest_call_Results) ToPtr() capnp.Ptr

type CapArgsTest_call_Results_Future 

type CapArgsTest_call_Results_Future struct{ *capnp.Future }

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

func (CapArgsTest_call_Results_Future) Struct 

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

type CapArgsTest_call_Results_List 

type CapArgsTest_call_Results_List = capnp.StructList[CapArgsTest_call_Results]

CapArgsTest_call_Results_List is a list of CapArgsTest_call_Results.

func NewCapArgsTest_call_Results_List 

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

NewCapArgsTest_call_Results creates a new list of CapArgsTest_call_Results.

type CapArgsTest_self 

type CapArgsTest_self struct {
	*server.Call
}

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

func (CapArgsTest_self) AllocResults 

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

AllocResults allocates the results struct.

func (CapArgsTest_self) Args 

func (c CapArgsTest_self) Args() CapArgsTest_self_Params

Args returns the call's arguments.

type CapArgsTest_self_Params 

type CapArgsTest_self_Params capnp.Struct

func NewCapArgsTest_self_Params 

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

func NewRootCapArgsTest_self_Params 

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

func ReadRootCapArgsTest_self_Params 

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

func (CapArgsTest_self_Params) DecodeFromPtr 

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

func (CapArgsTest_self_Params) EncodeAsPtr 

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

func (CapArgsTest_self_Params) IsValid 

func (s CapArgsTest_self_Params) IsValid() bool

func (CapArgsTest_self_Params) Message 

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

func (CapArgsTest_self_Params) Segment 

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

func (CapArgsTest_self_Params) String 

func (s CapArgsTest_self_Params) String() string

func (CapArgsTest_self_Params) ToPtr 

func (s CapArgsTest_self_Params) ToPtr() capnp.Ptr

type CapArgsTest_self_Params_Future 

type CapArgsTest_self_Params_Future struct{ *capnp.Future }

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

func (CapArgsTest_self_Params_Future) Struct 

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

type CapArgsTest_self_Params_List 

type CapArgsTest_self_Params_List = capnp.StructList[CapArgsTest_self_Params]

CapArgsTest_self_Params_List is a list of CapArgsTest_self_Params.

func NewCapArgsTest_self_Params_List 

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

NewCapArgsTest_self_Params creates a new list of CapArgsTest_self_Params.

type CapArgsTest_self_Results 

type CapArgsTest_self_Results capnp.Struct

func NewCapArgsTest_self_Results 

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

func NewRootCapArgsTest_self_Results 

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

func ReadRootCapArgsTest_self_Results 

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

func (CapArgsTest_self_Results) DecodeFromPtr 

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

func (CapArgsTest_self_Results) EncodeAsPtr 

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

func (CapArgsTest_self_Results) HasSelf 

func (s CapArgsTest_self_Results) HasSelf() bool

func (CapArgsTest_self_Results) IsValid 

func (s CapArgsTest_self_Results) IsValid() bool

func (CapArgsTest_self_Results) Message 

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

func (CapArgsTest_self_Results) Segment 

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

func (CapArgsTest_self_Results) Self 

func (s CapArgsTest_self_Results) Self() CapArgsTest

func (CapArgsTest_self_Results) SetSelf 

func (s CapArgsTest_self_Results) SetSelf(v CapArgsTest) error

func (CapArgsTest_self_Results) String 

func (s CapArgsTest_self_Results) String() string

func (CapArgsTest_self_Results) ToPtr 

func (s CapArgsTest_self_Results) ToPtr() capnp.Ptr

type CapArgsTest_self_Results_Future 

type CapArgsTest_self_Results_Future struct{ *capnp.Future }

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

func (CapArgsTest_self_Results_Future) Self 

func (p CapArgsTest_self_Results_Future) Self() CapArgsTest

func (CapArgsTest_self_Results_Future) Struct 

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

type CapArgsTest_self_Results_List 

type CapArgsTest_self_Results_List = capnp.StructList[CapArgsTest_self_Results]

CapArgsTest_self_Results_List is a list of CapArgsTest_self_Results.

func NewCapArgsTest_self_Results_List 

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

NewCapArgsTest_self_Results creates a new list of CapArgsTest_self_Results.

type PingPong 

type PingPong capnp.Client

func PingPong_ServerToClient 

func PingPong_ServerToClient(s PingPong_Server) PingPong

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

func (PingPong) AddRef 

func (c PingPong) AddRef() PingPong

AddRef creates a new Client that refers to the same capability as c. If c is nil or has resolved to null, then AddRef returns nil.

func (PingPong) DecodeFromPtr 

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

func (PingPong) EchoNum 

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

func (PingPong) EncodeAsPtr 

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

func (PingPong) GetFlowLimiter 

func (c PingPong) GetFlowLimiter() fc.FlowLimiter

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

func (PingPong) IsSame 

func (c PingPong) IsSame(other PingPong) bool

IsSame reports whether c and other refer to a capability created by the same call to NewClient. This can return false negatives if c or other are not fully resolved: use Resolve if this is an issue. If either c or other are released, then IsSame panics.

func (PingPong) IsValid 

func (c PingPong) IsValid() bool

IsValid reports whether c is a valid reference to a capability. A reference is invalid if it is nil, has resolved to null, or has been released.

func (PingPong) Release 

func (c PingPong) Release()

Release releases a capability reference. If this is the last reference to the capability, then the underlying resources associated with the capability will be released.

Release will panic if c has already been released, but not if c is nil or resolved to null.

func (PingPong) Resolve 

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

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

func (PingPong) SetFlowLimiter 

func (c PingPong) SetFlowLimiter(lim fc.FlowLimiter)

Update the flowcontrol.FlowLimiter used to manage flow control for this client. This affects all future calls, but not calls already waiting to send. Passing nil sets the value to flowcontrol.NopLimiter, which is also the default.

func (PingPong) String 

func (c PingPong) String() string

String returns a string that identifies this capability for debugging purposes. Its format should not be depended on: in particular, it should not be used to compare clients. Use IsSame to compare clients for equality.

type PingPong_List 

type PingPong_List = capnp.CapList[PingPong]

PingPong_List is a list of PingPong.

func NewPingPong_List 

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

NewPingPong creates a new list of PingPong.

type PingPong_Server 

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

type PingPong_echoNum 

type PingPong_echoNum struct {
	*server.Call
}

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

func (PingPong_echoNum) AllocResults 

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

AllocResults allocates the results struct.

func (PingPong_echoNum) Args 

func (c PingPong_echoNum) Args() PingPong_echoNum_Params

Args returns the call's arguments.

type PingPong_echoNum_Params 

type PingPong_echoNum_Params capnp.Struct

func NewPingPong_echoNum_Params 

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

func NewRootPingPong_echoNum_Params 

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

func ReadRootPingPong_echoNum_Params 

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

func (PingPong_echoNum_Params) DecodeFromPtr 

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

func (PingPong_echoNum_Params) EncodeAsPtr 

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

func (PingPong_echoNum_Params) IsValid 

func (s PingPong_echoNum_Params) IsValid() bool

func (PingPong_echoNum_Params) Message 

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

func (PingPong_echoNum_Params) N 

func (s PingPong_echoNum_Params) N() int64

func (PingPong_echoNum_Params) Segment 

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

func (PingPong_echoNum_Params) SetN 

func (s PingPong_echoNum_Params) SetN(v int64)

func (PingPong_echoNum_Params) String 

func (s PingPong_echoNum_Params) String() string

func (PingPong_echoNum_Params) ToPtr 

func (s PingPong_echoNum_Params) ToPtr() capnp.Ptr

type PingPong_echoNum_Params_Future 

type PingPong_echoNum_Params_Future struct{ *capnp.Future }

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

func (PingPong_echoNum_Params_Future) Struct 

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

type PingPong_echoNum_Params_List 

type PingPong_echoNum_Params_List = capnp.StructList[PingPong_echoNum_Params]

PingPong_echoNum_Params_List is a list of PingPong_echoNum_Params.

func NewPingPong_echoNum_Params_List 

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

NewPingPong_echoNum_Params creates a new list of PingPong_echoNum_Params.

type PingPong_echoNum_Results 

type PingPong_echoNum_Results capnp.Struct

func NewPingPong_echoNum_Results 

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

func NewRootPingPong_echoNum_Results 

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

func ReadRootPingPong_echoNum_Results 

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

func (PingPong_echoNum_Results) DecodeFromPtr 

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

func (PingPong_echoNum_Results) EncodeAsPtr 

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

func (PingPong_echoNum_Results) IsValid 

func (s PingPong_echoNum_Results) IsValid() bool

func (PingPong_echoNum_Results) Message 

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

func (PingPong_echoNum_Results) N 

func (s PingPong_echoNum_Results) N() int64

func (PingPong_echoNum_Results) Segment 

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

func (PingPong_echoNum_Results) SetN 

func (s PingPong_echoNum_Results) SetN(v int64)

func (PingPong_echoNum_Results) String 

func (s PingPong_echoNum_Results) String() string

func (PingPong_echoNum_Results) ToPtr 

func (s PingPong_echoNum_Results) ToPtr() capnp.Ptr

type PingPong_echoNum_Results_Future 

type PingPong_echoNum_Results_Future struct{ *capnp.Future }

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

func (PingPong_echoNum_Results_Future) Struct 

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

type PingPong_echoNum_Results_List 

type PingPong_echoNum_Results_List = capnp.StructList[PingPong_echoNum_Results]

PingPong_echoNum_Results_List is a list of PingPong_echoNum_Results.

func NewPingPong_echoNum_Results_List 

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

NewPingPong_echoNum_Results creates a new list of PingPong_echoNum_Results.

type StreamTest 

type StreamTest capnp.Client

func StreamTest_ServerToClient 

func StreamTest_ServerToClient(s StreamTest_Server) StreamTest

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

func (StreamTest) AddRef 

func (c StreamTest) AddRef() StreamTest

AddRef creates a new Client that refers to the same capability as c. If c is nil or has resolved to null, then AddRef returns nil.

func (StreamTest) DecodeFromPtr 

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

func (StreamTest) EncodeAsPtr 

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

func (StreamTest) GetFlowLimiter 

func (c StreamTest) GetFlowLimiter() fc.FlowLimiter

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

func (StreamTest) IsSame 

func (c StreamTest) IsSame(other StreamTest) bool

IsSame reports whether c and other refer to a capability created by the same call to NewClient. This can return false negatives if c or other are not fully resolved: use Resolve if this is an issue. If either c or other are released, then IsSame panics.

func (StreamTest) IsValid 

func (c StreamTest) IsValid() bool

IsValid reports whether c is a valid reference to a capability. A reference is invalid if it is nil, has resolved to null, or has been released.

func (StreamTest) Push 

func (c StreamTest) Push(ctx context.Context, params func(StreamTest_push_Params) error) (stream.StreamResult_Future, capnp.ReleaseFunc)

func (StreamTest) Release 

func (c StreamTest) Release()

Release releases a capability reference. If this is the last reference to the capability, then the underlying resources associated with the capability will be released.

Release will panic if c has already been released, but not if c is nil or resolved to null.

func (StreamTest) Resolve 

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

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

func (StreamTest) SetFlowLimiter 

func (c StreamTest) SetFlowLimiter(lim fc.FlowLimiter)

Update the flowcontrol.FlowLimiter used to manage flow control for this client. This affects all future calls, but not calls already waiting to send. Passing nil sets the value to flowcontrol.NopLimiter, which is also the default.

func (StreamTest) String 

func (c StreamTest) String() string

String returns a string that identifies this capability for debugging purposes. Its format should not be depended on: in particular, it should not be used to compare clients. Use IsSame to compare clients for equality.

type StreamTest_List 

type StreamTest_List = capnp.CapList[StreamTest]

StreamTest_List is a list of StreamTest.

func NewStreamTest_List 

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

NewStreamTest creates a new list of StreamTest.

type StreamTest_Server 

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

type StreamTest_push 

type StreamTest_push struct {
	*server.Call
}

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

func (StreamTest_push) AllocResults 

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

AllocResults allocates the results struct.

func (StreamTest_push) Args 

func (c StreamTest_push) Args() StreamTest_push_Params

Args returns the call's arguments.

type StreamTest_push_Params 

type StreamTest_push_Params capnp.Struct

func NewRootStreamTest_push_Params 

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

func NewStreamTest_push_Params 

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

func ReadRootStreamTest_push_Params 

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

func (StreamTest_push_Params) Data 

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

func (StreamTest_push_Params) DecodeFromPtr 

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

func (StreamTest_push_Params) EncodeAsPtr 

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

func (StreamTest_push_Params) HasData 

func (s StreamTest_push_Params) HasData() bool

func (StreamTest_push_Params) IsValid 

func (s StreamTest_push_Params) IsValid() bool

func (StreamTest_push_Params) Message 

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

func (StreamTest_push_Params) Segment 

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

func (StreamTest_push_Params) SetData 

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

func (StreamTest_push_Params) String 

func (s StreamTest_push_Params) String() string

func (StreamTest_push_Params) ToPtr 

func (s StreamTest_push_Params) ToPtr() capnp.Ptr

type StreamTest_push_Params_Future 

type StreamTest_push_Params_Future struct{ *capnp.Future }

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

func (StreamTest_push_Params_Future) Struct 

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

type StreamTest_push_Params_List 

type StreamTest_push_Params_List = capnp.StructList[StreamTest_push_Params]

StreamTest_push_Params_List is a list of StreamTest_push_Params.

func NewStreamTest_push_Params_List 

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

NewStreamTest_push_Params creates a new list of StreamTest_push_Params.

Source Files

View all Source files

Jump to

Keyboard shortcuts

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