pkg

Documentation

Index

• func GetBynoGameCsListings() (*[]domain.ByNoGameCsItem, error)
• type CronClient
  • func NewCronClient() CronClient
• type KafkaWriter
  • func NewKafkaWriter(topic, username, password, url string) *KafkaWriter
  • func (kw *KafkaWriter) Close() error
  • func (kw *KafkaWriter) WriteMessages(ctx context.Context, messages ...kafka.Message) error

Functions

func GetBynoGameCsListings

func GetBynoGameCsListings() (*[]domain.ByNoGameCsItem, error)

Types

type CronClient

type CronClient interface {
	Start()
	Schedule(interval string, fn func())
	Stop()
}

func NewCronClient

func NewCronClient() CronClient

type KafkaWriter

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

func NewKafkaWriter

func NewKafkaWriter(topic, username, password, url string) *KafkaWriter

func (*KafkaWriter) Close

func (kw *KafkaWriter) Close() error

func (*KafkaWriter) WriteMessages

func (kw *KafkaWriter) WriteMessages(ctx context.Context, messages ...kafka.Message) error