Documentation ¶
Index ¶
- Constants
- func Channel_Methods(methods []server.Method, s Channel_Server) []server.Method
- func Channel_NewServer(s Channel_Server) *server.Server
- func Channel_Reader_Methods(methods []server.Method, s Channel_Reader_Server) []server.Method
- func Channel_Reader_NewServer(s Channel_Reader_Server) *server.Server
- func Channel_Writer_Methods(methods []server.Method, s Channel_Writer_Server) []server.Method
- func Channel_Writer_NewServer(s Channel_Writer_Server) *server.Server
- func RegisterSchema(reg *schemas.Registry)
- type Channel
- func (c Channel) AddRef() Channel
- func (c Channel) Close(ctx context.Context, params func(Channel_close_Params) error) (Channel_close_Results_Future, capnp.ReleaseFunc)
- func (Channel) DecodeFromPtr(p capnp.Ptr) Channel
- func (c Channel) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (c Channel) Endpoints(ctx context.Context, params func(Channel_endpoints_Params) error) (Channel_endpoints_Results_Future, capnp.ReleaseFunc)
- func (c Channel) GetFlowLimiter() fc.FlowLimiter
- func (c Channel) Info(ctx context.Context, params func(common.Identifiable_info_Params) error) (common.IdInformation_Future, capnp.ReleaseFunc)
- func (c Channel) IsSame(other Channel) bool
- func (c Channel) IsValid() bool
- func (c Channel) Reader(ctx context.Context, params func(Channel_reader_Params) error) (Channel_reader_Results_Future, capnp.ReleaseFunc)
- func (c Channel) Release()
- func (c Channel) Resolve(ctx context.Context) error
- func (c Channel) Save(ctx context.Context, params func(persistence.Persistent_SaveParams) error) (persistence.Persistent_SaveResults_Future, capnp.ReleaseFunc)
- func (c Channel) SetAutoCloseSemantics(ctx context.Context, params func(Channel_setAutoCloseSemantics_Params) error) (Channel_setAutoCloseSemantics_Results_Future, capnp.ReleaseFunc)
- func (c Channel) SetBufferSize(ctx context.Context, params func(Channel_setBufferSize_Params) error) (Channel_setBufferSize_Results_Future, capnp.ReleaseFunc)
- func (c Channel) SetFlowLimiter(lim fc.FlowLimiter)
- func (c Channel) String() string
- func (c Channel) WaitStreaming() error
- func (c Channel) Writer(ctx context.Context, params func(Channel_writer_Params) error) (Channel_writer_Results_Future, capnp.ReleaseFunc)
- type Channel_CloseSemantics
- type Channel_CloseSemantics_List
- type Channel_List
- type Channel_Msg
- func (Channel_Msg) DecodeFromPtr(p capnp.Ptr) Channel_Msg
- func (s Channel_Msg) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Channel_Msg) HasValue() bool
- func (s Channel_Msg) IsValid() bool
- func (s Channel_Msg) Message() *capnp.Message
- func (s Channel_Msg) Segment() *capnp.Segment
- func (s Channel_Msg) SetDone()
- func (s Channel_Msg) SetValue(v capnp.Ptr) error
- func (s Channel_Msg) String() string
- func (s Channel_Msg) ToPtr() capnp.Ptr
- func (s Channel_Msg) Value() (capnp.Ptr, error)
- func (s Channel_Msg) Which() Channel_Msg_Which
- type Channel_Msg_Future
- type Channel_Msg_List
- type Channel_Msg_Which
- type Channel_Reader
- func (c Channel_Reader) AddRef() Channel_Reader
- func (c Channel_Reader) Close(ctx context.Context, params func(Channel_Reader_close_Params) error) (Channel_Reader_close_Results_Future, capnp.ReleaseFunc)
- func (Channel_Reader) DecodeFromPtr(p capnp.Ptr) Channel_Reader
- func (c Channel_Reader) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (c Channel_Reader) GetFlowLimiter() fc.FlowLimiter
- func (c Channel_Reader) IsSame(other Channel_Reader) bool
- func (c Channel_Reader) IsValid() bool
- func (c Channel_Reader) Read(ctx context.Context, params func(Channel_Reader_read_Params) error) (Channel_Msg_Future, capnp.ReleaseFunc)
- func (c Channel_Reader) Release()
- func (c Channel_Reader) Resolve(ctx context.Context) error
- func (c Channel_Reader) SetFlowLimiter(lim fc.FlowLimiter)
- func (c Channel_Reader) String() string
- func (c Channel_Reader) WaitStreaming() error
- type Channel_Reader_List
- type Channel_Reader_Server
- type Channel_Reader_close
- type Channel_Reader_close_Params
- func (Channel_Reader_close_Params) DecodeFromPtr(p capnp.Ptr) Channel_Reader_close_Params
- func (s Channel_Reader_close_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Channel_Reader_close_Params) IsValid() bool
- func (s Channel_Reader_close_Params) Message() *capnp.Message
- func (s Channel_Reader_close_Params) Segment() *capnp.Segment
- func (s Channel_Reader_close_Params) String() string
- func (s Channel_Reader_close_Params) ToPtr() capnp.Ptr
- type Channel_Reader_close_Params_Future
- type Channel_Reader_close_Params_List
- type Channel_Reader_close_Results
- func (Channel_Reader_close_Results) DecodeFromPtr(p capnp.Ptr) Channel_Reader_close_Results
- func (s Channel_Reader_close_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Channel_Reader_close_Results) IsValid() bool
- func (s Channel_Reader_close_Results) Message() *capnp.Message
- func (s Channel_Reader_close_Results) Segment() *capnp.Segment
- func (s Channel_Reader_close_Results) String() string
- func (s Channel_Reader_close_Results) ToPtr() capnp.Ptr
- type Channel_Reader_close_Results_Future
- type Channel_Reader_close_Results_List
- type Channel_Reader_read
- type Channel_Reader_read_Params
- func (Channel_Reader_read_Params) DecodeFromPtr(p capnp.Ptr) Channel_Reader_read_Params
- func (s Channel_Reader_read_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Channel_Reader_read_Params) IsValid() bool
- func (s Channel_Reader_read_Params) Message() *capnp.Message
- func (s Channel_Reader_read_Params) Segment() *capnp.Segment
- func (s Channel_Reader_read_Params) String() string
- func (s Channel_Reader_read_Params) ToPtr() capnp.Ptr
- type Channel_Reader_read_Params_Future
- type Channel_Reader_read_Params_List
- type Channel_Server
- type Channel_StartupInfo
- func (s Channel_StartupInfo) BufferSize() uint64
- func (s Channel_StartupInfo) ChannelSR() (string, error)
- func (s Channel_StartupInfo) ChannelSRBytes() ([]byte, error)
- func (s Channel_StartupInfo) CloseSemantics() Channel_CloseSemantics
- func (Channel_StartupInfo) DecodeFromPtr(p capnp.Ptr) Channel_StartupInfo
- func (s Channel_StartupInfo) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Channel_StartupInfo) HasChannelSR() bool
- func (s Channel_StartupInfo) HasReaderSRs() bool
- func (s Channel_StartupInfo) HasWriterSRs() bool
- func (s Channel_StartupInfo) IsValid() bool
- func (s Channel_StartupInfo) Message() *capnp.Message
- func (s Channel_StartupInfo) NewReaderSRs(n int32) (capnp.TextList, error)
- func (s Channel_StartupInfo) NewWriterSRs(n int32) (capnp.TextList, error)
- func (s Channel_StartupInfo) ReaderSRs() (capnp.TextList, error)
- func (s Channel_StartupInfo) Segment() *capnp.Segment
- func (s Channel_StartupInfo) SetBufferSize(v uint64)
- func (s Channel_StartupInfo) SetChannelSR(v string) error
- func (s Channel_StartupInfo) SetCloseSemantics(v Channel_CloseSemantics)
- func (s Channel_StartupInfo) SetReaderSRs(v capnp.TextList) error
- func (s Channel_StartupInfo) SetWriterSRs(v capnp.TextList) error
- func (s Channel_StartupInfo) String() string
- func (s Channel_StartupInfo) ToPtr() capnp.Ptr
- func (s Channel_StartupInfo) WriterSRs() (capnp.TextList, error)
- type Channel_StartupInfo_Future
- type Channel_StartupInfo_List
- type Channel_Writer
- func (c Channel_Writer) AddRef() Channel_Writer
- func (c Channel_Writer) Close(ctx context.Context, params func(Channel_Writer_close_Params) error) (Channel_Writer_close_Results_Future, capnp.ReleaseFunc)
- func (Channel_Writer) DecodeFromPtr(p capnp.Ptr) Channel_Writer
- func (c Channel_Writer) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (c Channel_Writer) GetFlowLimiter() fc.FlowLimiter
- func (c Channel_Writer) IsSame(other Channel_Writer) bool
- func (c Channel_Writer) IsValid() bool
- func (c Channel_Writer) Release()
- func (c Channel_Writer) Resolve(ctx context.Context) error
- func (c Channel_Writer) SetFlowLimiter(lim fc.FlowLimiter)
- func (c Channel_Writer) String() string
- func (c Channel_Writer) WaitStreaming() error
- func (c Channel_Writer) Write(ctx context.Context, params func(Channel_Msg) error) (Channel_Writer_write_Results_Future, capnp.ReleaseFunc)
- type Channel_Writer_List
- type Channel_Writer_Server
- type Channel_Writer_close
- type Channel_Writer_close_Params
- func (Channel_Writer_close_Params) DecodeFromPtr(p capnp.Ptr) Channel_Writer_close_Params
- func (s Channel_Writer_close_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Channel_Writer_close_Params) IsValid() bool
- func (s Channel_Writer_close_Params) Message() *capnp.Message
- func (s Channel_Writer_close_Params) Segment() *capnp.Segment
- func (s Channel_Writer_close_Params) String() string
- func (s Channel_Writer_close_Params) ToPtr() capnp.Ptr
- type Channel_Writer_close_Params_Future
- type Channel_Writer_close_Params_List
- type Channel_Writer_close_Results
- func (Channel_Writer_close_Results) DecodeFromPtr(p capnp.Ptr) Channel_Writer_close_Results
- func (s Channel_Writer_close_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Channel_Writer_close_Results) IsValid() bool
- func (s Channel_Writer_close_Results) Message() *capnp.Message
- func (s Channel_Writer_close_Results) Segment() *capnp.Segment
- func (s Channel_Writer_close_Results) String() string
- func (s Channel_Writer_close_Results) ToPtr() capnp.Ptr
- type Channel_Writer_close_Results_Future
- type Channel_Writer_close_Results_List
- type Channel_Writer_write
- type Channel_Writer_write_Results
- func (Channel_Writer_write_Results) DecodeFromPtr(p capnp.Ptr) Channel_Writer_write_Results
- func (s Channel_Writer_write_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Channel_Writer_write_Results) IsValid() bool
- func (s Channel_Writer_write_Results) Message() *capnp.Message
- func (s Channel_Writer_write_Results) Segment() *capnp.Segment
- func (s Channel_Writer_write_Results) String() string
- func (s Channel_Writer_write_Results) ToPtr() capnp.Ptr
- type Channel_Writer_write_Results_Future
- type Channel_Writer_write_Results_List
- type Channel_close
- type Channel_close_Params
- func (Channel_close_Params) DecodeFromPtr(p capnp.Ptr) Channel_close_Params
- func (s Channel_close_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Channel_close_Params) IsValid() bool
- func (s Channel_close_Params) Message() *capnp.Message
- func (s Channel_close_Params) Segment() *capnp.Segment
- func (s Channel_close_Params) SetWaitForEmptyBuffer(v bool)
- func (s Channel_close_Params) String() string
- func (s Channel_close_Params) ToPtr() capnp.Ptr
- func (s Channel_close_Params) WaitForEmptyBuffer() bool
- type Channel_close_Params_Future
- type Channel_close_Params_List
- type Channel_close_Results
- func (Channel_close_Results) DecodeFromPtr(p capnp.Ptr) Channel_close_Results
- func (s Channel_close_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Channel_close_Results) IsValid() bool
- func (s Channel_close_Results) Message() *capnp.Message
- func (s Channel_close_Results) Segment() *capnp.Segment
- func (s Channel_close_Results) String() string
- func (s Channel_close_Results) ToPtr() capnp.Ptr
- type Channel_close_Results_Future
- type Channel_close_Results_List
- type Channel_endpoints
- type Channel_endpoints_Params
- func (Channel_endpoints_Params) DecodeFromPtr(p capnp.Ptr) Channel_endpoints_Params
- func (s Channel_endpoints_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Channel_endpoints_Params) IsValid() bool
- func (s Channel_endpoints_Params) Message() *capnp.Message
- func (s Channel_endpoints_Params) Segment() *capnp.Segment
- func (s Channel_endpoints_Params) String() string
- func (s Channel_endpoints_Params) ToPtr() capnp.Ptr
- type Channel_endpoints_Params_Future
- type Channel_endpoints_Params_List
- type Channel_endpoints_Results
- func (Channel_endpoints_Results) DecodeFromPtr(p capnp.Ptr) Channel_endpoints_Results
- func (s Channel_endpoints_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Channel_endpoints_Results) HasR() bool
- func (s Channel_endpoints_Results) HasW() bool
- func (s Channel_endpoints_Results) IsValid() bool
- func (s Channel_endpoints_Results) Message() *capnp.Message
- func (s Channel_endpoints_Results) R() Channel_Reader
- func (s Channel_endpoints_Results) Segment() *capnp.Segment
- func (s Channel_endpoints_Results) SetR(v Channel_Reader) error
- func (s Channel_endpoints_Results) SetW(v Channel_Writer) error
- func (s Channel_endpoints_Results) String() string
- func (s Channel_endpoints_Results) ToPtr() capnp.Ptr
- func (s Channel_endpoints_Results) W() Channel_Writer
- type Channel_endpoints_Results_Future
- type Channel_endpoints_Results_List
- type Channel_reader
- type Channel_reader_Params
- func (Channel_reader_Params) DecodeFromPtr(p capnp.Ptr) Channel_reader_Params
- func (s Channel_reader_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Channel_reader_Params) IsValid() bool
- func (s Channel_reader_Params) Message() *capnp.Message
- func (s Channel_reader_Params) Segment() *capnp.Segment
- func (s Channel_reader_Params) String() string
- func (s Channel_reader_Params) ToPtr() capnp.Ptr
- type Channel_reader_Params_Future
- type Channel_reader_Params_List
- type Channel_reader_Results
- func (Channel_reader_Results) DecodeFromPtr(p capnp.Ptr) Channel_reader_Results
- func (s Channel_reader_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Channel_reader_Results) HasR() bool
- func (s Channel_reader_Results) IsValid() bool
- func (s Channel_reader_Results) Message() *capnp.Message
- func (s Channel_reader_Results) R() Channel_Reader
- func (s Channel_reader_Results) Segment() *capnp.Segment
- func (s Channel_reader_Results) SetR(v Channel_Reader) error
- func (s Channel_reader_Results) String() string
- func (s Channel_reader_Results) ToPtr() capnp.Ptr
- type Channel_reader_Results_Future
- type Channel_reader_Results_List
- type Channel_setAutoCloseSemantics
- type Channel_setAutoCloseSemantics_Params
- func NewChannel_setAutoCloseSemantics_Params(s *capnp.Segment) (Channel_setAutoCloseSemantics_Params, error)
- func NewRootChannel_setAutoCloseSemantics_Params(s *capnp.Segment) (Channel_setAutoCloseSemantics_Params, error)
- func ReadRootChannel_setAutoCloseSemantics_Params(msg *capnp.Message) (Channel_setAutoCloseSemantics_Params, error)
- func (s Channel_setAutoCloseSemantics_Params) Cs() Channel_CloseSemantics
- func (Channel_setAutoCloseSemantics_Params) DecodeFromPtr(p capnp.Ptr) Channel_setAutoCloseSemantics_Params
- func (s Channel_setAutoCloseSemantics_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Channel_setAutoCloseSemantics_Params) IsValid() bool
- func (s Channel_setAutoCloseSemantics_Params) Message() *capnp.Message
- func (s Channel_setAutoCloseSemantics_Params) Segment() *capnp.Segment
- func (s Channel_setAutoCloseSemantics_Params) SetCs(v Channel_CloseSemantics)
- func (s Channel_setAutoCloseSemantics_Params) String() string
- func (s Channel_setAutoCloseSemantics_Params) ToPtr() capnp.Ptr
- type Channel_setAutoCloseSemantics_Params_Future
- type Channel_setAutoCloseSemantics_Params_List
- type Channel_setAutoCloseSemantics_Results
- func NewChannel_setAutoCloseSemantics_Results(s *capnp.Segment) (Channel_setAutoCloseSemantics_Results, error)
- func NewRootChannel_setAutoCloseSemantics_Results(s *capnp.Segment) (Channel_setAutoCloseSemantics_Results, error)
- func ReadRootChannel_setAutoCloseSemantics_Results(msg *capnp.Message) (Channel_setAutoCloseSemantics_Results, error)
- func (Channel_setAutoCloseSemantics_Results) DecodeFromPtr(p capnp.Ptr) Channel_setAutoCloseSemantics_Results
- func (s Channel_setAutoCloseSemantics_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Channel_setAutoCloseSemantics_Results) IsValid() bool
- func (s Channel_setAutoCloseSemantics_Results) Message() *capnp.Message
- func (s Channel_setAutoCloseSemantics_Results) Segment() *capnp.Segment
- func (s Channel_setAutoCloseSemantics_Results) String() string
- func (s Channel_setAutoCloseSemantics_Results) ToPtr() capnp.Ptr
- type Channel_setAutoCloseSemantics_Results_Future
- type Channel_setAutoCloseSemantics_Results_List
- type Channel_setBufferSize
- type Channel_setBufferSize_Params
- func (Channel_setBufferSize_Params) DecodeFromPtr(p capnp.Ptr) Channel_setBufferSize_Params
- func (s Channel_setBufferSize_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Channel_setBufferSize_Params) IsValid() bool
- func (s Channel_setBufferSize_Params) Message() *capnp.Message
- func (s Channel_setBufferSize_Params) Segment() *capnp.Segment
- func (s Channel_setBufferSize_Params) SetSize(v uint64)
- func (s Channel_setBufferSize_Params) Size() uint64
- func (s Channel_setBufferSize_Params) String() string
- func (s Channel_setBufferSize_Params) ToPtr() capnp.Ptr
- type Channel_setBufferSize_Params_Future
- type Channel_setBufferSize_Params_List
- type Channel_setBufferSize_Results
- func (Channel_setBufferSize_Results) DecodeFromPtr(p capnp.Ptr) Channel_setBufferSize_Results
- func (s Channel_setBufferSize_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Channel_setBufferSize_Results) IsValid() bool
- func (s Channel_setBufferSize_Results) Message() *capnp.Message
- func (s Channel_setBufferSize_Results) Segment() *capnp.Segment
- func (s Channel_setBufferSize_Results) String() string
- func (s Channel_setBufferSize_Results) ToPtr() capnp.Ptr
- type Channel_setBufferSize_Results_Future
- type Channel_setBufferSize_Results_List
- type Channel_writer
- type Channel_writer_Params
- func (Channel_writer_Params) DecodeFromPtr(p capnp.Ptr) Channel_writer_Params
- func (s Channel_writer_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Channel_writer_Params) IsValid() bool
- func (s Channel_writer_Params) Message() *capnp.Message
- func (s Channel_writer_Params) Segment() *capnp.Segment
- func (s Channel_writer_Params) String() string
- func (s Channel_writer_Params) ToPtr() capnp.Ptr
- type Channel_writer_Params_Future
- type Channel_writer_Params_List
- type Channel_writer_Results
- func (Channel_writer_Results) DecodeFromPtr(p capnp.Ptr) Channel_writer_Results
- func (s Channel_writer_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Channel_writer_Results) HasW() bool
- func (s Channel_writer_Results) IsValid() bool
- func (s Channel_writer_Results) Message() *capnp.Message
- func (s Channel_writer_Results) Segment() *capnp.Segment
- func (s Channel_writer_Results) SetW(v Channel_Writer) error
- func (s Channel_writer_Results) String() string
- func (s Channel_writer_Results) ToPtr() capnp.Ptr
- func (s Channel_writer_Results) W() Channel_Writer
- type Channel_writer_Results_Future
- type Channel_writer_Results_List
- type IP
- func (s IP) Attributes() (IP_KV_List, error)
- func (s IP) Content() (capnp.Ptr, error)
- func (IP) DecodeFromPtr(p capnp.Ptr) IP
- func (s IP) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s IP) HasAttributes() bool
- func (s IP) HasContent() bool
- func (s IP) IsValid() bool
- func (s IP) Message() *capnp.Message
- func (s IP) NewAttributes(n int32) (IP_KV_List, error)
- func (s IP) Segment() *capnp.Segment
- func (s IP) SetAttributes(v IP_KV_List) error
- func (s IP) SetContent(v capnp.Ptr) error
- func (s IP) String() string
- func (s IP) ToPtr() capnp.Ptr
- type IP_Future
- type IP_KV
- func (IP_KV) DecodeFromPtr(p capnp.Ptr) IP_KV
- func (s IP_KV) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s IP_KV) HasKey() bool
- func (s IP_KV) HasValue() bool
- func (s IP_KV) IsValid() bool
- func (s IP_KV) Key() (string, error)
- func (s IP_KV) KeyBytes() ([]byte, error)
- func (s IP_KV) Message() *capnp.Message
- func (s IP_KV) Segment() *capnp.Segment
- func (s IP_KV) SetKey(v string) error
- func (s IP_KV) SetValue(v capnp.Ptr) error
- func (s IP_KV) String() string
- func (s IP_KV) ToPtr() capnp.Ptr
- func (s IP_KV) Value() (capnp.Ptr, error)
- type IP_KV_Future
- type IP_KV_List
- type IP_List
Constants ¶
const Channel_CloseSemantics_TypeID = 0xa8d787cae7e0b243
Channel_CloseSemantics_TypeID is the unique identifier for the type Channel_CloseSemantics.
const Channel_Msg_TypeID = 0xd5b512f4bcd0aa2e
Channel_Msg_TypeID is the unique identifier for the type Channel_Msg.
const Channel_Reader_TypeID = 0x8bc69192f3bc97cc
Channel_Reader_TypeID is the unique identifier for the type Channel_Reader.
const Channel_Reader_close_Params_TypeID = 0x9428ea64f18c41c8
Channel_Reader_close_Params_TypeID is the unique identifier for the type Channel_Reader_close_Params.
const Channel_Reader_close_Results_TypeID = 0xb3fe08a1bf53821a
Channel_Reader_close_Results_TypeID is the unique identifier for the type Channel_Reader_close_Results.
const Channel_Reader_read_Params_TypeID = 0xc0335d99db8b2ba5
Channel_Reader_read_Params_TypeID is the unique identifier for the type Channel_Reader_read_Params.
const Channel_StartupInfo_TypeID = 0xe3d7a3237f175028
Channel_StartupInfo_TypeID is the unique identifier for the type Channel_StartupInfo.
const Channel_TypeID = 0x9c62c32b2ff2b1e8
Channel_TypeID is the unique identifier for the type Channel.
const Channel_Writer_TypeID = 0xf7fec613b4a8c79f
Channel_Writer_TypeID is the unique identifier for the type Channel_Writer.
const Channel_Writer_close_Params_TypeID = 0xbadc988dda3d1e50
Channel_Writer_close_Params_TypeID is the unique identifier for the type Channel_Writer_close_Params.
const Channel_Writer_close_Results_TypeID = 0xcb02dc91e18e58c9
Channel_Writer_close_Results_TypeID is the unique identifier for the type Channel_Writer_close_Results.
const Channel_Writer_write_Results_TypeID = 0xce9f24b8ec149524
Channel_Writer_write_Results_TypeID is the unique identifier for the type Channel_Writer_write_Results.
const Channel_close_Params_TypeID = 0x95d8ad01c1113d9c
Channel_close_Params_TypeID is the unique identifier for the type Channel_close_Params.
const Channel_close_Results_TypeID = 0xcc079ad60f1363b7
Channel_close_Results_TypeID is the unique identifier for the type Channel_close_Results.
const Channel_endpoints_Params_TypeID = 0xd23f817e914373d8
Channel_endpoints_Params_TypeID is the unique identifier for the type Channel_endpoints_Params.
const Channel_endpoints_Results_TypeID = 0xf37401d21f8d97bb
Channel_endpoints_Results_TypeID is the unique identifier for the type Channel_endpoints_Results.
const Channel_reader_Params_TypeID = 0xe607c9dd64da04c4
Channel_reader_Params_TypeID is the unique identifier for the type Channel_reader_Params.
const Channel_reader_Results_TypeID = 0xb135ffc9ccc9eca6
Channel_reader_Results_TypeID is the unique identifier for the type Channel_reader_Results.
const Channel_setAutoCloseSemantics_Params_TypeID = 0xb49836b545583add
Channel_setAutoCloseSemantics_Params_TypeID is the unique identifier for the type Channel_setAutoCloseSemantics_Params.
const Channel_setAutoCloseSemantics_Results_TypeID = 0xc0fc6e5a3fcb3206
Channel_setAutoCloseSemantics_Results_TypeID is the unique identifier for the type Channel_setAutoCloseSemantics_Results.
const Channel_setBufferSize_Params_TypeID = 0x92101e3b7a761333
Channel_setBufferSize_Params_TypeID is the unique identifier for the type Channel_setBufferSize_Params.
const Channel_setBufferSize_Results_TypeID = 0xfe6a08d5e0712c23
Channel_setBufferSize_Results_TypeID is the unique identifier for the type Channel_setBufferSize_Results.
const Channel_writer_Params_TypeID = 0xbe611d34e368e109
Channel_writer_Params_TypeID is the unique identifier for the type Channel_writer_Params.
const Channel_writer_Results_TypeID = 0xb47b53679e985c7e
Channel_writer_Results_TypeID is the unique identifier for the type Channel_writer_Results.
const IP_KV_TypeID = 0x9e9e5391e0c499e6
IP_KV_TypeID is the unique identifier for the type IP_KV.
const IP_TypeID = 0xaf0a1dc4709a5ccf
IP_TypeID is the unique identifier for the type IP.
Variables ¶
This section is empty.
Functions ¶
func Channel_Methods ¶
func Channel_Methods(methods []server.Method, s Channel_Server) []server.Method
Channel_Methods appends Methods to a slice that invoke the methods on s. This can be used to create a more complicated Server.
func Channel_NewServer ¶
func Channel_NewServer(s Channel_Server) *server.Server
Channel_NewServer creates a new Server from an implementation of Channel_Server.
func Channel_Reader_Methods ¶
func Channel_Reader_Methods(methods []server.Method, s Channel_Reader_Server) []server.Method
Channel_Reader_Methods appends Methods to a slice that invoke the methods on s. This can be used to create a more complicated Server.
func Channel_Reader_NewServer ¶
func Channel_Reader_NewServer(s Channel_Reader_Server) *server.Server
Channel_Reader_NewServer creates a new Server from an implementation of Channel_Reader_Server.
func Channel_Writer_Methods ¶
func Channel_Writer_Methods(methods []server.Method, s Channel_Writer_Server) []server.Method
Channel_Writer_Methods appends Methods to a slice that invoke the methods on s. This can be used to create a more complicated Server.
func Channel_Writer_NewServer ¶
func Channel_Writer_NewServer(s Channel_Writer_Server) *server.Server
Channel_Writer_NewServer creates a new Server from an implementation of Channel_Writer_Server.
func RegisterSchema ¶
Types ¶
type Channel ¶
func Channel_ServerToClient ¶
func Channel_ServerToClient(s Channel_Server) Channel
Channel_ServerToClient creates a new Client from an implementation of Channel_Server. The caller is responsible for calling Release on the returned Client.
func (Channel) AddRef ¶
AddRef creates a new Client that refers to the same capability as c. If c is nil or has resolved to null, then AddRef returns nil.
func (Channel) Close ¶
func (c Channel) Close(ctx context.Context, params func(Channel_close_Params) error) (Channel_close_Results_Future, capnp.ReleaseFunc)
func (Channel) Endpoints ¶
func (c Channel) Endpoints(ctx context.Context, params func(Channel_endpoints_Params) error) (Channel_endpoints_Results_Future, capnp.ReleaseFunc)
func (Channel) GetFlowLimiter ¶
func (c Channel) GetFlowLimiter() fc.FlowLimiter
Get the current flowcontrol.FlowLimiter used to manage flow control for this client.
func (Channel) Info ¶
func (c Channel) Info(ctx context.Context, params func(common.Identifiable_info_Params) error) (common.IdInformation_Future, capnp.ReleaseFunc)
func (Channel) IsSame ¶
IsSame reports whether c and other refer to a capability created by the same call to NewClient. This can return false negatives if c or other are not fully resolved: use Resolve if this is an issue. If either c or other are released, then IsSame panics.
func (Channel) IsValid ¶
IsValid reports whether c is a valid reference to a capability. A reference is invalid if it is nil, has resolved to null, or has been released.
func (Channel) Reader ¶
func (c Channel) Reader(ctx context.Context, params func(Channel_reader_Params) error) (Channel_reader_Results_Future, capnp.ReleaseFunc)
func (Channel) Release ¶
func (c Channel) 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 (Channel) Resolve ¶
Resolve blocks until the capability is fully resolved or the Context expires.
func (Channel) Save ¶
func (c Channel) Save(ctx context.Context, params func(persistence.Persistent_SaveParams) error) (persistence.Persistent_SaveResults_Future, capnp.ReleaseFunc)
func (Channel) SetAutoCloseSemantics ¶
func (c Channel) SetAutoCloseSemantics(ctx context.Context, params func(Channel_setAutoCloseSemantics_Params) error) (Channel_setAutoCloseSemantics_Results_Future, capnp.ReleaseFunc)
func (Channel) SetBufferSize ¶
func (c Channel) SetBufferSize(ctx context.Context, params func(Channel_setBufferSize_Params) error) (Channel_setBufferSize_Results_Future, capnp.ReleaseFunc)
func (Channel) SetFlowLimiter ¶
func (c Channel) 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 (Channel) 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 (Channel) WaitStreaming ¶
func (Channel) Writer ¶
func (c Channel) Writer(ctx context.Context, params func(Channel_writer_Params) error) (Channel_writer_Results_Future, capnp.ReleaseFunc)
type Channel_CloseSemantics ¶
type Channel_CloseSemantics uint16
const ( Channel_CloseSemantics_fbp Channel_CloseSemantics = 0 Channel_CloseSemantics_no Channel_CloseSemantics = 1 )
Values of Channel_CloseSemantics.
func Channel_CloseSemanticsFromString ¶
func Channel_CloseSemanticsFromString(c string) Channel_CloseSemantics
Channel_CloseSemanticsFromString returns the enum value with a name, or the zero value if there's no such value.
func (Channel_CloseSemantics) String ¶
func (c Channel_CloseSemantics) String() string
String returns the enum's constant name.
type Channel_CloseSemantics_List ¶
type Channel_CloseSemantics_List = capnp.EnumList[Channel_CloseSemantics]
func NewChannel_CloseSemantics_List ¶
func NewChannel_CloseSemantics_List(s *capnp.Segment, sz int32) (Channel_CloseSemantics_List, error)
type Channel_List ¶
Channel_List is a list of Channel.
func NewChannel_List ¶
func NewChannel_List(s *capnp.Segment, sz int32) (Channel_List, error)
NewChannel creates a new list of Channel.
type Channel_Msg ¶
func NewChannel_Msg ¶
func NewChannel_Msg(s *capnp.Segment) (Channel_Msg, error)
func NewRootChannel_Msg ¶
func NewRootChannel_Msg(s *capnp.Segment) (Channel_Msg, error)
func ReadRootChannel_Msg ¶
func ReadRootChannel_Msg(msg *capnp.Message) (Channel_Msg, error)
func (Channel_Msg) DecodeFromPtr ¶
func (Channel_Msg) DecodeFromPtr(p capnp.Ptr) Channel_Msg
func (Channel_Msg) EncodeAsPtr ¶
func (s Channel_Msg) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Channel_Msg) HasValue ¶
func (s Channel_Msg) HasValue() bool
func (Channel_Msg) IsValid ¶
func (s Channel_Msg) IsValid() bool
func (Channel_Msg) Message ¶
func (s Channel_Msg) Message() *capnp.Message
func (Channel_Msg) Segment ¶
func (s Channel_Msg) Segment() *capnp.Segment
func (Channel_Msg) SetDone ¶
func (s Channel_Msg) SetDone()
func (Channel_Msg) String ¶
func (s Channel_Msg) String() string
func (Channel_Msg) ToPtr ¶
func (s Channel_Msg) ToPtr() capnp.Ptr
func (Channel_Msg) Which ¶
func (s Channel_Msg) Which() Channel_Msg_Which
type Channel_Msg_Future ¶
Channel_Msg_Future is a wrapper for a Channel_Msg promised by a client call.
func (Channel_Msg_Future) Struct ¶
func (f Channel_Msg_Future) Struct() (Channel_Msg, error)
func (Channel_Msg_Future) Value ¶
func (p Channel_Msg_Future) Value() *capnp.Future
type Channel_Msg_List ¶
type Channel_Msg_List = capnp.StructList[Channel_Msg]
Channel_Msg_List is a list of Channel_Msg.
func NewChannel_Msg_List ¶
func NewChannel_Msg_List(s *capnp.Segment, sz int32) (Channel_Msg_List, error)
NewChannel_Msg creates a new list of Channel_Msg.
type Channel_Msg_Which ¶
type Channel_Msg_Which uint16
const ( Channel_Msg_Which_value Channel_Msg_Which = 0 Channel_Msg_Which_done Channel_Msg_Which = 1 )
func (Channel_Msg_Which) String ¶
func (w Channel_Msg_Which) String() string
type Channel_Reader ¶
func Channel_Reader_ServerToClient ¶
func Channel_Reader_ServerToClient(s Channel_Reader_Server) Channel_Reader
Channel_Reader_ServerToClient creates a new Client from an implementation of Channel_Reader_Server. The caller is responsible for calling Release on the returned Client.
func (Channel_Reader) AddRef ¶
func (c Channel_Reader) AddRef() Channel_Reader
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 (Channel_Reader) Close ¶
func (c Channel_Reader) Close(ctx context.Context, params func(Channel_Reader_close_Params) error) (Channel_Reader_close_Results_Future, capnp.ReleaseFunc)
func (Channel_Reader) DecodeFromPtr ¶
func (Channel_Reader) DecodeFromPtr(p capnp.Ptr) Channel_Reader
func (Channel_Reader) EncodeAsPtr ¶
func (c Channel_Reader) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Channel_Reader) GetFlowLimiter ¶
func (c Channel_Reader) GetFlowLimiter() fc.FlowLimiter
Get the current flowcontrol.FlowLimiter used to manage flow control for this client.
func (Channel_Reader) IsSame ¶
func (c Channel_Reader) IsSame(other Channel_Reader) 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 (Channel_Reader) IsValid ¶
func (c Channel_Reader) 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 (Channel_Reader) Read ¶
func (c Channel_Reader) Read(ctx context.Context, params func(Channel_Reader_read_Params) error) (Channel_Msg_Future, capnp.ReleaseFunc)
func (Channel_Reader) Release ¶
func (c Channel_Reader) 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 (Channel_Reader) Resolve ¶
func (c Channel_Reader) Resolve(ctx context.Context) error
Resolve blocks until the capability is fully resolved or the Context expires.
func (Channel_Reader) SetFlowLimiter ¶
func (c Channel_Reader) 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 (Channel_Reader) String ¶
func (c Channel_Reader) 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 (Channel_Reader) WaitStreaming ¶
func (c Channel_Reader) WaitStreaming() error
type Channel_Reader_List ¶
type Channel_Reader_List = capnp.CapList[Channel_Reader]
Channel_Reader_List is a list of Channel_Reader.
func NewChannel_Reader_List ¶
func NewChannel_Reader_List(s *capnp.Segment, sz int32) (Channel_Reader_List, error)
NewChannel_Reader creates a new list of Channel_Reader.
type Channel_Reader_Server ¶
type Channel_Reader_Server interface { Read(context.Context, Channel_Reader_read) error Close(context.Context, Channel_Reader_close) error }
A Channel_Reader_Server is a Channel_Reader with a local implementation.
type Channel_Reader_close ¶
Channel_Reader_close holds the state for a server call to Channel_Reader.close. See server.Call for documentation.
func (Channel_Reader_close) AllocResults ¶
func (c Channel_Reader_close) AllocResults() (Channel_Reader_close_Results, error)
AllocResults allocates the results struct.
func (Channel_Reader_close) Args ¶
func (c Channel_Reader_close) Args() Channel_Reader_close_Params
Args returns the call's arguments.
type Channel_Reader_close_Params ¶
func NewChannel_Reader_close_Params ¶
func NewChannel_Reader_close_Params(s *capnp.Segment) (Channel_Reader_close_Params, error)
func NewRootChannel_Reader_close_Params ¶
func NewRootChannel_Reader_close_Params(s *capnp.Segment) (Channel_Reader_close_Params, error)
func ReadRootChannel_Reader_close_Params ¶
func ReadRootChannel_Reader_close_Params(msg *capnp.Message) (Channel_Reader_close_Params, error)
func (Channel_Reader_close_Params) DecodeFromPtr ¶
func (Channel_Reader_close_Params) DecodeFromPtr(p capnp.Ptr) Channel_Reader_close_Params
func (Channel_Reader_close_Params) EncodeAsPtr ¶
func (s Channel_Reader_close_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Channel_Reader_close_Params) IsValid ¶
func (s Channel_Reader_close_Params) IsValid() bool
func (Channel_Reader_close_Params) Message ¶
func (s Channel_Reader_close_Params) Message() *capnp.Message
func (Channel_Reader_close_Params) Segment ¶
func (s Channel_Reader_close_Params) Segment() *capnp.Segment
func (Channel_Reader_close_Params) String ¶
func (s Channel_Reader_close_Params) String() string
func (Channel_Reader_close_Params) ToPtr ¶
func (s Channel_Reader_close_Params) ToPtr() capnp.Ptr
type Channel_Reader_close_Params_Future ¶
Channel_Reader_close_Params_Future is a wrapper for a Channel_Reader_close_Params promised by a client call.
func (Channel_Reader_close_Params_Future) Struct ¶
func (f Channel_Reader_close_Params_Future) Struct() (Channel_Reader_close_Params, error)
type Channel_Reader_close_Params_List ¶
type Channel_Reader_close_Params_List = capnp.StructList[Channel_Reader_close_Params]
Channel_Reader_close_Params_List is a list of Channel_Reader_close_Params.
func NewChannel_Reader_close_Params_List ¶
func NewChannel_Reader_close_Params_List(s *capnp.Segment, sz int32) (Channel_Reader_close_Params_List, error)
NewChannel_Reader_close_Params creates a new list of Channel_Reader_close_Params.
type Channel_Reader_close_Results ¶
func NewChannel_Reader_close_Results ¶
func NewChannel_Reader_close_Results(s *capnp.Segment) (Channel_Reader_close_Results, error)
func NewRootChannel_Reader_close_Results ¶
func NewRootChannel_Reader_close_Results(s *capnp.Segment) (Channel_Reader_close_Results, error)
func ReadRootChannel_Reader_close_Results ¶
func ReadRootChannel_Reader_close_Results(msg *capnp.Message) (Channel_Reader_close_Results, error)
func (Channel_Reader_close_Results) DecodeFromPtr ¶
func (Channel_Reader_close_Results) DecodeFromPtr(p capnp.Ptr) Channel_Reader_close_Results
func (Channel_Reader_close_Results) EncodeAsPtr ¶
func (s Channel_Reader_close_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Channel_Reader_close_Results) IsValid ¶
func (s Channel_Reader_close_Results) IsValid() bool
func (Channel_Reader_close_Results) Message ¶
func (s Channel_Reader_close_Results) Message() *capnp.Message
func (Channel_Reader_close_Results) Segment ¶
func (s Channel_Reader_close_Results) Segment() *capnp.Segment
func (Channel_Reader_close_Results) String ¶
func (s Channel_Reader_close_Results) String() string
func (Channel_Reader_close_Results) ToPtr ¶
func (s Channel_Reader_close_Results) ToPtr() capnp.Ptr
type Channel_Reader_close_Results_Future ¶
Channel_Reader_close_Results_Future is a wrapper for a Channel_Reader_close_Results promised by a client call.
func (Channel_Reader_close_Results_Future) Struct ¶
func (f Channel_Reader_close_Results_Future) Struct() (Channel_Reader_close_Results, error)
type Channel_Reader_close_Results_List ¶
type Channel_Reader_close_Results_List = capnp.StructList[Channel_Reader_close_Results]
Channel_Reader_close_Results_List is a list of Channel_Reader_close_Results.
func NewChannel_Reader_close_Results_List ¶
func NewChannel_Reader_close_Results_List(s *capnp.Segment, sz int32) (Channel_Reader_close_Results_List, error)
NewChannel_Reader_close_Results creates a new list of Channel_Reader_close_Results.
type Channel_Reader_read ¶
Channel_Reader_read holds the state for a server call to Channel_Reader.read. See server.Call for documentation.
func (Channel_Reader_read) AllocResults ¶
func (c Channel_Reader_read) AllocResults() (Channel_Msg, error)
AllocResults allocates the results struct.
func (Channel_Reader_read) Args ¶
func (c Channel_Reader_read) Args() Channel_Reader_read_Params
Args returns the call's arguments.
type Channel_Reader_read_Params ¶
func NewChannel_Reader_read_Params ¶
func NewChannel_Reader_read_Params(s *capnp.Segment) (Channel_Reader_read_Params, error)
func NewRootChannel_Reader_read_Params ¶
func NewRootChannel_Reader_read_Params(s *capnp.Segment) (Channel_Reader_read_Params, error)
func ReadRootChannel_Reader_read_Params ¶
func ReadRootChannel_Reader_read_Params(msg *capnp.Message) (Channel_Reader_read_Params, error)
func (Channel_Reader_read_Params) DecodeFromPtr ¶
func (Channel_Reader_read_Params) DecodeFromPtr(p capnp.Ptr) Channel_Reader_read_Params
func (Channel_Reader_read_Params) EncodeAsPtr ¶
func (s Channel_Reader_read_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Channel_Reader_read_Params) IsValid ¶
func (s Channel_Reader_read_Params) IsValid() bool
func (Channel_Reader_read_Params) Message ¶
func (s Channel_Reader_read_Params) Message() *capnp.Message
func (Channel_Reader_read_Params) Segment ¶
func (s Channel_Reader_read_Params) Segment() *capnp.Segment
func (Channel_Reader_read_Params) String ¶
func (s Channel_Reader_read_Params) String() string
func (Channel_Reader_read_Params) ToPtr ¶
func (s Channel_Reader_read_Params) ToPtr() capnp.Ptr
type Channel_Reader_read_Params_Future ¶
Channel_Reader_read_Params_Future is a wrapper for a Channel_Reader_read_Params promised by a client call.
func (Channel_Reader_read_Params_Future) Struct ¶
func (f Channel_Reader_read_Params_Future) Struct() (Channel_Reader_read_Params, error)
type Channel_Reader_read_Params_List ¶
type Channel_Reader_read_Params_List = capnp.StructList[Channel_Reader_read_Params]
Channel_Reader_read_Params_List is a list of Channel_Reader_read_Params.
func NewChannel_Reader_read_Params_List ¶
func NewChannel_Reader_read_Params_List(s *capnp.Segment, sz int32) (Channel_Reader_read_Params_List, error)
NewChannel_Reader_read_Params creates a new list of Channel_Reader_read_Params.
type Channel_Server ¶
type Channel_Server interface { SetBufferSize(context.Context, Channel_setBufferSize) error Reader(context.Context, Channel_reader) error Writer(context.Context, Channel_writer) error Endpoints(context.Context, Channel_endpoints) error SetAutoCloseSemantics(context.Context, Channel_setAutoCloseSemantics) error Close(context.Context, Channel_close) error Info(context.Context, common.Identifiable_info) error Save(context.Context, persistence.Persistent_save) error }
A Channel_Server is a Channel with a local implementation.
type Channel_StartupInfo ¶
func NewChannel_StartupInfo ¶
func NewChannel_StartupInfo(s *capnp.Segment) (Channel_StartupInfo, error)
func NewRootChannel_StartupInfo ¶
func NewRootChannel_StartupInfo(s *capnp.Segment) (Channel_StartupInfo, error)
func ReadRootChannel_StartupInfo ¶
func ReadRootChannel_StartupInfo(msg *capnp.Message) (Channel_StartupInfo, error)
func (Channel_StartupInfo) BufferSize ¶
func (s Channel_StartupInfo) BufferSize() uint64
func (Channel_StartupInfo) ChannelSR ¶
func (s Channel_StartupInfo) ChannelSR() (string, error)
func (Channel_StartupInfo) ChannelSRBytes ¶
func (s Channel_StartupInfo) ChannelSRBytes() ([]byte, error)
func (Channel_StartupInfo) CloseSemantics ¶
func (s Channel_StartupInfo) CloseSemantics() Channel_CloseSemantics
func (Channel_StartupInfo) DecodeFromPtr ¶
func (Channel_StartupInfo) DecodeFromPtr(p capnp.Ptr) Channel_StartupInfo
func (Channel_StartupInfo) EncodeAsPtr ¶
func (s Channel_StartupInfo) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Channel_StartupInfo) HasChannelSR ¶
func (s Channel_StartupInfo) HasChannelSR() bool
func (Channel_StartupInfo) HasReaderSRs ¶
func (s Channel_StartupInfo) HasReaderSRs() bool
func (Channel_StartupInfo) HasWriterSRs ¶
func (s Channel_StartupInfo) HasWriterSRs() bool
func (Channel_StartupInfo) IsValid ¶
func (s Channel_StartupInfo) IsValid() bool
func (Channel_StartupInfo) Message ¶
func (s Channel_StartupInfo) Message() *capnp.Message
func (Channel_StartupInfo) NewReaderSRs ¶
func (s Channel_StartupInfo) NewReaderSRs(n int32) (capnp.TextList, error)
NewReaderSRs sets the readerSRs field to a newly allocated capnp.TextList, preferring placement in s's segment.
func (Channel_StartupInfo) NewWriterSRs ¶
func (s Channel_StartupInfo) NewWriterSRs(n int32) (capnp.TextList, error)
NewWriterSRs sets the writerSRs field to a newly allocated capnp.TextList, preferring placement in s's segment.
func (Channel_StartupInfo) ReaderSRs ¶
func (s Channel_StartupInfo) ReaderSRs() (capnp.TextList, error)
func (Channel_StartupInfo) Segment ¶
func (s Channel_StartupInfo) Segment() *capnp.Segment
func (Channel_StartupInfo) SetBufferSize ¶
func (s Channel_StartupInfo) SetBufferSize(v uint64)
func (Channel_StartupInfo) SetChannelSR ¶
func (s Channel_StartupInfo) SetChannelSR(v string) error
func (Channel_StartupInfo) SetCloseSemantics ¶
func (s Channel_StartupInfo) SetCloseSemantics(v Channel_CloseSemantics)
func (Channel_StartupInfo) SetReaderSRs ¶
func (s Channel_StartupInfo) SetReaderSRs(v capnp.TextList) error
func (Channel_StartupInfo) SetWriterSRs ¶
func (s Channel_StartupInfo) SetWriterSRs(v capnp.TextList) error
func (Channel_StartupInfo) String ¶
func (s Channel_StartupInfo) String() string
func (Channel_StartupInfo) ToPtr ¶
func (s Channel_StartupInfo) ToPtr() capnp.Ptr
type Channel_StartupInfo_Future ¶
Channel_StartupInfo_Future is a wrapper for a Channel_StartupInfo promised by a client call.
func (Channel_StartupInfo_Future) Struct ¶
func (f Channel_StartupInfo_Future) Struct() (Channel_StartupInfo, error)
type Channel_StartupInfo_List ¶
type Channel_StartupInfo_List = capnp.StructList[Channel_StartupInfo]
Channel_StartupInfo_List is a list of Channel_StartupInfo.
func NewChannel_StartupInfo_List ¶
func NewChannel_StartupInfo_List(s *capnp.Segment, sz int32) (Channel_StartupInfo_List, error)
NewChannel_StartupInfo creates a new list of Channel_StartupInfo.
type Channel_Writer ¶
func Channel_Writer_ServerToClient ¶
func Channel_Writer_ServerToClient(s Channel_Writer_Server) Channel_Writer
Channel_Writer_ServerToClient creates a new Client from an implementation of Channel_Writer_Server. The caller is responsible for calling Release on the returned Client.
func (Channel_Writer) AddRef ¶
func (c Channel_Writer) AddRef() Channel_Writer
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 (Channel_Writer) Close ¶
func (c Channel_Writer) Close(ctx context.Context, params func(Channel_Writer_close_Params) error) (Channel_Writer_close_Results_Future, capnp.ReleaseFunc)
func (Channel_Writer) DecodeFromPtr ¶
func (Channel_Writer) DecodeFromPtr(p capnp.Ptr) Channel_Writer
func (Channel_Writer) EncodeAsPtr ¶
func (c Channel_Writer) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Channel_Writer) GetFlowLimiter ¶
func (c Channel_Writer) GetFlowLimiter() fc.FlowLimiter
Get the current flowcontrol.FlowLimiter used to manage flow control for this client.
func (Channel_Writer) IsSame ¶
func (c Channel_Writer) IsSame(other Channel_Writer) 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 (Channel_Writer) IsValid ¶
func (c Channel_Writer) 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 (Channel_Writer) Release ¶
func (c Channel_Writer) 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 (Channel_Writer) Resolve ¶
func (c Channel_Writer) Resolve(ctx context.Context) error
Resolve blocks until the capability is fully resolved or the Context expires.
func (Channel_Writer) SetFlowLimiter ¶
func (c Channel_Writer) 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 (Channel_Writer) String ¶
func (c Channel_Writer) 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 (Channel_Writer) WaitStreaming ¶
func (c Channel_Writer) WaitStreaming() error
func (Channel_Writer) Write ¶
func (c Channel_Writer) Write(ctx context.Context, params func(Channel_Msg) error) (Channel_Writer_write_Results_Future, capnp.ReleaseFunc)
type Channel_Writer_List ¶
type Channel_Writer_List = capnp.CapList[Channel_Writer]
Channel_Writer_List is a list of Channel_Writer.
func NewChannel_Writer_List ¶
func NewChannel_Writer_List(s *capnp.Segment, sz int32) (Channel_Writer_List, error)
NewChannel_Writer creates a new list of Channel_Writer.
type Channel_Writer_Server ¶
type Channel_Writer_Server interface { Write(context.Context, Channel_Writer_write) error Close(context.Context, Channel_Writer_close) error }
A Channel_Writer_Server is a Channel_Writer with a local implementation.
type Channel_Writer_close ¶
Channel_Writer_close holds the state for a server call to Channel_Writer.close. See server.Call for documentation.
func (Channel_Writer_close) AllocResults ¶
func (c Channel_Writer_close) AllocResults() (Channel_Writer_close_Results, error)
AllocResults allocates the results struct.
func (Channel_Writer_close) Args ¶
func (c Channel_Writer_close) Args() Channel_Writer_close_Params
Args returns the call's arguments.
type Channel_Writer_close_Params ¶
func NewChannel_Writer_close_Params ¶
func NewChannel_Writer_close_Params(s *capnp.Segment) (Channel_Writer_close_Params, error)
func NewRootChannel_Writer_close_Params ¶
func NewRootChannel_Writer_close_Params(s *capnp.Segment) (Channel_Writer_close_Params, error)
func ReadRootChannel_Writer_close_Params ¶
func ReadRootChannel_Writer_close_Params(msg *capnp.Message) (Channel_Writer_close_Params, error)
func (Channel_Writer_close_Params) DecodeFromPtr ¶
func (Channel_Writer_close_Params) DecodeFromPtr(p capnp.Ptr) Channel_Writer_close_Params
func (Channel_Writer_close_Params) EncodeAsPtr ¶
func (s Channel_Writer_close_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Channel_Writer_close_Params) IsValid ¶
func (s Channel_Writer_close_Params) IsValid() bool
func (Channel_Writer_close_Params) Message ¶
func (s Channel_Writer_close_Params) Message() *capnp.Message
func (Channel_Writer_close_Params) Segment ¶
func (s Channel_Writer_close_Params) Segment() *capnp.Segment
func (Channel_Writer_close_Params) String ¶
func (s Channel_Writer_close_Params) String() string
func (Channel_Writer_close_Params) ToPtr ¶
func (s Channel_Writer_close_Params) ToPtr() capnp.Ptr
type Channel_Writer_close_Params_Future ¶
Channel_Writer_close_Params_Future is a wrapper for a Channel_Writer_close_Params promised by a client call.
func (Channel_Writer_close_Params_Future) Struct ¶
func (f Channel_Writer_close_Params_Future) Struct() (Channel_Writer_close_Params, error)
type Channel_Writer_close_Params_List ¶
type Channel_Writer_close_Params_List = capnp.StructList[Channel_Writer_close_Params]
Channel_Writer_close_Params_List is a list of Channel_Writer_close_Params.
func NewChannel_Writer_close_Params_List ¶
func NewChannel_Writer_close_Params_List(s *capnp.Segment, sz int32) (Channel_Writer_close_Params_List, error)
NewChannel_Writer_close_Params creates a new list of Channel_Writer_close_Params.
type Channel_Writer_close_Results ¶
func NewChannel_Writer_close_Results ¶
func NewChannel_Writer_close_Results(s *capnp.Segment) (Channel_Writer_close_Results, error)
func NewRootChannel_Writer_close_Results ¶
func NewRootChannel_Writer_close_Results(s *capnp.Segment) (Channel_Writer_close_Results, error)
func ReadRootChannel_Writer_close_Results ¶
func ReadRootChannel_Writer_close_Results(msg *capnp.Message) (Channel_Writer_close_Results, error)
func (Channel_Writer_close_Results) DecodeFromPtr ¶
func (Channel_Writer_close_Results) DecodeFromPtr(p capnp.Ptr) Channel_Writer_close_Results
func (Channel_Writer_close_Results) EncodeAsPtr ¶
func (s Channel_Writer_close_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Channel_Writer_close_Results) IsValid ¶
func (s Channel_Writer_close_Results) IsValid() bool
func (Channel_Writer_close_Results) Message ¶
func (s Channel_Writer_close_Results) Message() *capnp.Message
func (Channel_Writer_close_Results) Segment ¶
func (s Channel_Writer_close_Results) Segment() *capnp.Segment
func (Channel_Writer_close_Results) String ¶
func (s Channel_Writer_close_Results) String() string
func (Channel_Writer_close_Results) ToPtr ¶
func (s Channel_Writer_close_Results) ToPtr() capnp.Ptr
type Channel_Writer_close_Results_Future ¶
Channel_Writer_close_Results_Future is a wrapper for a Channel_Writer_close_Results promised by a client call.
func (Channel_Writer_close_Results_Future) Struct ¶
func (f Channel_Writer_close_Results_Future) Struct() (Channel_Writer_close_Results, error)
type Channel_Writer_close_Results_List ¶
type Channel_Writer_close_Results_List = capnp.StructList[Channel_Writer_close_Results]
Channel_Writer_close_Results_List is a list of Channel_Writer_close_Results.
func NewChannel_Writer_close_Results_List ¶
func NewChannel_Writer_close_Results_List(s *capnp.Segment, sz int32) (Channel_Writer_close_Results_List, error)
NewChannel_Writer_close_Results creates a new list of Channel_Writer_close_Results.
type Channel_Writer_write ¶
Channel_Writer_write holds the state for a server call to Channel_Writer.write. See server.Call for documentation.
func (Channel_Writer_write) AllocResults ¶
func (c Channel_Writer_write) AllocResults() (Channel_Writer_write_Results, error)
AllocResults allocates the results struct.
func (Channel_Writer_write) Args ¶
func (c Channel_Writer_write) Args() Channel_Msg
Args returns the call's arguments.
type Channel_Writer_write_Results ¶
func NewChannel_Writer_write_Results ¶
func NewChannel_Writer_write_Results(s *capnp.Segment) (Channel_Writer_write_Results, error)
func NewRootChannel_Writer_write_Results ¶
func NewRootChannel_Writer_write_Results(s *capnp.Segment) (Channel_Writer_write_Results, error)
func ReadRootChannel_Writer_write_Results ¶
func ReadRootChannel_Writer_write_Results(msg *capnp.Message) (Channel_Writer_write_Results, error)
func (Channel_Writer_write_Results) DecodeFromPtr ¶
func (Channel_Writer_write_Results) DecodeFromPtr(p capnp.Ptr) Channel_Writer_write_Results
func (Channel_Writer_write_Results) EncodeAsPtr ¶
func (s Channel_Writer_write_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Channel_Writer_write_Results) IsValid ¶
func (s Channel_Writer_write_Results) IsValid() bool
func (Channel_Writer_write_Results) Message ¶
func (s Channel_Writer_write_Results) Message() *capnp.Message
func (Channel_Writer_write_Results) Segment ¶
func (s Channel_Writer_write_Results) Segment() *capnp.Segment
func (Channel_Writer_write_Results) String ¶
func (s Channel_Writer_write_Results) String() string
func (Channel_Writer_write_Results) ToPtr ¶
func (s Channel_Writer_write_Results) ToPtr() capnp.Ptr
type Channel_Writer_write_Results_Future ¶
Channel_Writer_write_Results_Future is a wrapper for a Channel_Writer_write_Results promised by a client call.
func (Channel_Writer_write_Results_Future) Struct ¶
func (f Channel_Writer_write_Results_Future) Struct() (Channel_Writer_write_Results, error)
type Channel_Writer_write_Results_List ¶
type Channel_Writer_write_Results_List = capnp.StructList[Channel_Writer_write_Results]
Channel_Writer_write_Results_List is a list of Channel_Writer_write_Results.
func NewChannel_Writer_write_Results_List ¶
func NewChannel_Writer_write_Results_List(s *capnp.Segment, sz int32) (Channel_Writer_write_Results_List, error)
NewChannel_Writer_write_Results creates a new list of Channel_Writer_write_Results.
type Channel_close ¶
Channel_close holds the state for a server call to Channel.close. See server.Call for documentation.
func (Channel_close) AllocResults ¶
func (c Channel_close) AllocResults() (Channel_close_Results, error)
AllocResults allocates the results struct.
func (Channel_close) Args ¶
func (c Channel_close) Args() Channel_close_Params
Args returns the call's arguments.
type Channel_close_Params ¶
func NewChannel_close_Params ¶
func NewChannel_close_Params(s *capnp.Segment) (Channel_close_Params, error)
func NewRootChannel_close_Params ¶
func NewRootChannel_close_Params(s *capnp.Segment) (Channel_close_Params, error)
func ReadRootChannel_close_Params ¶
func ReadRootChannel_close_Params(msg *capnp.Message) (Channel_close_Params, error)
func (Channel_close_Params) DecodeFromPtr ¶
func (Channel_close_Params) DecodeFromPtr(p capnp.Ptr) Channel_close_Params
func (Channel_close_Params) EncodeAsPtr ¶
func (s Channel_close_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Channel_close_Params) IsValid ¶
func (s Channel_close_Params) IsValid() bool
func (Channel_close_Params) Message ¶
func (s Channel_close_Params) Message() *capnp.Message
func (Channel_close_Params) Segment ¶
func (s Channel_close_Params) Segment() *capnp.Segment
func (Channel_close_Params) SetWaitForEmptyBuffer ¶
func (s Channel_close_Params) SetWaitForEmptyBuffer(v bool)
func (Channel_close_Params) String ¶
func (s Channel_close_Params) String() string
func (Channel_close_Params) ToPtr ¶
func (s Channel_close_Params) ToPtr() capnp.Ptr
func (Channel_close_Params) WaitForEmptyBuffer ¶
func (s Channel_close_Params) WaitForEmptyBuffer() bool
type Channel_close_Params_Future ¶
Channel_close_Params_Future is a wrapper for a Channel_close_Params promised by a client call.
func (Channel_close_Params_Future) Struct ¶
func (f Channel_close_Params_Future) Struct() (Channel_close_Params, error)
type Channel_close_Params_List ¶
type Channel_close_Params_List = capnp.StructList[Channel_close_Params]
Channel_close_Params_List is a list of Channel_close_Params.
func NewChannel_close_Params_List ¶
func NewChannel_close_Params_List(s *capnp.Segment, sz int32) (Channel_close_Params_List, error)
NewChannel_close_Params creates a new list of Channel_close_Params.
type Channel_close_Results ¶
func NewChannel_close_Results ¶
func NewChannel_close_Results(s *capnp.Segment) (Channel_close_Results, error)
func NewRootChannel_close_Results ¶
func NewRootChannel_close_Results(s *capnp.Segment) (Channel_close_Results, error)
func ReadRootChannel_close_Results ¶
func ReadRootChannel_close_Results(msg *capnp.Message) (Channel_close_Results, error)
func (Channel_close_Results) DecodeFromPtr ¶
func (Channel_close_Results) DecodeFromPtr(p capnp.Ptr) Channel_close_Results
func (Channel_close_Results) EncodeAsPtr ¶
func (s Channel_close_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Channel_close_Results) IsValid ¶
func (s Channel_close_Results) IsValid() bool
func (Channel_close_Results) Message ¶
func (s Channel_close_Results) Message() *capnp.Message
func (Channel_close_Results) Segment ¶
func (s Channel_close_Results) Segment() *capnp.Segment
func (Channel_close_Results) String ¶
func (s Channel_close_Results) String() string
func (Channel_close_Results) ToPtr ¶
func (s Channel_close_Results) ToPtr() capnp.Ptr
type Channel_close_Results_Future ¶
Channel_close_Results_Future is a wrapper for a Channel_close_Results promised by a client call.
func (Channel_close_Results_Future) Struct ¶
func (f Channel_close_Results_Future) Struct() (Channel_close_Results, error)
type Channel_close_Results_List ¶
type Channel_close_Results_List = capnp.StructList[Channel_close_Results]
Channel_close_Results_List is a list of Channel_close_Results.
func NewChannel_close_Results_List ¶
func NewChannel_close_Results_List(s *capnp.Segment, sz int32) (Channel_close_Results_List, error)
NewChannel_close_Results creates a new list of Channel_close_Results.
type Channel_endpoints ¶
Channel_endpoints holds the state for a server call to Channel.endpoints. See server.Call for documentation.
func (Channel_endpoints) AllocResults ¶
func (c Channel_endpoints) AllocResults() (Channel_endpoints_Results, error)
AllocResults allocates the results struct.
func (Channel_endpoints) Args ¶
func (c Channel_endpoints) Args() Channel_endpoints_Params
Args returns the call's arguments.
type Channel_endpoints_Params ¶
func NewChannel_endpoints_Params ¶
func NewChannel_endpoints_Params(s *capnp.Segment) (Channel_endpoints_Params, error)
func NewRootChannel_endpoints_Params ¶
func NewRootChannel_endpoints_Params(s *capnp.Segment) (Channel_endpoints_Params, error)
func ReadRootChannel_endpoints_Params ¶
func ReadRootChannel_endpoints_Params(msg *capnp.Message) (Channel_endpoints_Params, error)
func (Channel_endpoints_Params) DecodeFromPtr ¶
func (Channel_endpoints_Params) DecodeFromPtr(p capnp.Ptr) Channel_endpoints_Params
func (Channel_endpoints_Params) EncodeAsPtr ¶
func (s Channel_endpoints_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Channel_endpoints_Params) IsValid ¶
func (s Channel_endpoints_Params) IsValid() bool
func (Channel_endpoints_Params) Message ¶
func (s Channel_endpoints_Params) Message() *capnp.Message
func (Channel_endpoints_Params) Segment ¶
func (s Channel_endpoints_Params) Segment() *capnp.Segment
func (Channel_endpoints_Params) String ¶
func (s Channel_endpoints_Params) String() string
func (Channel_endpoints_Params) ToPtr ¶
func (s Channel_endpoints_Params) ToPtr() capnp.Ptr
type Channel_endpoints_Params_Future ¶
Channel_endpoints_Params_Future is a wrapper for a Channel_endpoints_Params promised by a client call.
func (Channel_endpoints_Params_Future) Struct ¶
func (f Channel_endpoints_Params_Future) Struct() (Channel_endpoints_Params, error)
type Channel_endpoints_Params_List ¶
type Channel_endpoints_Params_List = capnp.StructList[Channel_endpoints_Params]
Channel_endpoints_Params_List is a list of Channel_endpoints_Params.
func NewChannel_endpoints_Params_List ¶
func NewChannel_endpoints_Params_List(s *capnp.Segment, sz int32) (Channel_endpoints_Params_List, error)
NewChannel_endpoints_Params creates a new list of Channel_endpoints_Params.
type Channel_endpoints_Results ¶
func NewChannel_endpoints_Results ¶
func NewChannel_endpoints_Results(s *capnp.Segment) (Channel_endpoints_Results, error)
func NewRootChannel_endpoints_Results ¶
func NewRootChannel_endpoints_Results(s *capnp.Segment) (Channel_endpoints_Results, error)
func ReadRootChannel_endpoints_Results ¶
func ReadRootChannel_endpoints_Results(msg *capnp.Message) (Channel_endpoints_Results, error)
func (Channel_endpoints_Results) DecodeFromPtr ¶
func (Channel_endpoints_Results) DecodeFromPtr(p capnp.Ptr) Channel_endpoints_Results
func (Channel_endpoints_Results) EncodeAsPtr ¶
func (s Channel_endpoints_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Channel_endpoints_Results) HasR ¶
func (s Channel_endpoints_Results) HasR() bool
func (Channel_endpoints_Results) HasW ¶
func (s Channel_endpoints_Results) HasW() bool
func (Channel_endpoints_Results) IsValid ¶
func (s Channel_endpoints_Results) IsValid() bool
func (Channel_endpoints_Results) Message ¶
func (s Channel_endpoints_Results) Message() *capnp.Message
func (Channel_endpoints_Results) R ¶
func (s Channel_endpoints_Results) R() Channel_Reader
func (Channel_endpoints_Results) Segment ¶
func (s Channel_endpoints_Results) Segment() *capnp.Segment
func (Channel_endpoints_Results) SetR ¶
func (s Channel_endpoints_Results) SetR(v Channel_Reader) error
func (Channel_endpoints_Results) SetW ¶
func (s Channel_endpoints_Results) SetW(v Channel_Writer) error
func (Channel_endpoints_Results) String ¶
func (s Channel_endpoints_Results) String() string
func (Channel_endpoints_Results) ToPtr ¶
func (s Channel_endpoints_Results) ToPtr() capnp.Ptr
func (Channel_endpoints_Results) W ¶
func (s Channel_endpoints_Results) W() Channel_Writer
type Channel_endpoints_Results_Future ¶
Channel_endpoints_Results_Future is a wrapper for a Channel_endpoints_Results promised by a client call.
func (Channel_endpoints_Results_Future) R ¶
func (p Channel_endpoints_Results_Future) R() Channel_Reader
func (Channel_endpoints_Results_Future) Struct ¶
func (f Channel_endpoints_Results_Future) Struct() (Channel_endpoints_Results, error)
func (Channel_endpoints_Results_Future) W ¶
func (p Channel_endpoints_Results_Future) W() Channel_Writer
type Channel_endpoints_Results_List ¶
type Channel_endpoints_Results_List = capnp.StructList[Channel_endpoints_Results]
Channel_endpoints_Results_List is a list of Channel_endpoints_Results.
func NewChannel_endpoints_Results_List ¶
func NewChannel_endpoints_Results_List(s *capnp.Segment, sz int32) (Channel_endpoints_Results_List, error)
NewChannel_endpoints_Results creates a new list of Channel_endpoints_Results.
type Channel_reader ¶
Channel_reader holds the state for a server call to Channel.reader. See server.Call for documentation.
func (Channel_reader) AllocResults ¶
func (c Channel_reader) AllocResults() (Channel_reader_Results, error)
AllocResults allocates the results struct.
func (Channel_reader) Args ¶
func (c Channel_reader) Args() Channel_reader_Params
Args returns the call's arguments.
type Channel_reader_Params ¶
func NewChannel_reader_Params ¶
func NewChannel_reader_Params(s *capnp.Segment) (Channel_reader_Params, error)
func NewRootChannel_reader_Params ¶
func NewRootChannel_reader_Params(s *capnp.Segment) (Channel_reader_Params, error)
func ReadRootChannel_reader_Params ¶
func ReadRootChannel_reader_Params(msg *capnp.Message) (Channel_reader_Params, error)
func (Channel_reader_Params) DecodeFromPtr ¶
func (Channel_reader_Params) DecodeFromPtr(p capnp.Ptr) Channel_reader_Params
func (Channel_reader_Params) EncodeAsPtr ¶
func (s Channel_reader_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Channel_reader_Params) IsValid ¶
func (s Channel_reader_Params) IsValid() bool
func (Channel_reader_Params) Message ¶
func (s Channel_reader_Params) Message() *capnp.Message
func (Channel_reader_Params) Segment ¶
func (s Channel_reader_Params) Segment() *capnp.Segment
func (Channel_reader_Params) String ¶
func (s Channel_reader_Params) String() string
func (Channel_reader_Params) ToPtr ¶
func (s Channel_reader_Params) ToPtr() capnp.Ptr
type Channel_reader_Params_Future ¶
Channel_reader_Params_Future is a wrapper for a Channel_reader_Params promised by a client call.
func (Channel_reader_Params_Future) Struct ¶
func (f Channel_reader_Params_Future) Struct() (Channel_reader_Params, error)
type Channel_reader_Params_List ¶
type Channel_reader_Params_List = capnp.StructList[Channel_reader_Params]
Channel_reader_Params_List is a list of Channel_reader_Params.
func NewChannel_reader_Params_List ¶
func NewChannel_reader_Params_List(s *capnp.Segment, sz int32) (Channel_reader_Params_List, error)
NewChannel_reader_Params creates a new list of Channel_reader_Params.
type Channel_reader_Results ¶
func NewChannel_reader_Results ¶
func NewChannel_reader_Results(s *capnp.Segment) (Channel_reader_Results, error)
func NewRootChannel_reader_Results ¶
func NewRootChannel_reader_Results(s *capnp.Segment) (Channel_reader_Results, error)
func ReadRootChannel_reader_Results ¶
func ReadRootChannel_reader_Results(msg *capnp.Message) (Channel_reader_Results, error)
func (Channel_reader_Results) DecodeFromPtr ¶
func (Channel_reader_Results) DecodeFromPtr(p capnp.Ptr) Channel_reader_Results
func (Channel_reader_Results) EncodeAsPtr ¶
func (s Channel_reader_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Channel_reader_Results) HasR ¶
func (s Channel_reader_Results) HasR() bool
func (Channel_reader_Results) IsValid ¶
func (s Channel_reader_Results) IsValid() bool
func (Channel_reader_Results) Message ¶
func (s Channel_reader_Results) Message() *capnp.Message
func (Channel_reader_Results) R ¶
func (s Channel_reader_Results) R() Channel_Reader
func (Channel_reader_Results) Segment ¶
func (s Channel_reader_Results) Segment() *capnp.Segment
func (Channel_reader_Results) SetR ¶
func (s Channel_reader_Results) SetR(v Channel_Reader) error
func (Channel_reader_Results) String ¶
func (s Channel_reader_Results) String() string
func (Channel_reader_Results) ToPtr ¶
func (s Channel_reader_Results) ToPtr() capnp.Ptr
type Channel_reader_Results_Future ¶
Channel_reader_Results_Future is a wrapper for a Channel_reader_Results promised by a client call.
func (Channel_reader_Results_Future) R ¶
func (p Channel_reader_Results_Future) R() Channel_Reader
func (Channel_reader_Results_Future) Struct ¶
func (f Channel_reader_Results_Future) Struct() (Channel_reader_Results, error)
type Channel_reader_Results_List ¶
type Channel_reader_Results_List = capnp.StructList[Channel_reader_Results]
Channel_reader_Results_List is a list of Channel_reader_Results.
func NewChannel_reader_Results_List ¶
func NewChannel_reader_Results_List(s *capnp.Segment, sz int32) (Channel_reader_Results_List, error)
NewChannel_reader_Results creates a new list of Channel_reader_Results.
type Channel_setAutoCloseSemantics ¶
Channel_setAutoCloseSemantics holds the state for a server call to Channel.setAutoCloseSemantics. See server.Call for documentation.
func (Channel_setAutoCloseSemantics) AllocResults ¶
func (c Channel_setAutoCloseSemantics) AllocResults() (Channel_setAutoCloseSemantics_Results, error)
AllocResults allocates the results struct.
func (Channel_setAutoCloseSemantics) Args ¶
func (c Channel_setAutoCloseSemantics) Args() Channel_setAutoCloseSemantics_Params
Args returns the call's arguments.
type Channel_setAutoCloseSemantics_Params ¶
func NewChannel_setAutoCloseSemantics_Params ¶
func NewChannel_setAutoCloseSemantics_Params(s *capnp.Segment) (Channel_setAutoCloseSemantics_Params, error)
func NewRootChannel_setAutoCloseSemantics_Params ¶
func NewRootChannel_setAutoCloseSemantics_Params(s *capnp.Segment) (Channel_setAutoCloseSemantics_Params, error)
func ReadRootChannel_setAutoCloseSemantics_Params ¶
func ReadRootChannel_setAutoCloseSemantics_Params(msg *capnp.Message) (Channel_setAutoCloseSemantics_Params, error)
func (Channel_setAutoCloseSemantics_Params) Cs ¶
func (s Channel_setAutoCloseSemantics_Params) Cs() Channel_CloseSemantics
func (Channel_setAutoCloseSemantics_Params) DecodeFromPtr ¶
func (Channel_setAutoCloseSemantics_Params) DecodeFromPtr(p capnp.Ptr) Channel_setAutoCloseSemantics_Params
func (Channel_setAutoCloseSemantics_Params) EncodeAsPtr ¶
func (s Channel_setAutoCloseSemantics_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Channel_setAutoCloseSemantics_Params) IsValid ¶
func (s Channel_setAutoCloseSemantics_Params) IsValid() bool
func (Channel_setAutoCloseSemantics_Params) Message ¶
func (s Channel_setAutoCloseSemantics_Params) Message() *capnp.Message
func (Channel_setAutoCloseSemantics_Params) Segment ¶
func (s Channel_setAutoCloseSemantics_Params) Segment() *capnp.Segment
func (Channel_setAutoCloseSemantics_Params) SetCs ¶
func (s Channel_setAutoCloseSemantics_Params) SetCs(v Channel_CloseSemantics)
func (Channel_setAutoCloseSemantics_Params) String ¶
func (s Channel_setAutoCloseSemantics_Params) String() string
func (Channel_setAutoCloseSemantics_Params) ToPtr ¶
func (s Channel_setAutoCloseSemantics_Params) ToPtr() capnp.Ptr
type Channel_setAutoCloseSemantics_Params_Future ¶
Channel_setAutoCloseSemantics_Params_Future is a wrapper for a Channel_setAutoCloseSemantics_Params promised by a client call.
func (Channel_setAutoCloseSemantics_Params_Future) Struct ¶
func (f Channel_setAutoCloseSemantics_Params_Future) Struct() (Channel_setAutoCloseSemantics_Params, error)
type Channel_setAutoCloseSemantics_Params_List ¶
type Channel_setAutoCloseSemantics_Params_List = capnp.StructList[Channel_setAutoCloseSemantics_Params]
Channel_setAutoCloseSemantics_Params_List is a list of Channel_setAutoCloseSemantics_Params.
func NewChannel_setAutoCloseSemantics_Params_List ¶
func NewChannel_setAutoCloseSemantics_Params_List(s *capnp.Segment, sz int32) (Channel_setAutoCloseSemantics_Params_List, error)
NewChannel_setAutoCloseSemantics_Params creates a new list of Channel_setAutoCloseSemantics_Params.
type Channel_setAutoCloseSemantics_Results ¶
func NewChannel_setAutoCloseSemantics_Results ¶
func NewChannel_setAutoCloseSemantics_Results(s *capnp.Segment) (Channel_setAutoCloseSemantics_Results, error)
func NewRootChannel_setAutoCloseSemantics_Results ¶
func NewRootChannel_setAutoCloseSemantics_Results(s *capnp.Segment) (Channel_setAutoCloseSemantics_Results, error)
func ReadRootChannel_setAutoCloseSemantics_Results ¶
func ReadRootChannel_setAutoCloseSemantics_Results(msg *capnp.Message) (Channel_setAutoCloseSemantics_Results, error)
func (Channel_setAutoCloseSemantics_Results) DecodeFromPtr ¶
func (Channel_setAutoCloseSemantics_Results) DecodeFromPtr(p capnp.Ptr) Channel_setAutoCloseSemantics_Results
func (Channel_setAutoCloseSemantics_Results) EncodeAsPtr ¶
func (s Channel_setAutoCloseSemantics_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Channel_setAutoCloseSemantics_Results) IsValid ¶
func (s Channel_setAutoCloseSemantics_Results) IsValid() bool
func (Channel_setAutoCloseSemantics_Results) Message ¶
func (s Channel_setAutoCloseSemantics_Results) Message() *capnp.Message
func (Channel_setAutoCloseSemantics_Results) Segment ¶
func (s Channel_setAutoCloseSemantics_Results) Segment() *capnp.Segment
func (Channel_setAutoCloseSemantics_Results) String ¶
func (s Channel_setAutoCloseSemantics_Results) String() string
func (Channel_setAutoCloseSemantics_Results) ToPtr ¶
func (s Channel_setAutoCloseSemantics_Results) ToPtr() capnp.Ptr
type Channel_setAutoCloseSemantics_Results_Future ¶
Channel_setAutoCloseSemantics_Results_Future is a wrapper for a Channel_setAutoCloseSemantics_Results promised by a client call.
func (Channel_setAutoCloseSemantics_Results_Future) Struct ¶
func (f Channel_setAutoCloseSemantics_Results_Future) Struct() (Channel_setAutoCloseSemantics_Results, error)
type Channel_setAutoCloseSemantics_Results_List ¶
type Channel_setAutoCloseSemantics_Results_List = capnp.StructList[Channel_setAutoCloseSemantics_Results]
Channel_setAutoCloseSemantics_Results_List is a list of Channel_setAutoCloseSemantics_Results.
func NewChannel_setAutoCloseSemantics_Results_List ¶
func NewChannel_setAutoCloseSemantics_Results_List(s *capnp.Segment, sz int32) (Channel_setAutoCloseSemantics_Results_List, error)
NewChannel_setAutoCloseSemantics_Results creates a new list of Channel_setAutoCloseSemantics_Results.
type Channel_setBufferSize ¶
Channel_setBufferSize holds the state for a server call to Channel.setBufferSize. See server.Call for documentation.
func (Channel_setBufferSize) AllocResults ¶
func (c Channel_setBufferSize) AllocResults() (Channel_setBufferSize_Results, error)
AllocResults allocates the results struct.
func (Channel_setBufferSize) Args ¶
func (c Channel_setBufferSize) Args() Channel_setBufferSize_Params
Args returns the call's arguments.
type Channel_setBufferSize_Params ¶
func NewChannel_setBufferSize_Params ¶
func NewChannel_setBufferSize_Params(s *capnp.Segment) (Channel_setBufferSize_Params, error)
func NewRootChannel_setBufferSize_Params ¶
func NewRootChannel_setBufferSize_Params(s *capnp.Segment) (Channel_setBufferSize_Params, error)
func ReadRootChannel_setBufferSize_Params ¶
func ReadRootChannel_setBufferSize_Params(msg *capnp.Message) (Channel_setBufferSize_Params, error)
func (Channel_setBufferSize_Params) DecodeFromPtr ¶
func (Channel_setBufferSize_Params) DecodeFromPtr(p capnp.Ptr) Channel_setBufferSize_Params
func (Channel_setBufferSize_Params) EncodeAsPtr ¶
func (s Channel_setBufferSize_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Channel_setBufferSize_Params) IsValid ¶
func (s Channel_setBufferSize_Params) IsValid() bool
func (Channel_setBufferSize_Params) Message ¶
func (s Channel_setBufferSize_Params) Message() *capnp.Message
func (Channel_setBufferSize_Params) Segment ¶
func (s Channel_setBufferSize_Params) Segment() *capnp.Segment
func (Channel_setBufferSize_Params) SetSize ¶
func (s Channel_setBufferSize_Params) SetSize(v uint64)
func (Channel_setBufferSize_Params) Size ¶
func (s Channel_setBufferSize_Params) Size() uint64
func (Channel_setBufferSize_Params) String ¶
func (s Channel_setBufferSize_Params) String() string
func (Channel_setBufferSize_Params) ToPtr ¶
func (s Channel_setBufferSize_Params) ToPtr() capnp.Ptr
type Channel_setBufferSize_Params_Future ¶
Channel_setBufferSize_Params_Future is a wrapper for a Channel_setBufferSize_Params promised by a client call.
func (Channel_setBufferSize_Params_Future) Struct ¶
func (f Channel_setBufferSize_Params_Future) Struct() (Channel_setBufferSize_Params, error)
type Channel_setBufferSize_Params_List ¶
type Channel_setBufferSize_Params_List = capnp.StructList[Channel_setBufferSize_Params]
Channel_setBufferSize_Params_List is a list of Channel_setBufferSize_Params.
func NewChannel_setBufferSize_Params_List ¶
func NewChannel_setBufferSize_Params_List(s *capnp.Segment, sz int32) (Channel_setBufferSize_Params_List, error)
NewChannel_setBufferSize_Params creates a new list of Channel_setBufferSize_Params.
type Channel_setBufferSize_Results ¶
func NewChannel_setBufferSize_Results ¶
func NewChannel_setBufferSize_Results(s *capnp.Segment) (Channel_setBufferSize_Results, error)
func NewRootChannel_setBufferSize_Results ¶
func NewRootChannel_setBufferSize_Results(s *capnp.Segment) (Channel_setBufferSize_Results, error)
func ReadRootChannel_setBufferSize_Results ¶
func ReadRootChannel_setBufferSize_Results(msg *capnp.Message) (Channel_setBufferSize_Results, error)
func (Channel_setBufferSize_Results) DecodeFromPtr ¶
func (Channel_setBufferSize_Results) DecodeFromPtr(p capnp.Ptr) Channel_setBufferSize_Results
func (Channel_setBufferSize_Results) EncodeAsPtr ¶
func (s Channel_setBufferSize_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Channel_setBufferSize_Results) IsValid ¶
func (s Channel_setBufferSize_Results) IsValid() bool
func (Channel_setBufferSize_Results) Message ¶
func (s Channel_setBufferSize_Results) Message() *capnp.Message
func (Channel_setBufferSize_Results) Segment ¶
func (s Channel_setBufferSize_Results) Segment() *capnp.Segment
func (Channel_setBufferSize_Results) String ¶
func (s Channel_setBufferSize_Results) String() string
func (Channel_setBufferSize_Results) ToPtr ¶
func (s Channel_setBufferSize_Results) ToPtr() capnp.Ptr
type Channel_setBufferSize_Results_Future ¶
Channel_setBufferSize_Results_Future is a wrapper for a Channel_setBufferSize_Results promised by a client call.
func (Channel_setBufferSize_Results_Future) Struct ¶
func (f Channel_setBufferSize_Results_Future) Struct() (Channel_setBufferSize_Results, error)
type Channel_setBufferSize_Results_List ¶
type Channel_setBufferSize_Results_List = capnp.StructList[Channel_setBufferSize_Results]
Channel_setBufferSize_Results_List is a list of Channel_setBufferSize_Results.
func NewChannel_setBufferSize_Results_List ¶
func NewChannel_setBufferSize_Results_List(s *capnp.Segment, sz int32) (Channel_setBufferSize_Results_List, error)
NewChannel_setBufferSize_Results creates a new list of Channel_setBufferSize_Results.
type Channel_writer ¶
Channel_writer holds the state for a server call to Channel.writer. See server.Call for documentation.
func (Channel_writer) AllocResults ¶
func (c Channel_writer) AllocResults() (Channel_writer_Results, error)
AllocResults allocates the results struct.
func (Channel_writer) Args ¶
func (c Channel_writer) Args() Channel_writer_Params
Args returns the call's arguments.
type Channel_writer_Params ¶
func NewChannel_writer_Params ¶
func NewChannel_writer_Params(s *capnp.Segment) (Channel_writer_Params, error)
func NewRootChannel_writer_Params ¶
func NewRootChannel_writer_Params(s *capnp.Segment) (Channel_writer_Params, error)
func ReadRootChannel_writer_Params ¶
func ReadRootChannel_writer_Params(msg *capnp.Message) (Channel_writer_Params, error)
func (Channel_writer_Params) DecodeFromPtr ¶
func (Channel_writer_Params) DecodeFromPtr(p capnp.Ptr) Channel_writer_Params
func (Channel_writer_Params) EncodeAsPtr ¶
func (s Channel_writer_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Channel_writer_Params) IsValid ¶
func (s Channel_writer_Params) IsValid() bool
func (Channel_writer_Params) Message ¶
func (s Channel_writer_Params) Message() *capnp.Message
func (Channel_writer_Params) Segment ¶
func (s Channel_writer_Params) Segment() *capnp.Segment
func (Channel_writer_Params) String ¶
func (s Channel_writer_Params) String() string
func (Channel_writer_Params) ToPtr ¶
func (s Channel_writer_Params) ToPtr() capnp.Ptr
type Channel_writer_Params_Future ¶
Channel_writer_Params_Future is a wrapper for a Channel_writer_Params promised by a client call.
func (Channel_writer_Params_Future) Struct ¶
func (f Channel_writer_Params_Future) Struct() (Channel_writer_Params, error)
type Channel_writer_Params_List ¶
type Channel_writer_Params_List = capnp.StructList[Channel_writer_Params]
Channel_writer_Params_List is a list of Channel_writer_Params.
func NewChannel_writer_Params_List ¶
func NewChannel_writer_Params_List(s *capnp.Segment, sz int32) (Channel_writer_Params_List, error)
NewChannel_writer_Params creates a new list of Channel_writer_Params.
type Channel_writer_Results ¶
func NewChannel_writer_Results ¶
func NewChannel_writer_Results(s *capnp.Segment) (Channel_writer_Results, error)
func NewRootChannel_writer_Results ¶
func NewRootChannel_writer_Results(s *capnp.Segment) (Channel_writer_Results, error)
func ReadRootChannel_writer_Results ¶
func ReadRootChannel_writer_Results(msg *capnp.Message) (Channel_writer_Results, error)
func (Channel_writer_Results) DecodeFromPtr ¶
func (Channel_writer_Results) DecodeFromPtr(p capnp.Ptr) Channel_writer_Results
func (Channel_writer_Results) EncodeAsPtr ¶
func (s Channel_writer_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Channel_writer_Results) HasW ¶
func (s Channel_writer_Results) HasW() bool
func (Channel_writer_Results) IsValid ¶
func (s Channel_writer_Results) IsValid() bool
func (Channel_writer_Results) Message ¶
func (s Channel_writer_Results) Message() *capnp.Message
func (Channel_writer_Results) Segment ¶
func (s Channel_writer_Results) Segment() *capnp.Segment
func (Channel_writer_Results) SetW ¶
func (s Channel_writer_Results) SetW(v Channel_Writer) error
func (Channel_writer_Results) String ¶
func (s Channel_writer_Results) String() string
func (Channel_writer_Results) ToPtr ¶
func (s Channel_writer_Results) ToPtr() capnp.Ptr
func (Channel_writer_Results) W ¶
func (s Channel_writer_Results) W() Channel_Writer
type Channel_writer_Results_Future ¶
Channel_writer_Results_Future is a wrapper for a Channel_writer_Results promised by a client call.
func (Channel_writer_Results_Future) Struct ¶
func (f Channel_writer_Results_Future) Struct() (Channel_writer_Results, error)
func (Channel_writer_Results_Future) W ¶
func (p Channel_writer_Results_Future) W() Channel_Writer
type Channel_writer_Results_List ¶
type Channel_writer_Results_List = capnp.StructList[Channel_writer_Results]
Channel_writer_Results_List is a list of Channel_writer_Results.
func NewChannel_writer_Results_List ¶
func NewChannel_writer_Results_List(s *capnp.Segment, sz int32) (Channel_writer_Results_List, error)
NewChannel_writer_Results creates a new list of Channel_writer_Results.
type IP ¶
func (IP) Attributes ¶
func (s IP) Attributes() (IP_KV_List, error)
func (IP) HasAttributes ¶
func (IP) HasContent ¶
func (IP) NewAttributes ¶
func (s IP) NewAttributes(n int32) (IP_KV_List, error)
NewAttributes sets the attributes field to a newly allocated IP_KV_List, preferring placement in s's segment.
func (IP) SetAttributes ¶
func (s IP) SetAttributes(v IP_KV_List) error
type IP_KV_Future ¶
IP_KV_Future is a wrapper for a IP_KV promised by a client call.
func (IP_KV_Future) Struct ¶
func (f IP_KV_Future) Struct() (IP_KV, error)
func (IP_KV_Future) Value ¶
func (p IP_KV_Future) Value() *capnp.Future
type IP_KV_List ¶
type IP_KV_List = capnp.StructList[IP_KV]
IP_KV_List is a list of IP_KV.
func NewIP_KV_List ¶
func NewIP_KV_List(s *capnp.Segment, sz int32) (IP_KV_List, error)
NewIP_KV creates a new list of IP_KV.