config

Documentation

Index

• type Config
  • func New(opts ...OptionFunc) (*Config, error)
• type OptionFunc
  • func WithAddrs(addrs []string) OptionFunc
  • func WithAgentEnabled(enabled bool) OptionFunc
  • func WithAgentOpts(opts *agent.Opts) OptionFunc
  • func WithCheckIndexInterval(s string) OptionFunc
  • func WithCreateIndexThreshold(n uint) OptionFunc
  • func WithGRPCHost(host string) OptionFunc
  • func WithGRPCPort(port uint) OptionFunc
  • func WithInsertDataInterceptor(idi *lua.LFunction) OptionFunc
  • func WithReplicas(n uint) OptionFunc
  • func WithSearchQueryInterceptor(sqi *lua.LFunction) OptionFunc
  • func WithSearchResultInterceptor(sri *lua.LFunction) OptionFunc

Types

type Config

type Config struct {
	AgentEnabled bool
	AgentOpts    *agent.Opts

	Addrs    []string
	GRPCHost string
	GRPCPort int

	Replicas             int
	CheckIndexInterval   time.Duration
	CreateIndexThreshold int

	SearchResultInterceptor *lua.LFunction
	SearchQueryInterceptor  *lua.LFunction
	InsertDataInterceptor   *lua.LFunction
}

func New

func New(opts ...OptionFunc) (*Config, error)

type OptionFunc

type OptionFunc func(c *Config) error

func WithAddrs

func WithAddrs(addrs []string) OptionFunc

func WithAgentEnabled

func WithAgentEnabled(enabled bool) OptionFunc

func WithAgentOpts

func WithAgentOpts(opts *agent.Opts) OptionFunc

func WithCheckIndexInterval

func WithCheckIndexInterval(s string) OptionFunc

func WithCreateIndexThreshold

func WithCreateIndexThreshold(n uint) OptionFunc

func WithGRPCHost

func WithGRPCHost(host string) OptionFunc

func WithGRPCPort

func WithGRPCPort(port uint) OptionFunc

func WithInsertDataInterceptor

func WithInsertDataInterceptor(idi *lua.LFunction) OptionFunc

func WithReplicas

func WithReplicas(n uint) OptionFunc

func WithSearchQueryInterceptor

func WithSearchQueryInterceptor(sqi *lua.LFunction) OptionFunc

func WithSearchResultInterceptor

func WithSearchResultInterceptor(sri *lua.LFunction) OptionFunc