Documentation
¶
Index ¶
- type Event
- type Transport
- func (t *Transport) Close() (err error)
- func (t *Transport) Closed() <-chan struct{}
- func (t *Transport) ErrorChan() <-chan error
- func (t *Transport) EventChan() <-chan pubsub.Event
- func (t *Transport) EventSeqTableChan() <-chan pubsub.EventSeqTable
- func (t *Transport) Publish(eventKind string, eventObject interface{}) error
- func (t *Transport) Subscribe(eventKindPrefix string) error
- func (t *Transport) Unsubscribe(eventKindPrefix string) error
- func (t *Transport) Wait() error
- type TransportFactory
- func (factory *TransportFactory) IsFullyConfigured() error
- func (factory *TransportFactory) MustBeFullyConfigured() *TransportFactory
- func (factory *TransportFactory) MustReadConfigFromEnv(prefix string) *TransportFactory
- func (factory *TransportFactory) NewTransport(identity string) (*Transport, error)
- func (factory *TransportFactory) ReadConfigFromEnv(prefix string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Event ¶
type Event struct {
// contains filtered or unexported fields
}
func (*Event) Seq ¶
func (event *Event) Seq() pubsub.EventSeqNum
type Transport ¶
type Transport struct {
// contains filtered or unexported fields
}
func (*Transport) EventSeqTableChan ¶
func (t *Transport) EventSeqTableChan() <-chan pubsub.EventSeqTable
func (*Transport) Unsubscribe ¶
type TransportFactory ¶
type TransportFactory struct {
RouterEndpoint string
DealerSndhwm int
DealerRcvhwm int
PubEndpoint string
SubRcvhwm int
}
func NewTransportFactory ¶
func NewTransportFactory() *TransportFactory
func (*TransportFactory) IsFullyConfigured ¶
func (factory *TransportFactory) IsFullyConfigured() error
func (*TransportFactory) MustBeFullyConfigured ¶
func (factory *TransportFactory) MustBeFullyConfigured() *TransportFactory
func (*TransportFactory) MustReadConfigFromEnv ¶
func (factory *TransportFactory) MustReadConfigFromEnv(prefix string) *TransportFactory
func (*TransportFactory) NewTransport ¶
func (factory *TransportFactory) NewTransport(identity string) (*Transport, error)
func (*TransportFactory) ReadConfigFromEnv ¶
func (factory *TransportFactory) ReadConfigFromEnv(prefix string) error
Source Files
Click to show internal directories.
Click to hide internal directories.