pubsub

package
v0.1.0-alpha.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const Router_TypeID = 0xde50b3e61b766f3a

Router_TypeID is the unique identifier for the type Router.

View Source 
const Router_join_Params_TypeID = 0xfb2fed6504f78754

Router_join_Params_TypeID is the unique identifier for the type Router_join_Params.

View Source 
const Router_join_Results_TypeID = 0xe8a6b1cad09d4625

Router_join_Results_TypeID is the unique identifier for the type Router_join_Results.

View Source 
const Topic_Consumer_TypeID = 0xd72d37c8b6fbef23

Topic_Consumer_TypeID is the unique identifier for the type Topic_Consumer.

View Source 
const Topic_Consumer_consume_Params_TypeID = 0xe7745ab0f47beb88

Topic_Consumer_consume_Params_TypeID is the unique identifier for the type Topic_Consumer_consume_Params.

View Source 
const Topic_TypeID = 0x986ea9282f106bb0

Topic_TypeID is the unique identifier for the type Topic.

View Source 
const Topic_name_Params_TypeID = 0xf1fc6ff9f4d43e07

Topic_name_Params_TypeID is the unique identifier for the type Topic_name_Params.

View Source 
const Topic_name_Results_TypeID = 0xd5765aab1c56263f

Topic_name_Results_TypeID is the unique identifier for the type Topic_name_Results.

View Source 
const Topic_publish_Params_TypeID = 0x8810938879cb8443

Topic_publish_Params_TypeID is the unique identifier for the type Topic_publish_Params.

View Source 
const Topic_subscribe_Params_TypeID = 0xc772c6756fef5ba8

Topic_subscribe_Params_TypeID is the unique identifier for the type Topic_subscribe_Params.

View Source 
const Topic_subscribe_Results_TypeID = 0x8470369ac91fcc32

Topic_subscribe_Results_TypeID is the unique identifier for the type Topic_subscribe_Results.

Variables

This section is empty.

Functions

func RegisterSchema 

func RegisterSchema(reg *schemas.Registry)

func Router_Methods 

func Router_Methods(methods []server.Method, s Router_Server) []server.Method

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

func Router_NewServer 

func Router_NewServer(s Router_Server) *server.Server

Router_NewServer creates a new Server from an implementation of Router_Server.

func Topic_Consumer_Methods 

func Topic_Consumer_Methods(methods []server.Method, s Topic_Consumer_Server) []server.Method

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

func Topic_Consumer_NewServer 

func Topic_Consumer_NewServer(s Topic_Consumer_Server) *server.Server

Topic_Consumer_NewServer creates a new Server from an implementation of Topic_Consumer_Server.

func Topic_Methods 

func Topic_Methods(methods []server.Method, s Topic_Server) []server.Method

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

func Topic_NewServer 

func Topic_NewServer(s Topic_Server) *server.Server

Topic_NewServer creates a new Server from an implementation of Topic_Server.

Types

type Router 

type Router capnp.Client

func Router_ServerToClient 

func Router_ServerToClient(s Router_Server) Router

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

func (Router) AddRef 

func (c Router) AddRef() Router

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

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

func (Router) EncodeAsPtr 

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

func (Router) GetFlowLimiter 

func (c Router) GetFlowLimiter() fc.FlowLimiter

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

func (Router) IsSame 

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

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

func (c Router) Join(ctx context.Context, params func(Router_join_Params) error) (Router_join_Results_Future, capnp.ReleaseFunc)

func (Router) Release 

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

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

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

func (Router) SetFlowLimiter 

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

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

func (c Router) WaitStreaming() error

type Router_List 

type Router_List = capnp.CapList[Router]

Router_List is a list of Router.

func NewRouter_List 

func NewRouter_List(s *capnp.Segment, sz int32) (Router_List, error)

NewRouter creates a new list of Router.

type Router_Server 

type Router_Server interface {
	Join(context.Context, Router_join) error
}

A Router_Server is a Router with a local implementation.

type Router_join 

type Router_join struct {
	*server.Call
}

Router_join holds the state for a server call to Router.join. See server.Call for documentation.

func (Router_join) AllocResults 

func (c Router_join) AllocResults() (Router_join_Results, error)

AllocResults allocates the results struct.

func (Router_join) Args 

func (c Router_join) Args() Router_join_Params

Args returns the call's arguments.

type Router_join_Params 

type Router_join_Params capnp.Struct

func NewRootRouter_join_Params 

func NewRootRouter_join_Params(s *capnp.Segment) (Router_join_Params, error)

func NewRouter_join_Params 

func NewRouter_join_Params(s *capnp.Segment) (Router_join_Params, error)

func ReadRootRouter_join_Params 

func ReadRootRouter_join_Params(msg *capnp.Message) (Router_join_Params, error)

func (Router_join_Params) DecodeFromPtr 

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

func (Router_join_Params) EncodeAsPtr 

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

func (Router_join_Params) HasName 

func (s Router_join_Params) HasName() bool

func (Router_join_Params) IsValid 

func (s Router_join_Params) IsValid() bool

func (Router_join_Params) Message 

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

func (Router_join_Params) Name 

func (s Router_join_Params) Name() (string, error)

func (Router_join_Params) NameBytes 

func (s Router_join_Params) NameBytes() ([]byte, error)

func (Router_join_Params) Segment 

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

func (Router_join_Params) SetName 

func (s Router_join_Params) SetName(v string) error

func (Router_join_Params) String 

func (s Router_join_Params) String() string

func (Router_join_Params) ToPtr 

func (s Router_join_Params) ToPtr() capnp.Ptr

type Router_join_Params_Future 

type Router_join_Params_Future struct{ *capnp.Future }

Router_join_Params_Future is a wrapper for a Router_join_Params promised by a client call.

func (Router_join_Params_Future) Struct 

func (f Router_join_Params_Future) Struct() (Router_join_Params, error)

type Router_join_Params_List 

type Router_join_Params_List = capnp.StructList[Router_join_Params]

Router_join_Params_List is a list of Router_join_Params.

func NewRouter_join_Params_List 

func NewRouter_join_Params_List(s *capnp.Segment, sz int32) (Router_join_Params_List, error)

NewRouter_join_Params creates a new list of Router_join_Params.

type Router_join_Results 

type Router_join_Results capnp.Struct

func NewRootRouter_join_Results 

func NewRootRouter_join_Results(s *capnp.Segment) (Router_join_Results, error)

func NewRouter_join_Results 

func NewRouter_join_Results(s *capnp.Segment) (Router_join_Results, error)

func ReadRootRouter_join_Results 

func ReadRootRouter_join_Results(msg *capnp.Message) (Router_join_Results, error)

func (Router_join_Results) DecodeFromPtr 

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

func (Router_join_Results) EncodeAsPtr 

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

func (Router_join_Results) HasTopic 

func (s Router_join_Results) HasTopic() bool

func (Router_join_Results) IsValid 

func (s Router_join_Results) IsValid() bool

func (Router_join_Results) Message 

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

func (Router_join_Results) Segment 

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

func (Router_join_Results) SetTopic 

func (s Router_join_Results) SetTopic(v Topic) error

func (Router_join_Results) String 

func (s Router_join_Results) String() string

func (Router_join_Results) ToPtr 

func (s Router_join_Results) ToPtr() capnp.Ptr

func (Router_join_Results) Topic 

func (s Router_join_Results) Topic() Topic

type Router_join_Results_Future 

type Router_join_Results_Future struct{ *capnp.Future }

Router_join_Results_Future is a wrapper for a Router_join_Results promised by a client call.

func (Router_join_Results_Future) Struct 

func (f Router_join_Results_Future) Struct() (Router_join_Results, error)

func (Router_join_Results_Future) Topic 

func (p Router_join_Results_Future) Topic() Topic

type Router_join_Results_List 

type Router_join_Results_List = capnp.StructList[Router_join_Results]

Router_join_Results_List is a list of Router_join_Results.

func NewRouter_join_Results_List 

func NewRouter_join_Results_List(s *capnp.Segment, sz int32) (Router_join_Results_List, error)

NewRouter_join_Results creates a new list of Router_join_Results.

type Topic 

type Topic capnp.Client

func Topic_ServerToClient 

func Topic_ServerToClient(s Topic_Server) Topic

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

func (Topic) AddRef 

func (c Topic) AddRef() Topic

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

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

func (Topic) EncodeAsPtr 

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

func (Topic) GetFlowLimiter 

func (c Topic) GetFlowLimiter() fc.FlowLimiter

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

func (Topic) IsSame 

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

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

func (c Topic) Name(ctx context.Context, params func(Topic_name_Params) error) (Topic_name_Results_Future, capnp.ReleaseFunc)

func (Topic) Publish 

func (c Topic) Publish(ctx context.Context, params func(Topic_publish_Params) error) error

func (Topic) Release 

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

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

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

func (Topic) SetFlowLimiter 

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

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

func (c Topic) Subscribe(ctx context.Context, params func(Topic_subscribe_Params) error) (Topic_subscribe_Results_Future, capnp.ReleaseFunc)

func (Topic) WaitStreaming 

func (c Topic) WaitStreaming() error

type Topic_Consumer 

type Topic_Consumer capnp.Client

func Topic_Consumer_ServerToClient 

func Topic_Consumer_ServerToClient(s Topic_Consumer_Server) Topic_Consumer

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

func (Topic_Consumer) AddRef 

func (c Topic_Consumer) AddRef() Topic_Consumer

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 (Topic_Consumer) Consume 

func (c Topic_Consumer) Consume(ctx context.Context, params func(Topic_Consumer_consume_Params) error) error

func (Topic_Consumer) DecodeFromPtr 

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

func (Topic_Consumer) EncodeAsPtr 

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

func (Topic_Consumer) GetFlowLimiter 

func (c Topic_Consumer) GetFlowLimiter() fc.FlowLimiter

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

func (Topic_Consumer) IsSame 

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

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

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

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

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

func (Topic_Consumer) SetFlowLimiter 

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

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

func (c Topic_Consumer) WaitStreaming() error

type Topic_Consumer_List 

type Topic_Consumer_List = capnp.CapList[Topic_Consumer]

Topic_Consumer_List is a list of Topic_Consumer.

func NewTopic_Consumer_List 

func NewTopic_Consumer_List(s *capnp.Segment, sz int32) (Topic_Consumer_List, error)

NewTopic_Consumer creates a new list of Topic_Consumer.

type Topic_Consumer_Server 

type Topic_Consumer_Server interface {
	Consume(context.Context, Topic_Consumer_consume) error
}

A Topic_Consumer_Server is a Topic_Consumer with a local implementation.

type Topic_Consumer_consume 

type Topic_Consumer_consume struct {
	*server.Call
}

Topic_Consumer_consume holds the state for a server call to Topic_Consumer.consume. See server.Call for documentation.

func (Topic_Consumer_consume) AllocResults 

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

AllocResults allocates the results struct.

func (Topic_Consumer_consume) Args 

func (c Topic_Consumer_consume) Args() Topic_Consumer_consume_Params

Args returns the call's arguments.

type Topic_Consumer_consume_Params 

type Topic_Consumer_consume_Params capnp.Struct

func NewRootTopic_Consumer_consume_Params 

func NewRootTopic_Consumer_consume_Params(s *capnp.Segment) (Topic_Consumer_consume_Params, error)

func NewTopic_Consumer_consume_Params 

func NewTopic_Consumer_consume_Params(s *capnp.Segment) (Topic_Consumer_consume_Params, error)

func ReadRootTopic_Consumer_consume_Params 

func ReadRootTopic_Consumer_consume_Params(msg *capnp.Message) (Topic_Consumer_consume_Params, error)

func (Topic_Consumer_consume_Params) DecodeFromPtr 

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

func (Topic_Consumer_consume_Params) EncodeAsPtr 

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

func (Topic_Consumer_consume_Params) HasMsg 

func (s Topic_Consumer_consume_Params) HasMsg() bool

func (Topic_Consumer_consume_Params) IsValid 

func (s Topic_Consumer_consume_Params) IsValid() bool

func (Topic_Consumer_consume_Params) Message 

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

func (Topic_Consumer_consume_Params) Msg 

func (s Topic_Consumer_consume_Params) Msg() ([]byte, error)

func (Topic_Consumer_consume_Params) Segment 

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

func (Topic_Consumer_consume_Params) SetMsg 

func (s Topic_Consumer_consume_Params) SetMsg(v []byte) error

func (Topic_Consumer_consume_Params) String 

func (s Topic_Consumer_consume_Params) String() string

func (Topic_Consumer_consume_Params) ToPtr 

func (s Topic_Consumer_consume_Params) ToPtr() capnp.Ptr

type Topic_Consumer_consume_Params_Future 

type Topic_Consumer_consume_Params_Future struct{ *capnp.Future }

Topic_Consumer_consume_Params_Future is a wrapper for a Topic_Consumer_consume_Params promised by a client call.

func (Topic_Consumer_consume_Params_Future) Struct 

func (f Topic_Consumer_consume_Params_Future) Struct() (Topic_Consumer_consume_Params, error)

type Topic_Consumer_consume_Params_List 

type Topic_Consumer_consume_Params_List = capnp.StructList[Topic_Consumer_consume_Params]

Topic_Consumer_consume_Params_List is a list of Topic_Consumer_consume_Params.

func NewTopic_Consumer_consume_Params_List 

func NewTopic_Consumer_consume_Params_List(s *capnp.Segment, sz int32) (Topic_Consumer_consume_Params_List, error)

NewTopic_Consumer_consume_Params creates a new list of Topic_Consumer_consume_Params.

type Topic_List 

type Topic_List = capnp.CapList[Topic]

Topic_List is a list of Topic.

func NewTopic_List 

func NewTopic_List(s *capnp.Segment, sz int32) (Topic_List, error)

NewTopic creates a new list of Topic.

type Topic_Server 

type Topic_Server interface {
	Publish(context.Context, Topic_publish) error

	Subscribe(context.Context, Topic_subscribe) error

	Name(context.Context, Topic_name) error
}

A Topic_Server is a Topic with a local implementation.

type Topic_name 

type Topic_name struct {
	*server.Call
}

Topic_name holds the state for a server call to Topic.name. See server.Call for documentation.

func (Topic_name) AllocResults 

func (c Topic_name) AllocResults() (Topic_name_Results, error)

AllocResults allocates the results struct.

func (Topic_name) Args 

func (c Topic_name) Args() Topic_name_Params

Args returns the call's arguments.

type Topic_name_Params 

type Topic_name_Params capnp.Struct

func NewRootTopic_name_Params 

func NewRootTopic_name_Params(s *capnp.Segment) (Topic_name_Params, error)

func NewTopic_name_Params 

func NewTopic_name_Params(s *capnp.Segment) (Topic_name_Params, error)

func ReadRootTopic_name_Params 

func ReadRootTopic_name_Params(msg *capnp.Message) (Topic_name_Params, error)

func (Topic_name_Params) DecodeFromPtr 

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

func (Topic_name_Params) EncodeAsPtr 

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

func (Topic_name_Params) IsValid 

func (s Topic_name_Params) IsValid() bool

func (Topic_name_Params) Message 

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

func (Topic_name_Params) Segment 

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

func (Topic_name_Params) String 

func (s Topic_name_Params) String() string

func (Topic_name_Params) ToPtr 

func (s Topic_name_Params) ToPtr() capnp.Ptr

type Topic_name_Params_Future 

type Topic_name_Params_Future struct{ *capnp.Future }

Topic_name_Params_Future is a wrapper for a Topic_name_Params promised by a client call.

func (Topic_name_Params_Future) Struct 

func (f Topic_name_Params_Future) Struct() (Topic_name_Params, error)

type Topic_name_Params_List 

type Topic_name_Params_List = capnp.StructList[Topic_name_Params]

Topic_name_Params_List is a list of Topic_name_Params.

func NewTopic_name_Params_List 

func NewTopic_name_Params_List(s *capnp.Segment, sz int32) (Topic_name_Params_List, error)

NewTopic_name_Params creates a new list of Topic_name_Params.

type Topic_name_Results 

type Topic_name_Results capnp.Struct

func NewRootTopic_name_Results 

func NewRootTopic_name_Results(s *capnp.Segment) (Topic_name_Results, error)

func NewTopic_name_Results 

func NewTopic_name_Results(s *capnp.Segment) (Topic_name_Results, error)

func ReadRootTopic_name_Results 

func ReadRootTopic_name_Results(msg *capnp.Message) (Topic_name_Results, error)

func (Topic_name_Results) DecodeFromPtr 

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

func (Topic_name_Results) EncodeAsPtr 

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

func (Topic_name_Results) HasName 

func (s Topic_name_Results) HasName() bool

func (Topic_name_Results) IsValid 

func (s Topic_name_Results) IsValid() bool

func (Topic_name_Results) Message 

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

func (Topic_name_Results) Name 

func (s Topic_name_Results) Name() (string, error)

func (Topic_name_Results) NameBytes 

func (s Topic_name_Results) NameBytes() ([]byte, error)

func (Topic_name_Results) Segment 

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

func (Topic_name_Results) SetName 

func (s Topic_name_Results) SetName(v string) error

func (Topic_name_Results) String 

func (s Topic_name_Results) String() string

func (Topic_name_Results) ToPtr 

func (s Topic_name_Results) ToPtr() capnp.Ptr

type Topic_name_Results_Future 

type Topic_name_Results_Future struct{ *capnp.Future }

Topic_name_Results_Future is a wrapper for a Topic_name_Results promised by a client call.

func (Topic_name_Results_Future) Struct 

func (f Topic_name_Results_Future) Struct() (Topic_name_Results, error)

type Topic_name_Results_List 

type Topic_name_Results_List = capnp.StructList[Topic_name_Results]

Topic_name_Results_List is a list of Topic_name_Results.

func NewTopic_name_Results_List 

func NewTopic_name_Results_List(s *capnp.Segment, sz int32) (Topic_name_Results_List, error)

NewTopic_name_Results creates a new list of Topic_name_Results.

type Topic_publish 

type Topic_publish struct {
	*server.Call
}

Topic_publish holds the state for a server call to Topic.publish. See server.Call for documentation.

func (Topic_publish) AllocResults 

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

AllocResults allocates the results struct.

func (Topic_publish) Args 

func (c Topic_publish) Args() Topic_publish_Params

Args returns the call's arguments.

type Topic_publish_Params 

type Topic_publish_Params capnp.Struct

func NewRootTopic_publish_Params 

func NewRootTopic_publish_Params(s *capnp.Segment) (Topic_publish_Params, error)

func NewTopic_publish_Params 

func NewTopic_publish_Params(s *capnp.Segment) (Topic_publish_Params, error)

func ReadRootTopic_publish_Params 

func ReadRootTopic_publish_Params(msg *capnp.Message) (Topic_publish_Params, error)

func (Topic_publish_Params) DecodeFromPtr 

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

func (Topic_publish_Params) EncodeAsPtr 

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

func (Topic_publish_Params) HasMsg 

func (s Topic_publish_Params) HasMsg() bool

func (Topic_publish_Params) IsValid 

func (s Topic_publish_Params) IsValid() bool

func (Topic_publish_Params) Message 

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

func (Topic_publish_Params) Msg 

func (s Topic_publish_Params) Msg() ([]byte, error)

func (Topic_publish_Params) Segment 

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

func (Topic_publish_Params) SetMsg 

func (s Topic_publish_Params) SetMsg(v []byte) error

func (Topic_publish_Params) String 

func (s Topic_publish_Params) String() string

func (Topic_publish_Params) ToPtr 

func (s Topic_publish_Params) ToPtr() capnp.Ptr

type Topic_publish_Params_Future 

type Topic_publish_Params_Future struct{ *capnp.Future }

Topic_publish_Params_Future is a wrapper for a Topic_publish_Params promised by a client call.

func (Topic_publish_Params_Future) Struct 

func (f Topic_publish_Params_Future) Struct() (Topic_publish_Params, error)

type Topic_publish_Params_List 

type Topic_publish_Params_List = capnp.StructList[Topic_publish_Params]

Topic_publish_Params_List is a list of Topic_publish_Params.

func NewTopic_publish_Params_List 

func NewTopic_publish_Params_List(s *capnp.Segment, sz int32) (Topic_publish_Params_List, error)

NewTopic_publish_Params creates a new list of Topic_publish_Params.

type Topic_subscribe 

type Topic_subscribe struct {
	*server.Call
}

Topic_subscribe holds the state for a server call to Topic.subscribe. See server.Call for documentation.

func (Topic_subscribe) AllocResults 

func (c Topic_subscribe) AllocResults() (Topic_subscribe_Results, error)

AllocResults allocates the results struct.

func (Topic_subscribe) Args 

func (c Topic_subscribe) Args() Topic_subscribe_Params

Args returns the call's arguments.

type Topic_subscribe_Params 

type Topic_subscribe_Params capnp.Struct

func NewRootTopic_subscribe_Params 

func NewRootTopic_subscribe_Params(s *capnp.Segment) (Topic_subscribe_Params, error)

func NewTopic_subscribe_Params 

func NewTopic_subscribe_Params(s *capnp.Segment) (Topic_subscribe_Params, error)

func ReadRootTopic_subscribe_Params 

func ReadRootTopic_subscribe_Params(msg *capnp.Message) (Topic_subscribe_Params, error)

func (Topic_subscribe_Params) Buf 

func (s Topic_subscribe_Params) Buf() uint16

func (Topic_subscribe_Params) Consumer 

func (s Topic_subscribe_Params) Consumer() Topic_Consumer

func (Topic_subscribe_Params) DecodeFromPtr 

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

func (Topic_subscribe_Params) EncodeAsPtr 

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

func (Topic_subscribe_Params) HasConsumer 

func (s Topic_subscribe_Params) HasConsumer() bool

func (Topic_subscribe_Params) IsValid 

func (s Topic_subscribe_Params) IsValid() bool

func (Topic_subscribe_Params) Message 

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

func (Topic_subscribe_Params) Segment 

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

func (Topic_subscribe_Params) SetBuf 

func (s Topic_subscribe_Params) SetBuf(v uint16)

func (Topic_subscribe_Params) SetConsumer 

func (s Topic_subscribe_Params) SetConsumer(v Topic_Consumer) error

func (Topic_subscribe_Params) String 

func (s Topic_subscribe_Params) String() string

func (Topic_subscribe_Params) ToPtr 

func (s Topic_subscribe_Params) ToPtr() capnp.Ptr

type Topic_subscribe_Params_Future 

type Topic_subscribe_Params_Future struct{ *capnp.Future }

Topic_subscribe_Params_Future is a wrapper for a Topic_subscribe_Params promised by a client call.

func (Topic_subscribe_Params_Future) Consumer 

func (p Topic_subscribe_Params_Future) Consumer() Topic_Consumer

func (Topic_subscribe_Params_Future) Struct 

func (f Topic_subscribe_Params_Future) Struct() (Topic_subscribe_Params, error)

type Topic_subscribe_Params_List 

type Topic_subscribe_Params_List = capnp.StructList[Topic_subscribe_Params]

Topic_subscribe_Params_List is a list of Topic_subscribe_Params.

func NewTopic_subscribe_Params_List 

func NewTopic_subscribe_Params_List(s *capnp.Segment, sz int32) (Topic_subscribe_Params_List, error)

NewTopic_subscribe_Params creates a new list of Topic_subscribe_Params.

type Topic_subscribe_Results 

type Topic_subscribe_Results capnp.Struct

func NewRootTopic_subscribe_Results 

func NewRootTopic_subscribe_Results(s *capnp.Segment) (Topic_subscribe_Results, error)

func NewTopic_subscribe_Results 

func NewTopic_subscribe_Results(s *capnp.Segment) (Topic_subscribe_Results, error)

func ReadRootTopic_subscribe_Results 

func ReadRootTopic_subscribe_Results(msg *capnp.Message) (Topic_subscribe_Results, error)

func (Topic_subscribe_Results) DecodeFromPtr 

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

func (Topic_subscribe_Results) EncodeAsPtr 

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

func (Topic_subscribe_Results) IsValid 

func (s Topic_subscribe_Results) IsValid() bool

func (Topic_subscribe_Results) Message 

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

func (Topic_subscribe_Results) Segment 

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

func (Topic_subscribe_Results) String 

func (s Topic_subscribe_Results) String() string

func (Topic_subscribe_Results) ToPtr 

func (s Topic_subscribe_Results) ToPtr() capnp.Ptr

type Topic_subscribe_Results_Future 

type Topic_subscribe_Results_Future struct{ *capnp.Future }

Topic_subscribe_Results_Future is a wrapper for a Topic_subscribe_Results promised by a client call.

func (Topic_subscribe_Results_Future) Struct 

func (f Topic_subscribe_Results_Future) Struct() (Topic_subscribe_Results, error)

type Topic_subscribe_Results_List 

type Topic_subscribe_Results_List = capnp.StructList[Topic_subscribe_Results]

Topic_subscribe_Results_List is a list of Topic_subscribe_Results.

func NewTopic_subscribe_Results_List 

func NewTopic_subscribe_Results_List(s *capnp.Segment, sz int32) (Topic_subscribe_Results_List, error)

NewTopic_subscribe_Results creates a new list of Topic_subscribe_Results.

Source Files

View all Source files

Jump to

Keyboard shortcuts

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