index

Documentation

Index

• type BulkIndex
• type Metrics
• type NatsConfig
• type Option
  • func SetBulkIndexer(bi esutil.BulkIndexer, direct bool) Option
  • func SetNatsConfiguration(ncfg *NatsConfig) Option
  • func WithDefaultMessageHandle() Option
• type Service
  • func NewService(options ...Option) (*Service, error)
  • func (s *Service) BulkIndexStats() esutil.BulkIndexerStats
  • func (s *Service) Metrics() Metrics
  • func (s *Service) Publish(ctx context.Context, messages ...*domainpb.IndexMessage) error
  • func (s *Service) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (s *Service) Shutdown(ctx context.Context) error
  • func (s *Service) Start(ctx context.Context, workers int) error

Types

type BulkIndex

type BulkIndex interface {
	Publish(ctx context.Context, message ...*domainpb.IndexMessage) error
}

type Metrics

type Metrics struct {
	Nats struct {
		Published uint64
		Consumed  uint64
		Failed    uint64
	}
	Index struct {
		Successful uint64
		Failed     uint64
	}
	// contains filtered or unexported fields
}

type NatsConfig

type NatsConfig struct {
	Conn         stan.Conn
	SubjectID    string
	ClusterID    string
	ClientID     string
	DurableName  string
	DurableQueue string
}

type Option

type Option func(*Service) error

func SetBulkIndexer

func SetBulkIndexer(bi esutil.BulkIndexer, direct bool) Option

func SetNatsConfiguration

func SetNatsConfiguration(ncfg *NatsConfig) Option

func WithDefaultMessageHandle

func WithDefaultMessageHandle() Option

type Service

type Service struct {
	MsgHandler func(ctx context.Context, m *domainpb.IndexMessage) error
	// contains filtered or unexported fields
}

func NewService

func NewService(options ...Option) (*Service, error)

func (*Service) BulkIndexStats

func (s *Service) BulkIndexStats() esutil.BulkIndexerStats

func (*Service) Metrics

func (s *Service) Metrics() Metrics

func (*Service) Publish

func (s *Service) Publish(ctx context.Context, messages ...*domainpb.IndexMessage) error

func (*Service) ServeHTTP

func (s *Service) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*Service) Shutdown

func (s *Service) Shutdown(ctx context.Context) error

func (*Service) Start

func (s *Service) Start(ctx context.Context, workers int) error