sub

Documentation

Index

• Variables
• type AwsSqsInput
  • func (k *AwsSqsInput) GetName() string
  • func (k *AwsSqsInput) Initialize(configuration util.Configuration, prefix string) error
  • func (k *AwsSqsInput) ReceiveMessage() (key string, message *filer_pb.EventNotification, onSuccessFn func(), ...)
• type GooglePubSubInput
  • func (k *GooglePubSubInput) GetName() string
  • func (k *GooglePubSubInput) Initialize(configuration util.Configuration, prefix string) error
  • func (k *GooglePubSubInput) ReceiveMessage() (key string, message *filer_pb.EventNotification, onSuccessFn func(), ...)
• type KafkaInput
  • func (k *KafkaInput) GetName() string
  • func (k *KafkaInput) Initialize(configuration util.Configuration, prefix string) error
  • func (k *KafkaInput) ReceiveMessage() (key string, message *filer_pb.EventNotification, onSuccessFn func(), ...)
• type KafkaProgress
• type NotificationInput

Variables

var (
	NotificationInputs []NotificationInput
)

Types

type AwsSqsInput

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

func (*AwsSqsInput) GetName

func (k *AwsSqsInput) GetName() string

func (*AwsSqsInput) Initialize

func (k *AwsSqsInput) Initialize(configuration util.Configuration, prefix string) error

func (*AwsSqsInput) ReceiveMessage

func (k *AwsSqsInput) ReceiveMessage() (key string, message *filer_pb.EventNotification, onSuccessFn func(), onFailureFn func(), err error)

type GooglePubSubInput

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

func (*GooglePubSubInput) GetName

func (k *GooglePubSubInput) GetName() string

func (*GooglePubSubInput) Initialize

func (k *GooglePubSubInput) Initialize(configuration util.Configuration, prefix string) error

func (*GooglePubSubInput) ReceiveMessage

func (k *GooglePubSubInput) ReceiveMessage() (key string, message *filer_pb.EventNotification, onSuccessFn func(), onFailureFn func(), err error)

type KafkaInput

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

func (*KafkaInput) GetName

func (k *KafkaInput) GetName() string

func (*KafkaInput) Initialize

func (k *KafkaInput) Initialize(configuration util.Configuration, prefix string) error

func (*KafkaInput) ReceiveMessage

func (k *KafkaInput) ReceiveMessage() (key string, message *filer_pb.EventNotification, onSuccessFn func(), onFailureFn func(), err error)

type KafkaProgress

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

	sync.Mutex
	// contains filtered or unexported fields
}

type NotificationInput

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)
}