channel

Documentation

Index

• type Channel
• type OutputChannel
  • func (oc *OutputChannel) Close()
  • func (oc *OutputChannel) GetChannel() interface{}
  • func (oc *OutputChannel) NewChannel(config *config.SyncParamConfig)
• type SyncChannel
  • func (sc *SyncChannel) Close()
  • func (sc *SyncChannel) GetChannel() interface{}
  • func (sc *SyncChannel) NewChannel(config *config.SyncParamConfig)

Types

type Channel

type Channel interface {
	NewChannel(config *config.SyncParamConfig)
	GetChannel() interface{}
	Close()
}

type OutputChannel

type OutputChannel struct {
	SyncChan               chan interface{}
	ChannelSize            int
	FLushCHanMaxWaitSecond int
	Done                   chan struct{}
}

func (*OutputChannel) Close

func (oc *OutputChannel) Close()

func (*OutputChannel) GetChannel

func (oc *OutputChannel) GetChannel() interface{}

func (*OutputChannel) NewChannel

func (oc *OutputChannel) NewChannel(config *config.SyncParamConfig)

type SyncChannel

type SyncChannel struct {
	SyncChan               chan interface{}
	FLushCHanMaxWaitSecond int
	Done                   chan struct{}
}

func (*SyncChannel) Close

func (sc *SyncChannel) Close()

func (*SyncChannel) GetChannel

func (sc *SyncChannel) GetChannel() interface{}

func (*SyncChannel) NewChannel

func (sc *SyncChannel) NewChannel(config *config.SyncParamConfig)