outputhost

type AckID string

type Committer interface {
	// SetCommitLevel indicates that work up to and including the message specified by the sequence number and address
	// has been acknowledged. Not guaranteed to be persisted until a successful call to Flush()
	SetCommitLevel(l CommitterLevel)

	// SetReadLevel indicates that a particular message has been read. Metadata not guaranteed to be communicated/persisted
	// until a successful call to Flush()
	SetReadLevel(l CommitterLevel)

	// SetFinalLevel indicates that a particular level is the last that can possibly be read. Metadata not guaranteed
	// to be communicated/persisted until a successful call to Flush()
	SetFinalLevel(l CommitterLevel)

	// UnlockAndFlush copies accumulated commit/read state, unlocks the provided lock, and then commits
	// the levels to durable storage, e.g. Kafka offset storage or Cherami-Cassandra AckLevel storage
	UnlockAndFlush(l sync.Locker) error

	// GetCommitLevel receives the last value given to Commit()
	GetCommitLevel() (l CommitterLevel)

	// GetReadLevel receives the last value given to Read()
	GetReadLevel() (l CommitterLevel)
}

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

type KafkaCommitter struct {
	*sc.OffsetStash

	KafkaOffsetMetadata
	// contains filtered or unexported fields
}

type KafkaGroupMetadata struct {
	// Version is the version of this structure
	Version uint

	// CGUUID is the internal Cherami consumer group UUID that committed this offset
	CGUUID string

	// OutputHostUUID is the UUID of the Cherami Outputhost that committed this offset
	OutputHostUUID string
}

type KafkaMessageConverter func(kMsg *s.ConsumerMessage) (cMsg *store.ReadMessageContent)

type KafkaMessageConverterConfig struct {
	// Destination and ConsumerGroup are not needed currently, but may in the future
	// Destination *cherami.DestinationDescription
	// ConsumerGroup *cherami.ConsumerGroupDescription
	KafkaTopics  []string // optional: already contained in destination-description
	KafkaCluster string   // optional: already contained in destination-description
}

type KafkaMessageConverterFactory interface {
	GetConverter(cfg *KafkaMessageConverterConfig, log bark.Logger) KafkaMessageConverter
}

type KafkaOffsetMetadata struct {
	// Version is the version of this structure
	Version uint

	// CGUUID is the internal Cherami consumer group UUID that committed this offset
	CGUUID string

	// OutputHostUUID is the UUID of the Cherami Outputhost that committed this offset
	OutputHostUUID string

	// OutputHostStartTime is the time that the output host started
	OutputHostStartTime string

	// CommitterStartTime is the time that this committer was started
	CommitterStartTime string
}

type Notifier interface {
	// Register is the rotuine to register this connection on the notifier
	Register(id int, notifyCh chan NotifyMsg)

	// Unregister is the routine to unregister this connection from the notifier
	Unregister(id int)

	// Notify is the routine to send a notification on the appropriate channel
	Notify(id int, notifyMsg NotifyMsg)
}

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

type NotifyType int

type OutOptions struct {
	//CacheIdleTimeout
	CacheIdleTimeout time.Duration
	//KStreamFactory
	KStreamFactory KafkaMessageConverterFactory
}

type OutputCgConfig struct {
	// MessageCacheSize is used to configure the per CG cache size.
	// This is a string slice, where each entry is a tuple with the
	// destination/CG_name=value.
	// For example, we can ideally have two CGs for the same destination
	// with different size config as follows:
	// "/test/destination//test/cg_1=50,/test/destination//test/cg_2=100"
	MessageCacheSize []string `name:"messagecachesize" default:"/=10000"`

	// RedeliveryIntervalInMs is used to configure the per CG message redelivery interval.
	// Just like MessageCacheSize above
	RedeliveryIntervalInMs []string `name:"redeliveryIntervalInMs" default:"/=100"`
}

type OutputHost struct {
	common.SCommon
	// contains filtered or unexported fields
}

type Throttler interface {
	// SetBackoffCoefficient is the routine to set the backoff coefficient for the throttler
	SetBackoffCoefficient(backoffCoefficient float64)

	// SetMaxThrottleDuration is used to set the max duration to return for the throttler
	SetMaxThrottleDuration(max time.Duration)

	// SetMinThrottleDuration is used to set the min duration to return for the throttler
	SetMinThrottleDuration(min time.Duration)

	// GetCurrentSleepDuration returns the current duration for this throttler
	GetCurrentSleepDuration() time.Duration

	// GetNextSleepDuration returns the sleep duration based on the backoff coefficient
	GetNextSleepDuration() time.Duration

	// ResetSleepDuration resets the current sleep duration for this throttler
	ResetSleepDuration() time.Duration

	// IsCurrentSleepDurationAtMaximum tells whether the current sleep duration is maxed out
	IsCurrentSleepDurationAtMaximum() bool
}