index

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

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

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

type Option func(*Service) error

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