dwh

Documentation

Index

• Constants
• type Config
  • func NewConfig(path string) (*Config, error)
• type DWH
  • func NewDWH(ctx context.Context, cfg *Config, key *ecdsa.PrivateKey) (*DWH, error)
  • func (m *DWH) GetBlacklist(ctx context.Context, request *pb.BlacklistRequest) (*pb.BlacklistReply, error)
  • func (m *DWH) GetDealChangeRequests(ctx context.Context, request *pb.BigInt) (*pb.DealChangeRequestsReply, error)
  • func (m *DWH) GetDealConditions(ctx context.Context, request *pb.DealConditionsRequest) (*pb.DealConditionsReply, error)
  • func (m *DWH) GetDealDetails(ctx context.Context, request *pb.BigInt) (*pb.DWHDeal, error)
  • func (m *DWH) GetDeals(ctx context.Context, request *pb.DealsRequest) (*pb.DWHDealsReply, error)
  • func (m *DWH) GetMatchingOrders(ctx context.Context, request *pb.MatchingOrdersRequest) (*pb.DWHOrdersReply, error)
  • func (m *DWH) GetOrderDetails(ctx context.Context, request *pb.BigInt) (*pb.DWHOrder, error)
  • func (m *DWH) GetOrders(ctx context.Context, request *pb.OrdersRequest) (*pb.DWHOrdersReply, error)
  • func (m *DWH) GetProfileInfo(ctx context.Context, request *pb.EthID) (*pb.Profile, error)
  • func (m *DWH) GetProfiles(ctx context.Context, request *pb.ProfilesRequest) (*pb.ProfilesReply, error)
  • func (m *DWH) GetValidators(ctx context.Context, request *pb.ValidatorsRequest) (*pb.ValidatorsReply, error)
  • func (m *DWH) GetWorkers(ctx context.Context, request *pb.WorkersRequest) (*pb.WorkersReply, error)
  • func (m *DWH) Serve() error
  • func (m *DWH) Stop()
• type LoggingConfig
• type YAMLConfig

Constants

const (
	MaxLimit         = 200
	NumMaxBenchmarks = 128
)

const (
	CertificateName           = 1102
	CertificateCountry        = 1303
	MaxBenchmark       uint64 = 1 << 63
)

Types

type Config

type Config struct {
	Logging           LoggingConfig      `yaml:"logging"`
	GRPCListenAddr    string             `yaml:"grpc_address" default:"127.0.0.1:15021"`
	HTTPListenAddr    string             `yaml:"http_address" default:"127.0.0.1:15022"`
	Eth               accounts.EthConfig `yaml:"ethereum" required:"true"`
	Storage           *storageConfig     `yaml:"storage" required:"true"`
	Blockchain        *blockchain.Config `yaml:"blockchain"`
	MetricsListenAddr string             `yaml:"metrics_listen_addr" default:"127.0.0.1:14004"`
	ColdStart         bool               `yaml:"cold_start"`
	NumWorkers        int                `yaml:"num_workers" default:"64"`
}

func NewConfig

func NewConfig(path string) (*Config, error)

type DWH

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

func NewDWH

func NewDWH(ctx context.Context, cfg *Config, key *ecdsa.PrivateKey) (*DWH, error)

func (*DWH) GetBlacklist

func (m *DWH) GetBlacklist(ctx context.Context, request *pb.BlacklistRequest) (*pb.BlacklistReply, error)

func (*DWH) GetDealChangeRequests

func (m *DWH) GetDealChangeRequests(ctx context.Context, request *pb.BigInt) (*pb.DealChangeRequestsReply, error)

func (*DWH) GetDealConditions

func (m *DWH) GetDealConditions(ctx context.Context, request *pb.DealConditionsRequest) (*pb.DealConditionsReply, error)

func (*DWH) GetDealDetails

func (m *DWH) GetDealDetails(ctx context.Context, request *pb.BigInt) (*pb.DWHDeal, error)

func (*DWH) GetDeals

func (m *DWH) GetDeals(ctx context.Context, request *pb.DealsRequest) (*pb.DWHDealsReply, error)

func (*DWH) GetMatchingOrders

func (m *DWH) GetMatchingOrders(ctx context.Context, request *pb.MatchingOrdersRequest) (*pb.DWHOrdersReply, error)

func (*DWH) GetOrderDetails

func (m *DWH) GetOrderDetails(ctx context.Context, request *pb.BigInt) (*pb.DWHOrder, error)

func (*DWH) GetOrders

func (m *DWH) GetOrders(ctx context.Context, request *pb.OrdersRequest) (*pb.DWHOrdersReply, error)

func (*DWH) GetProfileInfo

func (m *DWH) GetProfileInfo(ctx context.Context, request *pb.EthID) (*pb.Profile, error)

func (*DWH) GetProfiles

func (m *DWH) GetProfiles(ctx context.Context, request *pb.ProfilesRequest) (*pb.ProfilesReply, error)

func (*DWH) GetValidators

func (m *DWH) GetValidators(ctx context.Context, request *pb.ValidatorsRequest) (*pb.ValidatorsReply, error)

func (*DWH) GetWorkers

func (m *DWH) GetWorkers(ctx context.Context, request *pb.WorkersRequest) (*pb.WorkersReply, error)

func (*DWH) Serve

func (m *DWH) Serve() error

func (*DWH) Stop

func (m *DWH) Stop()

type LoggingConfig

type LoggingConfig struct {
	Level *logging.Level `required:"true" default:"warn"`
}

type YAMLConfig

type YAMLConfig struct {
	Endpoint string `yaml:"endpoint" required:"false"`
}