Documentation
¶
Index ¶
- Constants
- type Channel
- type ChannelFinder
- type ChannelGetCreator
- type ChannelGeter
- type ChannelLister
- type ChannelMonitorCreator
- type ChannelProvider
- type ChannelRPCCreator
- type ChannelRPCer
- type Nexter
- type Server
- type SimpleChannel
- func (c *SimpleChannel) ChannelGet(ctx context.Context) (interface{}, error)
- func (c *SimpleChannel) ChannelList(ctx context.Context) ([]string, error)
- func (c *SimpleChannel) CreateChannel(ctx context.Context, name string) (Channel, error)
- func (c *SimpleChannel) CreateChannelMonitor(ctx context.Context, req pvdata.PVStructure) (types.Nexter, error)
- func (c *SimpleChannel) Get() interface{}
- func (c *SimpleChannel) Name() string
- func (c *SimpleChannel) Set(value interface{})
Constants ¶
View Source
const ( INIT = iota READY REQUEST_IN_PROGRESS CANCELLED DESTROYED )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChannelFinder ¶
type ChannelFinder = types.ChannelFinder
type ChannelGetCreator ¶
type ChannelGetCreator = types.ChannelGetCreator
type ChannelGeter ¶
type ChannelGeter = types.ChannelGeter
type ChannelLister ¶
type ChannelLister = types.ChannelLister
type ChannelMonitorCreator ¶
type ChannelMonitorCreator = types.ChannelMonitorCreator
type ChannelProvider ¶
type ChannelProvider = types.ChannelProvider
type ChannelRPCCreator ¶
type ChannelRPCCreator = types.ChannelRPCCreator
type ChannelRPCer ¶
type ChannelRPCer = types.ChannelRPCer
type Server ¶
type Server struct { DisableSearch bool // contains filtered or unexported fields }
func (*Server) AddChannelProvider ¶
func (s *Server) AddChannelProvider(provider ChannelProvider)
func (*Server) ChannelProviders ¶
func (s *Server) ChannelProviders() []ChannelProvider
func (*Server) ListenAndServe ¶
ListenAndServe listens on a random port and then calls Serve.
type SimpleChannel ¶
type SimpleChannel struct {
// contains filtered or unexported fields
}
func NewSimpleChannel ¶
func NewSimpleChannel(name string) *SimpleChannel
func (*SimpleChannel) ChannelGet ¶
func (c *SimpleChannel) ChannelGet(ctx context.Context) (interface{}, error)
func (*SimpleChannel) ChannelList ¶
func (c *SimpleChannel) ChannelList(ctx context.Context) ([]string, error)
func (*SimpleChannel) CreateChannel ¶
func (*SimpleChannel) CreateChannelMonitor ¶
func (c *SimpleChannel) CreateChannelMonitor(ctx context.Context, req pvdata.PVStructure) (types.Nexter, error)
func (*SimpleChannel) Get ¶
func (c *SimpleChannel) Get() interface{}
Get returns the current value in c.
func (*SimpleChannel) Name ¶
func (c *SimpleChannel) Name() string
func (*SimpleChannel) Set ¶
func (c *SimpleChannel) Set(value interface{})
Set changes the value in c and notifies any clients that are monitoring the channel. It is not recommended to change the type of the value between calls to Set.
Click to show internal directories.
Click to hide internal directories.