group

Documentation

Index

• type GroupSubscriber
  • func New(bundle *bundle.Bundle) *GroupSubscriber
  • func (d *GroupSubscriber) Name() string
  • func (d *GroupSubscriber) Publish(dest string, content string, time int64, msg *types.Message) []error
  • func (d *GroupSubscriber) SetRoute(route routerI)
  • func (d *GroupSubscriber) Status() interface{}
• type Option

Types

type GroupSubscriber

type GroupSubscriber struct {
	// contains filtered or unexported fields
}

func New

func New(bundle *bundle.Bundle) *GroupSubscriber

func (*GroupSubscriber) Name

func (d *GroupSubscriber) Name() string

func (*GroupSubscriber) Publish

func (d *GroupSubscriber) Publish(dest string, content string, time int64, msg *types.Message) []error

func (*GroupSubscriber) SetRoute

func (d *GroupSubscriber) SetRoute(route routerI)

func (*GroupSubscriber) Status

func (d *GroupSubscriber) Status() interface{}

type Option

type Option func(*GroupSubscriber)