Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type FlusherTimeoutOpt ¶
type FlusherTimeoutOpt struct {
// contains filtered or unexported fields
}
func WithFlusherTimeout ¶
func WithFlusherTimeout(flusherTimeout time.Duration) FlusherTimeoutOpt
type MarshalerFunc ¶
MarshalerFunc marshal struct to bytes.
type MarshalerOpt ¶
type MarshalerOpt struct {
// contains filtered or unexported fields
}
func WithMarshaler ¶
func WithMarshaler(dataMarshaler MarshalerFunc) MarshalerOpt
type Publisher ¶
type Publisher struct {
// contains filtered or unexported fields
}
Publisher implements a eventbus.Publisher interface.
func (*Publisher) AddCloseFunc ¶
func (p *Publisher) AddCloseFunc(f func())
Click to show internal directories.
Click to hide internal directories.