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 {
	Indexer indexer.Config `yaml:"indexer"`
	API     api.Config     `yaml:"api"`
}

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, p *persistence.Indexer, c store.Store, grpcConn string, grpcOpts []grpc.DialOption) ([]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"
	ServiceTypeIndexer Type = indexer.ServiceType
	ServiceTypeAPI     Type = api.ServiceType
)