bs

package
v0.0.0-...-cbdd025 Latest Latest
Warning

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

 Go to latest Published: Nov 2, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const ByteStream_SubstreamCallback_TypeID = 0xb23c0a13cf65c36e

ByteStream_SubstreamCallback_TypeID is the unique identifier for the type ByteStream_SubstreamCallback.

View Source 
const ByteStream_SubstreamCallback_ended_Params_TypeID = 0xccb18eca8acafbe7

ByteStream_SubstreamCallback_ended_Params_TypeID is the unique identifier for the type ByteStream_SubstreamCallback_ended_Params.

View Source 
const ByteStream_SubstreamCallback_ended_Results_TypeID = 0xba8feb56b5b6922d

ByteStream_SubstreamCallback_ended_Results_TypeID is the unique identifier for the type ByteStream_SubstreamCallback_ended_Results.

View Source 
const ByteStream_SubstreamCallback_reachedLimit_Params_TypeID = 0xd80bf35671585f44

ByteStream_SubstreamCallback_reachedLimit_Params_TypeID is the unique identifier for the type ByteStream_SubstreamCallback_reachedLimit_Params.

View Source 
const ByteStream_SubstreamCallback_reachedLimit_Results_TypeID = 0xddd06638ed144353

ByteStream_SubstreamCallback_reachedLimit_Results_TypeID is the unique identifier for the type ByteStream_SubstreamCallback_reachedLimit_Results.

View Source 
const ByteStream_TypeID = 0xd2e7d8a0dc0a9766

ByteStream_TypeID is the unique identifier for the type ByteStream.

View Source 
const ByteStream_end_Params_TypeID = 0xcbd32047945c0144

ByteStream_end_Params_TypeID is the unique identifier for the type ByteStream_end_Params.

View Source 
const ByteStream_end_Results_TypeID = 0xe7e2ddbc3c63d594

ByteStream_end_Results_TypeID is the unique identifier for the type ByteStream_end_Results.

View Source 
const ByteStream_getSubstream_Params_TypeID = 0xc5b18e80fc80d9f8

ByteStream_getSubstream_Params_TypeID is the unique identifier for the type ByteStream_getSubstream_Params.

View Source 
const ByteStream_getSubstream_Results_TypeID = 0x8d198ede6d27756a

ByteStream_getSubstream_Results_TypeID is the unique identifier for the type ByteStream_getSubstream_Results.

View Source 
const ByteStream_startTls_Params_TypeID = 0xea8253a695da1ab8

ByteStream_startTls_Params_TypeID is the unique identifier for the type ByteStream_startTls_Params.

View Source 
const ByteStream_write_Params_TypeID = 0xa45d8c4c07bb36d2

ByteStream_write_Params_TypeID is the unique identifier for the type ByteStream_write_Params.

Variables

This section is empty.

Functions

func ByteStream_Methods 

func ByteStream_Methods(methods []server.Method, s ByteStream_Server) []server.Method

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

func ByteStream_NewServer 

func ByteStream_NewServer(s ByteStream_Server) *server.Server

ByteStream_NewServer creates a new Server from an implementation of ByteStream_Server.

func ByteStream_SubstreamCallback_Methods 

func ByteStream_SubstreamCallback_Methods(methods []server.Method, s ByteStream_SubstreamCallback_Server) []server.Method

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

func ByteStream_SubstreamCallback_NewServer 

func ByteStream_SubstreamCallback_NewServer(s ByteStream_SubstreamCallback_Server) *server.Server

ByteStream_SubstreamCallback_NewServer creates a new Server from an implementation of ByteStream_SubstreamCallback_Server.

func RegisterSchema 

func RegisterSchema(reg *schemas.Registry)

Types

type ByteStream 

type ByteStream capnp.Client

func ByteStream_ServerToClient 

func ByteStream_ServerToClient(s ByteStream_Server) ByteStream

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

func (ByteStream) AddRef 

func (c ByteStream) AddRef() ByteStream

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

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

func (ByteStream) EncodeAsPtr 

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

func (ByteStream) End 

func (c ByteStream) End(ctx context.Context, params func(ByteStream_end_Params) error) (ByteStream_end_Results_Future, capnp.ReleaseFunc)

func (ByteStream) GetFlowLimiter 

func (c ByteStream) GetFlowLimiter() fc.FlowLimiter

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

func (ByteStream) GetSubstream 

func (c ByteStream) GetSubstream(ctx context.Context, params func(ByteStream_getSubstream_Params) error) (ByteStream_getSubstream_Results_Future, capnp.ReleaseFunc)

func (ByteStream) IsSame 

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

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

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

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

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

func (ByteStream) SetFlowLimiter 

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

func (c ByteStream) StartTls(ctx context.Context, params func(ByteStream_startTls_Params) error) error

func (ByteStream) String 

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

func (c ByteStream) WaitStreaming() error

func (ByteStream) Write 

func (c ByteStream) Write(ctx context.Context, params func(ByteStream_write_Params) error) error

type ByteStream_List 

type ByteStream_List = capnp.CapList[ByteStream]

ByteStream_List is a list of ByteStream.

func NewByteStream_List 

func NewByteStream_List(s *capnp.Segment, sz int32) (ByteStream_List, error)

NewByteStream creates a new list of ByteStream.

type ByteStream_Server 

type ByteStream_Server interface {
	Write(context.Context, ByteStream_write) error

	End(context.Context, ByteStream_end) error

	GetSubstream(context.Context, ByteStream_getSubstream) error

	StartTls(context.Context, ByteStream_startTls) error
}

A ByteStream_Server is a ByteStream with a local implementation.

type ByteStream_SubstreamCallback 

type ByteStream_SubstreamCallback capnp.Client

func ByteStream_SubstreamCallback_ServerToClient 

func ByteStream_SubstreamCallback_ServerToClient(s ByteStream_SubstreamCallback_Server) ByteStream_SubstreamCallback

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

func (ByteStream_SubstreamCallback) AddRef 

func (c ByteStream_SubstreamCallback) AddRef() ByteStream_SubstreamCallback

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

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

func (ByteStream_SubstreamCallback) EncodeAsPtr 

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

func (ByteStream_SubstreamCallback) Ended 

func (c ByteStream_SubstreamCallback) Ended(ctx context.Context, params func(ByteStream_SubstreamCallback_ended_Params) error) (ByteStream_SubstreamCallback_ended_Results_Future, capnp.ReleaseFunc)

func (ByteStream_SubstreamCallback) GetFlowLimiter 

func (c ByteStream_SubstreamCallback) GetFlowLimiter() fc.FlowLimiter

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

func (ByteStream_SubstreamCallback) IsSame 

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

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

func (c ByteStream_SubstreamCallback) ReachedLimit(ctx context.Context, params func(ByteStream_SubstreamCallback_reachedLimit_Params) error) (ByteStream_SubstreamCallback_reachedLimit_Results_Future, capnp.ReleaseFunc)

func (ByteStream_SubstreamCallback) Release 

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

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

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

func (ByteStream_SubstreamCallback) SetFlowLimiter 

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

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

func (c ByteStream_SubstreamCallback) WaitStreaming() error

type ByteStream_SubstreamCallback_List 

type ByteStream_SubstreamCallback_List = capnp.CapList[ByteStream_SubstreamCallback]

ByteStream_SubstreamCallback_List is a list of ByteStream_SubstreamCallback.

func NewByteStream_SubstreamCallback_List 

func NewByteStream_SubstreamCallback_List(s *capnp.Segment, sz int32) (ByteStream_SubstreamCallback_List, error)

NewByteStream_SubstreamCallback creates a new list of ByteStream_SubstreamCallback.

type ByteStream_SubstreamCallback_Server 

type ByteStream_SubstreamCallback_Server interface {
	Ended(context.Context, ByteStream_SubstreamCallback_ended) error

	ReachedLimit(context.Context, ByteStream_SubstreamCallback_reachedLimit) error
}

A ByteStream_SubstreamCallback_Server is a ByteStream_SubstreamCallback with a local implementation.

type ByteStream_SubstreamCallback_ended 

type ByteStream_SubstreamCallback_ended struct {
	*server.Call
}

ByteStream_SubstreamCallback_ended holds the state for a server call to ByteStream_SubstreamCallback.ended. See server.Call for documentation.

func (ByteStream_SubstreamCallback_ended) AllocResults 

func (c ByteStream_SubstreamCallback_ended) AllocResults() (ByteStream_SubstreamCallback_ended_Results, error)

AllocResults allocates the results struct.

func (ByteStream_SubstreamCallback_ended) Args 

func (c ByteStream_SubstreamCallback_ended) Args() ByteStream_SubstreamCallback_ended_Params

Args returns the call's arguments.

type ByteStream_SubstreamCallback_ended_Params 

type ByteStream_SubstreamCallback_ended_Params capnp.Struct

func NewByteStream_SubstreamCallback_ended_Params 

func NewByteStream_SubstreamCallback_ended_Params(s *capnp.Segment) (ByteStream_SubstreamCallback_ended_Params, error)

func NewRootByteStream_SubstreamCallback_ended_Params 

func NewRootByteStream_SubstreamCallback_ended_Params(s *capnp.Segment) (ByteStream_SubstreamCallback_ended_Params, error)

func ReadRootByteStream_SubstreamCallback_ended_Params 

func ReadRootByteStream_SubstreamCallback_ended_Params(msg *capnp.Message) (ByteStream_SubstreamCallback_ended_Params, error)

func (ByteStream_SubstreamCallback_ended_Params) ByteCount 

func (s ByteStream_SubstreamCallback_ended_Params) ByteCount() uint64

func (ByteStream_SubstreamCallback_ended_Params) DecodeFromPtr 

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

func (ByteStream_SubstreamCallback_ended_Params) EncodeAsPtr 

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

func (ByteStream_SubstreamCallback_ended_Params) IsValid 

func (s ByteStream_SubstreamCallback_ended_Params) IsValid() bool

func (ByteStream_SubstreamCallback_ended_Params) Message 

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

func (ByteStream_SubstreamCallback_ended_Params) Segment 

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

func (ByteStream_SubstreamCallback_ended_Params) SetByteCount 

func (s ByteStream_SubstreamCallback_ended_Params) SetByteCount(v uint64)

func (ByteStream_SubstreamCallback_ended_Params) String 

func (s ByteStream_SubstreamCallback_ended_Params) String() string

func (ByteStream_SubstreamCallback_ended_Params) ToPtr 

func (s ByteStream_SubstreamCallback_ended_Params) ToPtr() capnp.Ptr

type ByteStream_SubstreamCallback_ended_Params_Future 

type ByteStream_SubstreamCallback_ended_Params_Future struct{ *capnp.Future }

ByteStream_SubstreamCallback_ended_Params_Future is a wrapper for a ByteStream_SubstreamCallback_ended_Params promised by a client call.

func (ByteStream_SubstreamCallback_ended_Params_Future) Struct 

func (f ByteStream_SubstreamCallback_ended_Params_Future) Struct() (ByteStream_SubstreamCallback_ended_Params, error)

type ByteStream_SubstreamCallback_ended_Params_List 

type ByteStream_SubstreamCallback_ended_Params_List = capnp.StructList[ByteStream_SubstreamCallback_ended_Params]

ByteStream_SubstreamCallback_ended_Params_List is a list of ByteStream_SubstreamCallback_ended_Params.

func NewByteStream_SubstreamCallback_ended_Params_List 

func NewByteStream_SubstreamCallback_ended_Params_List(s *capnp.Segment, sz int32) (ByteStream_SubstreamCallback_ended_Params_List, error)

NewByteStream_SubstreamCallback_ended_Params creates a new list of ByteStream_SubstreamCallback_ended_Params.

type ByteStream_SubstreamCallback_ended_Results 

type ByteStream_SubstreamCallback_ended_Results capnp.Struct

func NewByteStream_SubstreamCallback_ended_Results 

func NewByteStream_SubstreamCallback_ended_Results(s *capnp.Segment) (ByteStream_SubstreamCallback_ended_Results, error)

func NewRootByteStream_SubstreamCallback_ended_Results 

func NewRootByteStream_SubstreamCallback_ended_Results(s *capnp.Segment) (ByteStream_SubstreamCallback_ended_Results, error)

func ReadRootByteStream_SubstreamCallback_ended_Results 

func ReadRootByteStream_SubstreamCallback_ended_Results(msg *capnp.Message) (ByteStream_SubstreamCallback_ended_Results, error)

func (ByteStream_SubstreamCallback_ended_Results) DecodeFromPtr 

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

func (ByteStream_SubstreamCallback_ended_Results) EncodeAsPtr 

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

func (ByteStream_SubstreamCallback_ended_Results) IsValid 

func (s ByteStream_SubstreamCallback_ended_Results) IsValid() bool

func (ByteStream_SubstreamCallback_ended_Results) Message 

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

func (ByteStream_SubstreamCallback_ended_Results) Segment 

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

func (ByteStream_SubstreamCallback_ended_Results) String 

func (s ByteStream_SubstreamCallback_ended_Results) String() string

func (ByteStream_SubstreamCallback_ended_Results) ToPtr 

func (s ByteStream_SubstreamCallback_ended_Results) ToPtr() capnp.Ptr

type ByteStream_SubstreamCallback_ended_Results_Future 

type ByteStream_SubstreamCallback_ended_Results_Future struct{ *capnp.Future }

ByteStream_SubstreamCallback_ended_Results_Future is a wrapper for a ByteStream_SubstreamCallback_ended_Results promised by a client call.

func (ByteStream_SubstreamCallback_ended_Results_Future) Struct 

func (f ByteStream_SubstreamCallback_ended_Results_Future) Struct() (ByteStream_SubstreamCallback_ended_Results, error)

type ByteStream_SubstreamCallback_ended_Results_List 

type ByteStream_SubstreamCallback_ended_Results_List = capnp.StructList[ByteStream_SubstreamCallback_ended_Results]

ByteStream_SubstreamCallback_ended_Results_List is a list of ByteStream_SubstreamCallback_ended_Results.

func NewByteStream_SubstreamCallback_ended_Results_List 

func NewByteStream_SubstreamCallback_ended_Results_List(s *capnp.Segment, sz int32) (ByteStream_SubstreamCallback_ended_Results_List, error)

NewByteStream_SubstreamCallback_ended_Results creates a new list of ByteStream_SubstreamCallback_ended_Results.

type ByteStream_SubstreamCallback_reachedLimit 

type ByteStream_SubstreamCallback_reachedLimit struct {
	*server.Call
}

ByteStream_SubstreamCallback_reachedLimit holds the state for a server call to ByteStream_SubstreamCallback.reachedLimit. See server.Call for documentation.

func (ByteStream_SubstreamCallback_reachedLimit) AllocResults 

func (c ByteStream_SubstreamCallback_reachedLimit) AllocResults() (ByteStream_SubstreamCallback_reachedLimit_Results, error)

AllocResults allocates the results struct.

func (ByteStream_SubstreamCallback_reachedLimit) Args 

func (c ByteStream_SubstreamCallback_reachedLimit) Args() ByteStream_SubstreamCallback_reachedLimit_Params

Args returns the call's arguments.

type ByteStream_SubstreamCallback_reachedLimit_Params 

type ByteStream_SubstreamCallback_reachedLimit_Params capnp.Struct

func NewByteStream_SubstreamCallback_reachedLimit_Params 

func NewByteStream_SubstreamCallback_reachedLimit_Params(s *capnp.Segment) (ByteStream_SubstreamCallback_reachedLimit_Params, error)

func NewRootByteStream_SubstreamCallback_reachedLimit_Params 

func NewRootByteStream_SubstreamCallback_reachedLimit_Params(s *capnp.Segment) (ByteStream_SubstreamCallback_reachedLimit_Params, error)

func ReadRootByteStream_SubstreamCallback_reachedLimit_Params 

func ReadRootByteStream_SubstreamCallback_reachedLimit_Params(msg *capnp.Message) (ByteStream_SubstreamCallback_reachedLimit_Params, error)

func (ByteStream_SubstreamCallback_reachedLimit_Params) DecodeFromPtr 

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

func (ByteStream_SubstreamCallback_reachedLimit_Params) EncodeAsPtr 

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

func (ByteStream_SubstreamCallback_reachedLimit_Params) IsValid 

func (s ByteStream_SubstreamCallback_reachedLimit_Params) IsValid() bool

func (ByteStream_SubstreamCallback_reachedLimit_Params) Message 

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

func (ByteStream_SubstreamCallback_reachedLimit_Params) Segment 

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

func (ByteStream_SubstreamCallback_reachedLimit_Params) String 

func (s ByteStream_SubstreamCallback_reachedLimit_Params) String() string

func (ByteStream_SubstreamCallback_reachedLimit_Params) ToPtr 

func (s ByteStream_SubstreamCallback_reachedLimit_Params) ToPtr() capnp.Ptr

type ByteStream_SubstreamCallback_reachedLimit_Params_Future 

type ByteStream_SubstreamCallback_reachedLimit_Params_Future struct{ *capnp.Future }

ByteStream_SubstreamCallback_reachedLimit_Params_Future is a wrapper for a ByteStream_SubstreamCallback_reachedLimit_Params promised by a client call.

func (ByteStream_SubstreamCallback_reachedLimit_Params_Future) Struct 

func (f ByteStream_SubstreamCallback_reachedLimit_Params_Future) Struct() (ByteStream_SubstreamCallback_reachedLimit_Params, error)

type ByteStream_SubstreamCallback_reachedLimit_Params_List 

type ByteStream_SubstreamCallback_reachedLimit_Params_List = capnp.StructList[ByteStream_SubstreamCallback_reachedLimit_Params]

ByteStream_SubstreamCallback_reachedLimit_Params_List is a list of ByteStream_SubstreamCallback_reachedLimit_Params.

func NewByteStream_SubstreamCallback_reachedLimit_Params_List 

func NewByteStream_SubstreamCallback_reachedLimit_Params_List(s *capnp.Segment, sz int32) (ByteStream_SubstreamCallback_reachedLimit_Params_List, error)

NewByteStream_SubstreamCallback_reachedLimit_Params creates a new list of ByteStream_SubstreamCallback_reachedLimit_Params.

type ByteStream_SubstreamCallback_reachedLimit_Results 

type ByteStream_SubstreamCallback_reachedLimit_Results capnp.Struct

func NewByteStream_SubstreamCallback_reachedLimit_Results 

func NewByteStream_SubstreamCallback_reachedLimit_Results(s *capnp.Segment) (ByteStream_SubstreamCallback_reachedLimit_Results, error)

func NewRootByteStream_SubstreamCallback_reachedLimit_Results 

func NewRootByteStream_SubstreamCallback_reachedLimit_Results(s *capnp.Segment) (ByteStream_SubstreamCallback_reachedLimit_Results, error)

func ReadRootByteStream_SubstreamCallback_reachedLimit_Results 

func ReadRootByteStream_SubstreamCallback_reachedLimit_Results(msg *capnp.Message) (ByteStream_SubstreamCallback_reachedLimit_Results, error)

func (ByteStream_SubstreamCallback_reachedLimit_Results) DecodeFromPtr 

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

func (ByteStream_SubstreamCallback_reachedLimit_Results) EncodeAsPtr 

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

func (ByteStream_SubstreamCallback_reachedLimit_Results) HasNext 

func (s ByteStream_SubstreamCallback_reachedLimit_Results) HasNext() bool

func (ByteStream_SubstreamCallback_reachedLimit_Results) IsValid 

func (s ByteStream_SubstreamCallback_reachedLimit_Results) IsValid() bool

func (ByteStream_SubstreamCallback_reachedLimit_Results) Message 

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

func (ByteStream_SubstreamCallback_reachedLimit_Results) Next 

func (s ByteStream_SubstreamCallback_reachedLimit_Results) Next() ByteStream

func (ByteStream_SubstreamCallback_reachedLimit_Results) Segment 

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

func (ByteStream_SubstreamCallback_reachedLimit_Results) SetNext 

func (s ByteStream_SubstreamCallback_reachedLimit_Results) SetNext(v ByteStream) error

func (ByteStream_SubstreamCallback_reachedLimit_Results) String 

func (s ByteStream_SubstreamCallback_reachedLimit_Results) String() string

func (ByteStream_SubstreamCallback_reachedLimit_Results) ToPtr 

func (s ByteStream_SubstreamCallback_reachedLimit_Results) ToPtr() capnp.Ptr

type ByteStream_SubstreamCallback_reachedLimit_Results_Future 

type ByteStream_SubstreamCallback_reachedLimit_Results_Future struct{ *capnp.Future }

ByteStream_SubstreamCallback_reachedLimit_Results_Future is a wrapper for a ByteStream_SubstreamCallback_reachedLimit_Results promised by a client call.

func (ByteStream_SubstreamCallback_reachedLimit_Results_Future) Next 

func (p ByteStream_SubstreamCallback_reachedLimit_Results_Future) Next() ByteStream

func (ByteStream_SubstreamCallback_reachedLimit_Results_Future) Struct 

func (f ByteStream_SubstreamCallback_reachedLimit_Results_Future) Struct() (ByteStream_SubstreamCallback_reachedLimit_Results, error)

type ByteStream_SubstreamCallback_reachedLimit_Results_List 

type ByteStream_SubstreamCallback_reachedLimit_Results_List = capnp.StructList[ByteStream_SubstreamCallback_reachedLimit_Results]

ByteStream_SubstreamCallback_reachedLimit_Results_List is a list of ByteStream_SubstreamCallback_reachedLimit_Results.

func NewByteStream_SubstreamCallback_reachedLimit_Results_List 

func NewByteStream_SubstreamCallback_reachedLimit_Results_List(s *capnp.Segment, sz int32) (ByteStream_SubstreamCallback_reachedLimit_Results_List, error)

NewByteStream_SubstreamCallback_reachedLimit_Results creates a new list of ByteStream_SubstreamCallback_reachedLimit_Results.

type ByteStream_end 

type ByteStream_end struct {
	*server.Call
}

ByteStream_end holds the state for a server call to ByteStream.end. See server.Call for documentation.

func (ByteStream_end) AllocResults 

func (c ByteStream_end) AllocResults() (ByteStream_end_Results, error)

AllocResults allocates the results struct.

func (ByteStream_end) Args 

func (c ByteStream_end) Args() ByteStream_end_Params

Args returns the call's arguments.

type ByteStream_end_Params 

type ByteStream_end_Params capnp.Struct

func NewByteStream_end_Params 

func NewByteStream_end_Params(s *capnp.Segment) (ByteStream_end_Params, error)

func NewRootByteStream_end_Params 

func NewRootByteStream_end_Params(s *capnp.Segment) (ByteStream_end_Params, error)

func ReadRootByteStream_end_Params 

func ReadRootByteStream_end_Params(msg *capnp.Message) (ByteStream_end_Params, error)

func (ByteStream_end_Params) DecodeFromPtr 

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

func (ByteStream_end_Params) EncodeAsPtr 

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

func (ByteStream_end_Params) IsValid 

func (s ByteStream_end_Params) IsValid() bool

func (ByteStream_end_Params) Message 

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

func (ByteStream_end_Params) Segment 

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

func (ByteStream_end_Params) String 

func (s ByteStream_end_Params) String() string

func (ByteStream_end_Params) ToPtr 

func (s ByteStream_end_Params) ToPtr() capnp.Ptr

type ByteStream_end_Params_Future 

type ByteStream_end_Params_Future struct{ *capnp.Future }

ByteStream_end_Params_Future is a wrapper for a ByteStream_end_Params promised by a client call.

func (ByteStream_end_Params_Future) Struct 

func (f ByteStream_end_Params_Future) Struct() (ByteStream_end_Params, error)

type ByteStream_end_Params_List 

type ByteStream_end_Params_List = capnp.StructList[ByteStream_end_Params]

ByteStream_end_Params_List is a list of ByteStream_end_Params.

func NewByteStream_end_Params_List 

func NewByteStream_end_Params_List(s *capnp.Segment, sz int32) (ByteStream_end_Params_List, error)

NewByteStream_end_Params creates a new list of ByteStream_end_Params.

type ByteStream_end_Results 

type ByteStream_end_Results capnp.Struct

func NewByteStream_end_Results 

func NewByteStream_end_Results(s *capnp.Segment) (ByteStream_end_Results, error)

func NewRootByteStream_end_Results 

func NewRootByteStream_end_Results(s *capnp.Segment) (ByteStream_end_Results, error)

func ReadRootByteStream_end_Results 

func ReadRootByteStream_end_Results(msg *capnp.Message) (ByteStream_end_Results, error)

func (ByteStream_end_Results) DecodeFromPtr 

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

func (ByteStream_end_Results) EncodeAsPtr 

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

func (ByteStream_end_Results) IsValid 

func (s ByteStream_end_Results) IsValid() bool

func (ByteStream_end_Results) Message 

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

func (ByteStream_end_Results) Segment 

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

func (ByteStream_end_Results) String 

func (s ByteStream_end_Results) String() string

func (ByteStream_end_Results) ToPtr 

func (s ByteStream_end_Results) ToPtr() capnp.Ptr

type ByteStream_end_Results_Future 

type ByteStream_end_Results_Future struct{ *capnp.Future }

ByteStream_end_Results_Future is a wrapper for a ByteStream_end_Results promised by a client call.

func (ByteStream_end_Results_Future) Struct 

func (f ByteStream_end_Results_Future) Struct() (ByteStream_end_Results, error)

type ByteStream_end_Results_List 

type ByteStream_end_Results_List = capnp.StructList[ByteStream_end_Results]

ByteStream_end_Results_List is a list of ByteStream_end_Results.

func NewByteStream_end_Results_List 

func NewByteStream_end_Results_List(s *capnp.Segment, sz int32) (ByteStream_end_Results_List, error)

NewByteStream_end_Results creates a new list of ByteStream_end_Results.

type ByteStream_getSubstream 

type ByteStream_getSubstream struct {
	*server.Call
}

ByteStream_getSubstream holds the state for a server call to ByteStream.getSubstream. See server.Call for documentation.

func (ByteStream_getSubstream) AllocResults 

func (c ByteStream_getSubstream) AllocResults() (ByteStream_getSubstream_Results, error)

AllocResults allocates the results struct.

func (ByteStream_getSubstream) Args 

func (c ByteStream_getSubstream) Args() ByteStream_getSubstream_Params

Args returns the call's arguments.

type ByteStream_getSubstream_Params 

type ByteStream_getSubstream_Params capnp.Struct

func NewByteStream_getSubstream_Params 

func NewByteStream_getSubstream_Params(s *capnp.Segment) (ByteStream_getSubstream_Params, error)

func NewRootByteStream_getSubstream_Params 

func NewRootByteStream_getSubstream_Params(s *capnp.Segment) (ByteStream_getSubstream_Params, error)

func ReadRootByteStream_getSubstream_Params 

func ReadRootByteStream_getSubstream_Params(msg *capnp.Message) (ByteStream_getSubstream_Params, error)

func (ByteStream_getSubstream_Params) Callback 

func (s ByteStream_getSubstream_Params) Callback() ByteStream_SubstreamCallback

func (ByteStream_getSubstream_Params) DecodeFromPtr 

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

func (ByteStream_getSubstream_Params) EncodeAsPtr 

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

func (ByteStream_getSubstream_Params) HasCallback 

func (s ByteStream_getSubstream_Params) HasCallback() bool

func (ByteStream_getSubstream_Params) IsValid 

func (s ByteStream_getSubstream_Params) IsValid() bool

func (ByteStream_getSubstream_Params) Limit 

func (s ByteStream_getSubstream_Params) Limit() uint64

func (ByteStream_getSubstream_Params) Message 

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

func (ByteStream_getSubstream_Params) Segment 

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

func (ByteStream_getSubstream_Params) SetCallback 

func (s ByteStream_getSubstream_Params) SetCallback(v ByteStream_SubstreamCallback) error

func (ByteStream_getSubstream_Params) SetLimit 

func (s ByteStream_getSubstream_Params) SetLimit(v uint64)

func (ByteStream_getSubstream_Params) String 

func (s ByteStream_getSubstream_Params) String() string

func (ByteStream_getSubstream_Params) ToPtr 

func (s ByteStream_getSubstream_Params) ToPtr() capnp.Ptr

type ByteStream_getSubstream_Params_Future 

type ByteStream_getSubstream_Params_Future struct{ *capnp.Future }

ByteStream_getSubstream_Params_Future is a wrapper for a ByteStream_getSubstream_Params promised by a client call.

func (ByteStream_getSubstream_Params_Future) Callback 

func (p ByteStream_getSubstream_Params_Future) Callback() ByteStream_SubstreamCallback

func (ByteStream_getSubstream_Params_Future) Struct 

func (f ByteStream_getSubstream_Params_Future) Struct() (ByteStream_getSubstream_Params, error)

type ByteStream_getSubstream_Params_List 

type ByteStream_getSubstream_Params_List = capnp.StructList[ByteStream_getSubstream_Params]

ByteStream_getSubstream_Params_List is a list of ByteStream_getSubstream_Params.

func NewByteStream_getSubstream_Params_List 

func NewByteStream_getSubstream_Params_List(s *capnp.Segment, sz int32) (ByteStream_getSubstream_Params_List, error)

NewByteStream_getSubstream_Params creates a new list of ByteStream_getSubstream_Params.

type ByteStream_getSubstream_Results 

type ByteStream_getSubstream_Results capnp.Struct

func NewByteStream_getSubstream_Results 

func NewByteStream_getSubstream_Results(s *capnp.Segment) (ByteStream_getSubstream_Results, error)

func NewRootByteStream_getSubstream_Results 

func NewRootByteStream_getSubstream_Results(s *capnp.Segment) (ByteStream_getSubstream_Results, error)

func ReadRootByteStream_getSubstream_Results 

func ReadRootByteStream_getSubstream_Results(msg *capnp.Message) (ByteStream_getSubstream_Results, error)

func (ByteStream_getSubstream_Results) DecodeFromPtr 

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

func (ByteStream_getSubstream_Results) EncodeAsPtr 

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

func (ByteStream_getSubstream_Results) HasSubstream 

func (s ByteStream_getSubstream_Results) HasSubstream() bool

func (ByteStream_getSubstream_Results) IsValid 

func (s ByteStream_getSubstream_Results) IsValid() bool

func (ByteStream_getSubstream_Results) Message 

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

func (ByteStream_getSubstream_Results) Segment 

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

func (ByteStream_getSubstream_Results) SetSubstream 

func (s ByteStream_getSubstream_Results) SetSubstream(v ByteStream) error

func (ByteStream_getSubstream_Results) String 

func (s ByteStream_getSubstream_Results) String() string

func (ByteStream_getSubstream_Results) Substream 

func (s ByteStream_getSubstream_Results) Substream() ByteStream

func (ByteStream_getSubstream_Results) ToPtr 

func (s ByteStream_getSubstream_Results) ToPtr() capnp.Ptr

type ByteStream_getSubstream_Results_Future 

type ByteStream_getSubstream_Results_Future struct{ *capnp.Future }

ByteStream_getSubstream_Results_Future is a wrapper for a ByteStream_getSubstream_Results promised by a client call.

func (ByteStream_getSubstream_Results_Future) Struct 

func (f ByteStream_getSubstream_Results_Future) Struct() (ByteStream_getSubstream_Results, error)

func (ByteStream_getSubstream_Results_Future) Substream 

func (p ByteStream_getSubstream_Results_Future) Substream() ByteStream

type ByteStream_getSubstream_Results_List 

type ByteStream_getSubstream_Results_List = capnp.StructList[ByteStream_getSubstream_Results]

ByteStream_getSubstream_Results_List is a list of ByteStream_getSubstream_Results.

func NewByteStream_getSubstream_Results_List 

func NewByteStream_getSubstream_Results_List(s *capnp.Segment, sz int32) (ByteStream_getSubstream_Results_List, error)

NewByteStream_getSubstream_Results creates a new list of ByteStream_getSubstream_Results.

type ByteStream_startTls 

type ByteStream_startTls struct {
	*server.Call
}

ByteStream_startTls holds the state for a server call to ByteStream.startTls. See server.Call for documentation.

func (ByteStream_startTls) AllocResults 

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

AllocResults allocates the results struct.

func (ByteStream_startTls) Args 

func (c ByteStream_startTls) Args() ByteStream_startTls_Params

Args returns the call's arguments.

type ByteStream_startTls_Params 

type ByteStream_startTls_Params capnp.Struct

func NewByteStream_startTls_Params 

func NewByteStream_startTls_Params(s *capnp.Segment) (ByteStream_startTls_Params, error)

func NewRootByteStream_startTls_Params 

func NewRootByteStream_startTls_Params(s *capnp.Segment) (ByteStream_startTls_Params, error)

func ReadRootByteStream_startTls_Params 

func ReadRootByteStream_startTls_Params(msg *capnp.Message) (ByteStream_startTls_Params, error)

func (ByteStream_startTls_Params) DecodeFromPtr 

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

func (ByteStream_startTls_Params) EncodeAsPtr 

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

func (ByteStream_startTls_Params) ExpectedServerHostname 

func (s ByteStream_startTls_Params) ExpectedServerHostname() (string, error)

func (ByteStream_startTls_Params) ExpectedServerHostnameBytes 

func (s ByteStream_startTls_Params) ExpectedServerHostnameBytes() ([]byte, error)

func (ByteStream_startTls_Params) HasExpectedServerHostname 

func (s ByteStream_startTls_Params) HasExpectedServerHostname() bool

func (ByteStream_startTls_Params) IsValid 

func (s ByteStream_startTls_Params) IsValid() bool

func (ByteStream_startTls_Params) Message 

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

func (ByteStream_startTls_Params) Segment 

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

func (ByteStream_startTls_Params) SetExpectedServerHostname 

func (s ByteStream_startTls_Params) SetExpectedServerHostname(v string) error

func (ByteStream_startTls_Params) String 

func (s ByteStream_startTls_Params) String() string

func (ByteStream_startTls_Params) ToPtr 

func (s ByteStream_startTls_Params) ToPtr() capnp.Ptr

type ByteStream_startTls_Params_Future 

type ByteStream_startTls_Params_Future struct{ *capnp.Future }

ByteStream_startTls_Params_Future is a wrapper for a ByteStream_startTls_Params promised by a client call.

func (ByteStream_startTls_Params_Future) Struct 

func (f ByteStream_startTls_Params_Future) Struct() (ByteStream_startTls_Params, error)

type ByteStream_startTls_Params_List 

type ByteStream_startTls_Params_List = capnp.StructList[ByteStream_startTls_Params]

ByteStream_startTls_Params_List is a list of ByteStream_startTls_Params.

func NewByteStream_startTls_Params_List 

func NewByteStream_startTls_Params_List(s *capnp.Segment, sz int32) (ByteStream_startTls_Params_List, error)

NewByteStream_startTls_Params creates a new list of ByteStream_startTls_Params.

type ByteStream_write 

type ByteStream_write struct {
	*server.Call
}

ByteStream_write holds the state for a server call to ByteStream.write. See server.Call for documentation.

func (ByteStream_write) AllocResults 

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

AllocResults allocates the results struct.

func (ByteStream_write) Args 

func (c ByteStream_write) Args() ByteStream_write_Params

Args returns the call's arguments.

type ByteStream_write_Params 

type ByteStream_write_Params capnp.Struct

func NewByteStream_write_Params 

func NewByteStream_write_Params(s *capnp.Segment) (ByteStream_write_Params, error)

func NewRootByteStream_write_Params 

func NewRootByteStream_write_Params(s *capnp.Segment) (ByteStream_write_Params, error)

func ReadRootByteStream_write_Params 

func ReadRootByteStream_write_Params(msg *capnp.Message) (ByteStream_write_Params, error)

func (ByteStream_write_Params) Bytes 

func (s ByteStream_write_Params) Bytes() ([]byte, error)

func (ByteStream_write_Params) DecodeFromPtr 

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

func (ByteStream_write_Params) EncodeAsPtr 

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

func (ByteStream_write_Params) HasBytes 

func (s ByteStream_write_Params) HasBytes() bool

func (ByteStream_write_Params) IsValid 

func (s ByteStream_write_Params) IsValid() bool

func (ByteStream_write_Params) Message 

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

func (ByteStream_write_Params) Segment 

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

func (ByteStream_write_Params) SetBytes 

func (s ByteStream_write_Params) SetBytes(v []byte) error

func (ByteStream_write_Params) String 

func (s ByteStream_write_Params) String() string

func (ByteStream_write_Params) ToPtr 

func (s ByteStream_write_Params) ToPtr() capnp.Ptr

type ByteStream_write_Params_Future 

type ByteStream_write_Params_Future struct{ *capnp.Future }

ByteStream_write_Params_Future is a wrapper for a ByteStream_write_Params promised by a client call.

func (ByteStream_write_Params_Future) Struct 

func (f ByteStream_write_Params_Future) Struct() (ByteStream_write_Params, error)

type ByteStream_write_Params_List 

type ByteStream_write_Params_List = capnp.StructList[ByteStream_write_Params]

ByteStream_write_Params_List is a list of ByteStream_write_Params.

func NewByteStream_write_Params_List 

func NewByteStream_write_Params_List(s *capnp.Segment, sz int32) (ByteStream_write_Params_List, error)

NewByteStream_write_Params creates a new list of ByteStream_write_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.