transport

Documentation

Index

• func NewKafkaTransport(conf interface{}) (core.ITransport, error)
• func NewNatsTransport(conf interface{}) (core.ITransport, error)
• type KafkaTransport
  • func (t *KafkaTransport) AddChannel(dir int, id, topic, grp string, conf interface{}) bool
  • func (t *KafkaTransport) GetBrokers() string
  • func (t *KafkaTransport) GetChannel(id string) (core.IChannel, bool)
  • func (t *KafkaTransport) GetStatsInterval() int
  • func (t *KafkaTransport) Init(logPorf bool)
  • func (t *KafkaTransport) PreStart()
  • func (t *KafkaTransport) PreStartChannel(id string) bool
  • func (t *KafkaTransport) RemoveChannel(id string)
  • func (t *KafkaTransport) SetBrokers(broker string)
  • func (t *KafkaTransport) SetID(id string)
  • func (t *KafkaTransport) SetStatsInterval(interval int)
  • func (t *KafkaTransport) Start()
  • func (t *KafkaTransport) StartChannel(id string)
  • func (t *KafkaTransport) StopChannel(id string)
• type NatsTransport
  • func (t *NatsTransport) AddChannel(dir int, id, topic, grp string, conf interface{}) bool
  • func (t *NatsTransport) GetBrokers() string
  • func (t *NatsTransport) GetChannel(id string) (core.IChannel, bool)
  • func (t *NatsTransport) GetStatsInterval() int
  • func (t *NatsTransport) Init(logPorf bool)
  • func (t *NatsTransport) PreStart()
  • func (t *NatsTransport) PreStartChannel(id string) bool
  • func (t *NatsTransport) RemoveChannel(id string)
  • func (t *NatsTransport) SetBrokers(broker string)
  • func (t *NatsTransport) SetID(id string)
  • func (t *NatsTransport) SetStatsInterval(interval int)
  • func (t *NatsTransport) Start()
  • func (t *NatsTransport) StartChannel(id string)
  • func (t *NatsTransport) StopChannel(id string)

Functions

func NewKafkaTransport

func NewKafkaTransport(conf interface{}) (core.ITransport, error)

func NewNatsTransport

func NewNatsTransport(conf interface{}) (core.ITransport, error)

Types

type KafkaTransport

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

func (*KafkaTransport) AddChannel

func (t *KafkaTransport) AddChannel(dir int, id, topic, grp string, conf interface{}) bool

func (*KafkaTransport) GetBrokers

func (t *KafkaTransport) GetBrokers() string

func (*KafkaTransport) GetChannel

func (t *KafkaTransport) GetChannel(id string) (core.IChannel, bool)

func (*KafkaTransport) GetStatsInterval

func (t *KafkaTransport) GetStatsInterval() int

func (*KafkaTransport) Init

func (t *KafkaTransport) Init(logPorf bool)

func (*KafkaTransport) PreStart

func (t *KafkaTransport) PreStart()

func (*KafkaTransport) PreStartChannel

func (t *KafkaTransport) PreStartChannel(id string) bool

func (*KafkaTransport) RemoveChannel

func (t *KafkaTransport) RemoveChannel(id string)

func (*KafkaTransport) SetBrokers

func (t *KafkaTransport) SetBrokers(broker string)

func (*KafkaTransport) SetID

func (t *KafkaTransport) SetID(id string)

func (*KafkaTransport) SetStatsInterval

func (t *KafkaTransport) SetStatsInterval(interval int)

func (*KafkaTransport) Start

func (t *KafkaTransport) Start()

func (*KafkaTransport) StartChannel

func (t *KafkaTransport) StartChannel(id string)

func (*KafkaTransport) StopChannel

func (t *KafkaTransport) StopChannel(id string)

type NatsTransport

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

func (*NatsTransport) AddChannel

func (t *NatsTransport) AddChannel(dir int, id, topic, grp string, conf interface{}) bool

func (*NatsTransport) GetBrokers

func (t *NatsTransport) GetBrokers() string

func (*NatsTransport) GetChannel

func (t *NatsTransport) GetChannel(id string) (core.IChannel, bool)

func (*NatsTransport) GetStatsInterval

func (t *NatsTransport) GetStatsInterval() int

func (*NatsTransport) Init

func (t *NatsTransport) Init(logPorf bool)

func (*NatsTransport) PreStart

func (t *NatsTransport) PreStart()

func (*NatsTransport) PreStartChannel

func (t *NatsTransport) PreStartChannel(id string) bool

func (*NatsTransport) RemoveChannel

func (t *NatsTransport) RemoveChannel(id string)

func (*NatsTransport) SetBrokers

func (t *NatsTransport) SetBrokers(broker string)

func (*NatsTransport) SetID

func (t *NatsTransport) SetID(id string)

func (*NatsTransport) SetStatsInterval

func (t *NatsTransport) SetStatsInterval(interval int)

func (*NatsTransport) Start

func (t *NatsTransport) Start()

func (*NatsTransport) StartChannel

func (t *NatsTransport) StartChannel(id string)

func (*NatsTransport) StopChannel

func (t *NatsTransport) StopChannel(id string)