streamer

Documentation

Index

• type ReaderHub
  • func GetReaderHub() *ReaderHub
  • func (h *ReaderHub) EarliestActiveRelayLog() *RelayLogInfo
  • func (h *ReaderHub) RemoveActiveRelayLog(taskName string)
  • func (h *ReaderHub) UpdateActiveRelayLog(taskName, subDir, filename string) error
• type RelayLogInfo
  • func (info *RelayLogInfo) Earlier(other *RelayLogInfo) bool
  • func (info *RelayLogInfo) String() string

Types

type ReaderHub

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

ReaderHub holds information for all active Readers.

func GetReaderHub

func GetReaderHub() *ReaderHub

GetReaderHub gets singleton instance of ReaderHub.

func (*ReaderHub) EarliestActiveRelayLog

func (h *ReaderHub) EarliestActiveRelayLog() *RelayLogInfo

EarliestActiveRelayLog implements RelayOperator.EarliestActiveRelayLog.

func (*ReaderHub) RemoveActiveRelayLog

func (h *ReaderHub) RemoveActiveRelayLog(taskName string)

RemoveActiveRelayLog removes active relay log for taskName.

func (*ReaderHub) UpdateActiveRelayLog

func (h *ReaderHub) UpdateActiveRelayLog(taskName, subDir, filename string) error

UpdateActiveRelayLog updates active relay log for taskName.

type RelayLogInfo

type RelayLogInfo struct {
	TaskName     string
	SubDir       string
	SubDirSuffix int
	Filename     string
}

RelayLogInfo represents information for relay log.

func (*RelayLogInfo) Earlier

func (info *RelayLogInfo) Earlier(other *RelayLogInfo) bool

Earlier checks whether this relay log file is earlier than the other.

func (*RelayLogInfo) String

func (info *RelayLogInfo) String() string

String implements Stringer.String.