Documentation
¶
Index ¶
- Constants
- type Kafka
- func (d *Kafka) Close() error
- func (d *Kafka) Connect() error
- func (d *Kafka) Enable(enabled bool)
- func (d *Kafka) GetCheckInterval() int
- func (d *Kafka) GetDownTimeDiff() string
- func (d *Kafka) GetMessage() string
- func (d *Kafka) IsEnabled() bool
- func (d *Kafka) IsRecover() bool
- func (d *Kafka) Name() string
- func (d *Kafka) Ping() []byte
- func (d *Kafka) SetCheckInterval(interval int)
- func (d *Kafka) SetConfig(configs config.Config)
- func (d *Kafka) SetLastDownTimeNow()
- func (d *Kafka) SetMessage(message string)
- func (d *Kafka) SetRecover(recovered bool)
- func (d *Kafka) SetURL(url string)
- func (d *Kafka) Stop() chan bool
Constants ¶
View Source
const (
// ErrorClosedNetwork is an error indicating the connection is closed
ErrorClosedNetwork = "use of closed network connection"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Kafka ¶
type Kafka struct {
// contains filtered or unexported fields
}
Kafka service
func (*Kafka) GetCheckInterval ¶
GetCheckInterval will return check interval to service
func (*Kafka) GetDownTimeDiff ¶
GetDownTimeDiff will return down time service difference in minutes
func (*Kafka) GetMessage ¶
GetMessage will return additional message
func (*Kafka) SetCheckInterval ¶
SetCheckInterval will set check interval to service
func (*Kafka) SetLastDownTimeNow ¶
func (d *Kafka) SetLastDownTimeNow()
LastDownTime will set last down time of service to current time
func (*Kafka) SetMessage ¶
SetMessage will set additional message
func (*Kafka) SetRecover ¶
SetRecover will set recovered status
Source Files
Click to show internal directories.
Click to hide internal directories.