service

Documentation

Index

• type Config
  • func (c *Config) Validate() error
• type GRPCService
  • func CreateGRPCServices(ctx context.Context, log logrus.FieldLogger, cfg *Config, ...) ([]GRPCService, error)
• type RawMessage
  • func (r *RawMessage) Unmarshal(v interface{}) error
  • func (r *RawMessage) UnmarshalYAML(unmarshal func(interface{}) error) error
• type Type

Types

type Config

type Config struct {
	EventIngester eventingester.Config `yaml:"eventIngester"`
	Coordinator   coordinator.Config   `yaml:"coordinator"`
}

func (*Config) Validate

func (c *Config) Validate() error

type GRPCService

type GRPCService interface {
	Start(ctx context.Context, server *grpc.Server) error
	Stop(ctx context.Context) error
}

GRPCService is a service that implements a single gRPC service as defined in our Protobuf definition.

func CreateGRPCServices

func CreateGRPCServices(ctx context.Context, log logrus.FieldLogger, cfg *Config, clockDrift *time.Duration, p *persistence.Client, c store.Cache, g geoip.Provider) ([]GRPCService, error)

type RawMessage

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

func (*RawMessage) Unmarshal

func (r *RawMessage) Unmarshal(v interface{}) error

func (*RawMessage) UnmarshalYAML

func (r *RawMessage) UnmarshalYAML(unmarshal func(interface{}) error) error

type Type

type Type string

const (
	ServiceTypeUnknown       Type = "unknown"
	ServiceTypeEventIngester Type = eventingester.ServiceType
	ServiceTypeCoordinator   Type = coordinator.ServiceType
)