eventbus

package module

Go to main page

Versions in this module

v1

v1.1.2

Jul 22, 2021

v1.1.1

Jul 19, 2021

v1.1.0

Jul 18, 2021

Changes in this version

type ClusterEventbusOption

+ Workers int

+ WorkersCommandBufferSize int

+ WorkersCommandTimeout time.Duration

+ WorkersMaxIdleTime time.Duration

type Eventbus

+ func NewNatsEventbus(discovery ServiceDiscovery, option NatsEventbusOption) (bus Eventbus, err error)

type LocaledEventbusOption

+ Workers int

+ WorkersCommandBufferSize int

+ WorkersCommandTimeout time.Duration

+ WorkersMaxIdleTime time.Duration

+ type NatsEventbusOption struct

+ EventChanCap int

+ MaxReconnects int

+ Meta *EndpointMeta

+ Name string

+ Password string

+ ReconnectWaitSecond int

+ RetryOnFailedConnect bool

+ Servers []string

+ TLS *EndpointTLS

+ Tags []string

+ Username string

+ Workers int

+ WorkersCommandBufferSize int

+ WorkersCommandTimeout time.Duration

+ WorkersMaxIdleTime time.Duration

v1.0.5

Jul 18, 2021

v1.0.4

Jul 17, 2021

v1.0.3

Jul 17, 2021

v1.0.2

Jul 16, 2021

Changes in this version

type ClusterEventbusOption

+ EventWorkers int

type Eventbus

+ RegisterLocalHandler func(address string, handler EventHandler, tags ...string) (err error)

type LocaledEventbusOption

+ EventWorkers int

v1.0.1

Jul 15, 2021

Changes in this version

type DeliveryOptions

+ Add func(key string, value string)

+ Empty func() bool

+ Get func(key string) (string, bool)

+ Keys func() []string

+ Put func(key string, value []string)

+ Remove func(key string)

+ Values func(key string) ([]string, bool)

+ type Event interface

+ Body func() []byte

+ Head func() EventHead

+ type EventHead interface

+ Add func(key string, value string)

+ Empty func() bool

+ Get func(key string) (string, bool)

+ Keys func() []string

+ Put func(key string, value []string)

+ Remove func(key string)

+ Values func(key string) ([]string, bool)

type ReplyFuture

+ Get func(v interface{}) (err error)

v1.0.0

Jul 14, 2021

Changes in this version

+ const EndpointStatusClosing

+ const EndpointStatusRunning

+ func NewEventbusWithOption(option LocaledEventbusOption) (eb *localedEventbus)

+ type ClusterEventbusOption struct

+ EnableLocal bool

+ EventChanCap int

+ EventHandlerInstanceNumber int

+ Host string

+ Meta *EndpointMeta

+ Port int

+ PublicHost string

+ PublicPort int

+ TLS *EndpointTLS

+ Tags []string

+ type DeliveryOptions struct

+ func NewDeliveryOptions() DeliveryOptions

+ func (options *DeliveryOptions) AddTag(tags ...string)

+ type EndpointMeta map[string]string

+ func NewEndpointMeta() EndpointMeta

+ func (meta EndpointMeta) Empty() bool

+ func (meta EndpointMeta) Get(key string) (string, bool)

+ func (meta EndpointMeta) Keys() []string

+ func (meta EndpointMeta) Merge(o ...Meta)

+ func (meta EndpointMeta) Put(key string, value string)

+ func (meta EndpointMeta) Rem(key string)

+ type EndpointStatus string

+ func (s EndpointStatus) Closing() bool

+ func (s EndpointStatus) Ok() bool

+ type EndpointTLS struct

+ CA_ string

+ ClientCert_ string

+ ClientKey_ string

+ Enable_ bool

+ ServerCert_ string

+ ServerKey_ string

+ VerifySSL_ bool

+ func (s EndpointTLS) CA() string

+ func (s EndpointTLS) ClientCert() string

+ func (s EndpointTLS) ClientKey() string

+ func (s EndpointTLS) Enable() bool

+ func (s EndpointTLS) ServerCert() string

+ func (s EndpointTLS) ServerKey() string

+ func (s EndpointTLS) ToClientTLSConfig() (config *tls.Config, err error)

+ func (s EndpointTLS) ToServerTLSConfig() (config *tls.Config, err error)

+ func (s EndpointTLS) VerifySSL() bool

+ type EventHandler func(head MultiMap, body []byte) (result interface{}, err error)

+ type Eventbus interface

+ Close func(context context.Context)

+ RegisterHandler func(address string, handler EventHandler, tags ...string) (err error)

+ Request func(address string, v interface{}, options ...DeliveryOptions) (reply *ReplyFuture)

+ Send func(address string, v interface{}, options ...DeliveryOptions) (err error)

+ Start func(context context.Context)

+ func NewClusterEventbus(discovery ServiceDiscovery, option ClusterEventbusOption) (bus Eventbus, err error)

+ func NewEventbus() Eventbus

+ type LocaledEventbusOption struct

+ EventChanCap int

+ EventHandlerInstanceNumber int

+ type Meta interface

+ Empty func() (ok bool)

+ Get func(key string) (value string, has bool)

+ Keys func() (keys []string)

+ Merge func(o ...Meta)

+ Put func(key string, value string)

+ Rem func(key string)

+ type MultiMap map[string][]string

+ func (h MultiMap) Add(key string, value string)

+ func (h MultiMap) Empty() bool

+ func (h MultiMap) Get(key string) (string, bool)

+ func (h MultiMap) Keys() []string

+ func (h MultiMap) Merge(o ...MultiMap)

+ func (h MultiMap) Put(key string, value []string)

+ func (h MultiMap) Remove(key string)

+ func (h MultiMap) Values(key string) ([]string, bool)

+ type Registration interface

+ Address func() (address string)

+ Group func() (group string)

+ Id func() (id string)

+ Meta func() (meta Meta)

+ Name func() (name string)

+ NodeId func() (nodeId string)

+ NodeName func() (nodeName string)

+ Protocol func() (protocol string)

+ Status func() (status Status)

+ TLS func() (registrationTLS RegistrationTLS)

+ Tags func() (tags []string)

+ type RegistrationTLS interface

+ CA func() string

+ ClientCert func() string

+ ClientKey func() string

+ Enable func() bool

+ ServerCert func() string

+ ServerKey func() string

+ ToClientTLSConfig func() (config *tls.Config, err error)

+ ToServerTLSConfig func() (config *tls.Config, err error)

+ VerifySSL func() bool

+ type ReplyError struct

+ Code string

+ FailureCode int

+ Id string

+ Message string

+ Meta errors.MultiMap

+ func (e *ReplyError) Error() string

+ func (e *ReplyError) GetMeta() errors.MultiMap

+ func (e *ReplyError) GetStacktrace() (fn string, file string, line int)

+ func (e *ReplyError) SetFailureCode(failureCode int) errors.CodeError

+ func (e *ReplyError) SetId(id string) errors.CodeError

+ func (e *ReplyError) String() string

+ func (e *ReplyError) ToJson() []byte

+ type ReplyFuture struct

+ func (r *ReplyFuture) Result(v interface{}) (err error)

+ type ServiceDiscovery interface

+ Get func(group string, name string, tags ...string) (registration Registration, has bool, err error)

+ GetALL func(group string, name string, tags ...string) (registrations []Registration, has bool, err error)

+ Publish func(group string, name string, protocol string, address string, tags []string, ...) (registration Registration, err error)

+ UnPublish func(registration Registration) (err error)

+ type Status interface

+ Closing func() bool

+ Ok func() bool

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL