Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ReplicationQueuePubSub ¶
type ReplicationQueuePubSub struct {
// contains filtered or unexported fields
}
func NewReplicationQueuePubSub ¶
func NewReplicationQueuePubSub(options *viper.Viper, hostname string) (rq *ReplicationQueuePubSub, err error)
func (*ReplicationQueuePubSub) ConsumeQueue ¶
func (rq *ReplicationQueuePubSub) ConsumeQueue(callbackFn func(entry *models.Replication) error) (err error)
func (*ReplicationQueuePubSub) PushToQueue ¶
func (rq *ReplicationQueuePubSub) PushToQueue(entry *models.Replication) (err error)
Click to show internal directories.
Click to hide internal directories.