isolation

Documentation

Index

• func InitIsolationSet()
• func SetIsolation(keyword string, ProducerConfig map[string]interface{}, ...)
• type Isolation
  • func (T *Isolation) Consume(topic string, ch chan *kafka.Message)
  • func (T *Isolation) ProduceAsync(topic string, message []byte)
  • func (T *Isolation) String() string
• type Set
  • func (T *Set) GetIsolation(keyword string) (*Isolation, error)
  • func (T *Set) String() string

Functions

func InitIsolationSet

func InitIsolationSet()

functions for IsolationSet

func SetIsolation

func SetIsolation(keyword string, ProducerConfig map[string]interface{}, ConsumerConfig map[string]interface{})

Types

type Isolation

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

func (*Isolation) Consume

func (T *Isolation) Consume(topic string, ch chan *kafka.Message)

func (*Isolation) ProduceAsync

func (T *Isolation) ProduceAsync(topic string, message []byte)

functions for Isolation

func (*Isolation) String

func (T *Isolation) String() string

type Set

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

Set for Isolation

var IsolationSet Set

all isolation

func (*Set) GetIsolation

func (T *Set) GetIsolation(keyword string) (*Isolation, error)

func (*Set) String

func (T *Set) String() string