service

Documentation

Overview

Package service manages the main logic of server.

Package service

Package service

Index

• type Indexer
  • func New(opts ...Option) (idx Indexer, err error)
• type Option
  • func WithAgentName(name string) Option
  • func WithAgentOptions(opts ...grpc.Option) Option
  • func WithAgentPort(port int) Option
  • func WithAgentServiceDNSARecord(a string) Option
  • func WithDiscoverDuration(dur string) Option
  • func WithDiscovererAddr(addr string) Option
  • func WithDiscovererClient(client grpc.Client) Option
  • func WithDiscovererHostPort(host string, port int) Option
  • func WithErrGroup(eg errgroup.Group) Option
  • func WithIndexingConcurrency(c int) Option
  • func WithIndexingDuration(dur string) Option
  • func WithIndexingDurationLimit(dur string) Option

Types

type Indexer

type Indexer interface {
	Start(ctx context.Context) (<-chan error, error)
	UUIDs(context.Context) []string
	UncommittedUUIDs() []string
	IsIndexing() bool
}

func New

func New(opts ...Option) (idx Indexer, err error)

type Option

type Option func(i *index) error

func WithAgentName

func WithAgentName(name string) Option

func WithAgentOptions

func WithAgentOptions(opts ...grpc.Option) Option

func WithAgentPort

func WithAgentPort(port int) Option

func WithAgentServiceDNSARecord

func WithAgentServiceDNSARecord(a string) Option

func WithDiscoverDuration

func WithDiscoverDuration(dur string) Option

func WithDiscovererAddr

func WithDiscovererAddr(addr string) Option

func WithDiscovererClient

func WithDiscovererClient(client grpc.Client) Option

func WithDiscovererHostPort

func WithDiscovererHostPort(host string, port int) Option

func WithErrGroup

func WithErrGroup(eg errgroup.Group) Option

func WithIndexingConcurrency

func WithIndexingConcurrency(c int) Option

func WithIndexingDuration

func WithIndexingDuration(dur string) Option

func WithIndexingDurationLimit

func WithIndexingDurationLimit(dur string) Option