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

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
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