Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrEmptyStreamName = errors.New("kinesis stream name can't be empty")
)
Functions ¶
func BuildStore ¶
func BuildStore(cfg StoreConfig) (consumer.Store, error)
Types ¶
type LoggerAdapter ¶ added in v0.3.0
type LoggerAdapter struct {
// contains filtered or unexported fields
}
func (*LoggerAdapter) Log ¶ added in v0.3.0
func (l *LoggerAdapter) Log(args ...interface{})
type SessionConfig ¶
type StoreConfig ¶
type StoreConfig struct { Driver string `default:"memory"` AppName string `split_words:"true" default:"watchops_consumer"` Redis struct { Address string Password string Username string DB int } Postgres struct { TableName string `split_words:"true"` DSN string } MySQL struct { TableName string `split_words:"true"` DSN string } }
type Subscriber ¶
type Subscriber struct {
// contains filtered or unexported fields
}
Subscriber is the kinesis subscriber.
func NewSubscriber ¶
func NewSubscriber(ctx context.Context, cfg SessionConfig) (*Subscriber, error)
NewSubscriber creates a new instance of Subscriber.
Click to show internal directories.
Click to hide internal directories.