dwh

package

v0.4.31 Latest Latest Go to latest Published: May 15, 2020 License: GPL-3.0 Imports: 34 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/sonm-io/core

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type DWH
- func NewDWH(ctx context.Context, cfg *DWHConfig, key *ecdsa.PrivateKey) (*DWH, error)
type DWHConfig
- func NewDWHConfig(path string) (*DWHConfig, error)
type L1Processor
- func NewL1Processor(ctx context.Context, cfg *L1ProcessorConfig) (*L1Processor, error)
- func (m *L1Processor) Start() error
- func (m *L1Processor) Stop()
type L1ProcessorConfig
type YAMLConfig

Constants ¶

View Source

const (
	MaxLimit         = 200
	NumMaxBenchmarks = 128
)

View Source

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

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type DWH ¶

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

func NewDWH ¶

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

func (*DWH) GetBlacklist ¶

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

func (*DWH) GetBlacklistsContainingUser ¶

func (m *DWH) GetBlacklistsContainingUser(ctx context.Context, r *sonm.BlacklistRequest) (*sonm.BlacklistsContainingUserReply, error)

func (*DWH) GetChangeRequests ¶ added in v0.4.10

func (m *DWH) GetChangeRequests(ctx context.Context, request *sonm.ChangeRequestsRequest) (*sonm.DealChangeRequestsReply, error)

func (*DWH) GetDealChangeRequests ¶

func (m *DWH) GetDealChangeRequests(ctx context.Context, dealID *sonm.BigInt) (*sonm.DealChangeRequestsReply, error)

func (*DWH) GetDealConditions ¶

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

func (*DWH) GetDealDetails ¶

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

func (*DWH) GetDeals ¶

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

func (*DWH) GetMatchingOrders ¶

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

func (*DWH) GetOrderDetails ¶

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

func (*DWH) GetOrders ¶

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

func (*DWH) GetOrdersByIDs ¶ added in v0.4.12

func (m *DWH) GetOrdersByIDs(ctx context.Context, request *sonm.OrdersByIDsRequest) (*sonm.DWHOrdersReply, error)

func (*DWH) GetProfileInfo ¶

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

func (*DWH) GetProfiles ¶

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

func (*DWH) GetStats ¶ added in v0.4.12

func (m *DWH) GetStats(ctx context.Context, request *sonm.Empty) (*sonm.DWHStatsReply, error)

func (*DWH) GetValidators ¶

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

func (*DWH) GetWorkers ¶

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

func (*DWH) Serve ¶

func (m *DWH) Serve() error

func (*DWH) Stop ¶

func (m *DWH) Stop()

type DWHConfig ¶ added in v0.4.8

type DWHConfig struct {
	Logging           logging.Config     `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" required:"true"`
	MetricsListenAddr string             `yaml:"metrics_listen_addr" default:"127.0.0.1:14004"`
	ColdStart         bool               `yaml:"cold_start"`
	NumWorkers        int                `yaml:"num_workers" default:"64"`
	Debug             *debug.Config      `yaml:"debug"`
}

func NewDWHConfig ¶ added in v0.4.8

func NewDWHConfig(path string) (*DWHConfig, error)

type L1Processor ¶ added in v0.4.8

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

func NewL1Processor ¶ added in v0.4.8

func NewL1Processor(ctx context.Context, cfg *L1ProcessorConfig) (*L1Processor, error)

func (*L1Processor) Start ¶ added in v0.4.8

func (m *L1Processor) Start() error

func (*L1Processor) Stop ¶ added in v0.4.8

func (m *L1Processor) Stop()

type L1ProcessorConfig ¶ added in v0.4.8

type L1ProcessorConfig struct {
	Storage    *storageConfig
	Blockchain *blockchain.Config
	NumWorkers int
	ColdStart  bool
}

type YAMLConfig ¶

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL