Documentation ¶
Index ¶
- Constants
- Variables
- func InitLogging(level string) error
- type App
- type CassandraProducer
- type Executor
- func (e *Executor) Disconnected(executor.ExecutorDriver)
- func (e *Executor) Error(driver executor.ExecutorDriver, message string)
- func (e *Executor) FrameworkMessage(driver executor.ExecutorDriver, message string)
- func (e *Executor) KillTask(driver executor.ExecutorDriver, id *mesos.TaskID)
- func (e *Executor) LaunchTask(driver executor.ExecutorDriver, task *mesos.TaskInfo)
- func (e *Executor) Registered(driver executor.ExecutorDriver, executor *mesos.ExecutorInfo, ...)
- func (e *Executor) Reregistered(driver executor.ExecutorDriver, slave *mesos.SlaveInfo)
- func (e *Executor) Shutdown(driver executor.ExecutorDriver)
- type KafkaConsumer
Constants ¶
View Source
const (
CassandraRetryTimeout = 2 * time.Second
)
Variables ¶
View Source
var Logger log.LoggerInterface
Functions ¶
func InitLogging ¶
Types ¶
type App ¶
type App struct {
// contains filtered or unexported fields
}
func NewApp ¶
func NewApp(consumer *KafkaConsumer, producer *CassandraProducer) *App
type CassandraProducer ¶
type CassandraProducer struct {
// contains filtered or unexported fields
}
func NewCassandraProducer ¶
func NewCassandraProducer(cluster string, keyspace string, schema string) *CassandraProducer
func (*CassandraProducer) Start ¶
func (cp *CassandraProducer) Start(messages <-chan *gonzo.MessageAndMetadata) error
type Executor ¶
type Executor struct {
// contains filtered or unexported fields
}
func NewExecutor ¶
func (*Executor) Disconnected ¶
func (e *Executor) Disconnected(executor.ExecutorDriver)
func (*Executor) FrameworkMessage ¶
func (e *Executor) FrameworkMessage(driver executor.ExecutorDriver, message string)
func (*Executor) KillTask ¶
func (e *Executor) KillTask(driver executor.ExecutorDriver, id *mesos.TaskID)
func (*Executor) LaunchTask ¶
func (e *Executor) LaunchTask(driver executor.ExecutorDriver, task *mesos.TaskInfo)
func (*Executor) Registered ¶
func (e *Executor) Registered(driver executor.ExecutorDriver, executor *mesos.ExecutorInfo, framework *mesos.FrameworkInfo, slave *mesos.SlaveInfo)
func (*Executor) Reregistered ¶
func (e *Executor) Reregistered(driver executor.ExecutorDriver, slave *mesos.SlaveInfo)
func (*Executor) Shutdown ¶
func (e *Executor) Shutdown(driver executor.ExecutorDriver)
type KafkaConsumer ¶
type KafkaConsumer struct {
// contains filtered or unexported fields
}
func NewKafkaConsumer ¶
func NewKafkaConsumer(brokerList []string, topics []string, partitions []int32) *KafkaConsumer
func (*KafkaConsumer) Start ¶
func (kc *KafkaConsumer) Start() (<-chan *gonzo.MessageAndMetadata, error)
Click to show internal directories.
Click to hide internal directories.