sub

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

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

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

type KafkaProgress struct {
	Topic            string          `json:"topic"`
	PartitionOffsets map[int32]int64 `json:"partitionOffsets"`

	sync.Mutex
	// contains filtered or unexported fields
}

type NotificationInput interface {
	// GetName gets the name to locate the configuration in sync.toml file
	GetName() string
	// Initialize initializes the file store
	Initialize(configuration util.Configuration, prefix string) error
	ReceiveMessage() (key string, message *filer_pb.EventNotification, onSuccessFn func(), onFailureFn func(), err error)
}