services

package
v0.72.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 7, 2023 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrMissingProposalOrPartyFilter = errors.New("missing proposal or party filter")

Functions

This section is empty.

Types

type Accounts

type Accounts struct {
	*subscribers.Base
	// contains filtered or unexported fields
}

func NewAccounts

func NewAccounts(ctx context.Context) *Accounts

func (*Accounts) List

func (a *Accounts) List(party, market string) []*coreapipb.Account

func (*Accounts) Push

func (a *Accounts) Push(evts ...events.Event)

func (*Accounts) Types

func (a *Accounts) Types() []events.Type

type Assets

type Assets struct {
	*subscribers.Base
	// contains filtered or unexported fields
}

func NewAssets

func NewAssets(ctx context.Context) (assets *Assets)

func (*Assets) List

func (a *Assets) List(assetID string) []*vegapb.Asset

func (*Assets) Push

func (a *Assets) Push(evts ...events.Event)

func (*Assets) Types

func (a *Assets) Types() []events.Type

type Delegations

type Delegations struct {
	*subscribers.Base
	// contains filtered or unexported fields
}

Delegations is a storage for keeping track of delegation state from delegation balance update events.

func NewDelegations

func NewDelegations(ctx context.Context) (delegations *Delegations)

func (*Delegations) List

func (d *Delegations) List(party, node, epoch string) []*pb.Delegation

func (*Delegations) Push

func (d *Delegations) Push(evts ...events.Event)

func (*Delegations) Types

func (d *Delegations) Types() []events.Type
type Links []eventspb.StakeLinking

func (Links) IntoPointers

func (l Links) IntoPointers() []*eventspb.StakeLinking

type Markets

type Markets struct {
	*subscribers.Base
	// contains filtered or unexported fields
}

func NewMarkets

func NewMarkets(ctx context.Context) (markets *Markets)

func (*Markets) List

func (m *Markets) List(marketID string) []*vegapb.Market

func (*Markets) Push

func (m *Markets) Push(evts ...events.Event)

func (*Markets) Types

func (m *Markets) Types() []events.Type

type MarketsData

type MarketsData struct {
	*subscribers.Base
	// contains filtered or unexported fields
}

func NewMarketsData

func NewMarketsData(ctx context.Context) (marketsData *MarketsData)

func (*MarketsData) List

func (m *MarketsData) List(marketID string) []*vegapb.MarketData

func (*MarketsData) Push

func (m *MarketsData) Push(evts ...events.Event)

func (*MarketsData) Types

func (m *MarketsData) Types() []events.Type

type NetLimits

type NetLimits struct {
	*subscribers.Base
	// contains filtered or unexported fields
}

func NewNetLimits

func NewNetLimits(ctx context.Context) (netLimits *NetLimits)

func (*NetLimits) Get

func (n *NetLimits) Get() *vega.NetworkLimits

func (*NetLimits) Push

func (n *NetLimits) Push(evts ...events.Event)

func (*NetLimits) Types

func (n *NetLimits) Types() []events.Type

type NetParams

type NetParams struct {
	*subscribers.Base
	// contains filtered or unexported fields
}

func NewNetParams

func NewNetParams(ctx context.Context) (netParams *NetParams)

func (*NetParams) List

func (a *NetParams) List(netParamsID string) []*vegapb.NetworkParameter

func (*NetParams) Push

func (a *NetParams) Push(evts ...events.Event)

func (*NetParams) Types

func (a *NetParams) Types() []events.Type

type Parties

type Parties struct {
	*subscribers.Base
	// contains filtered or unexported fields
}

func NewParties

func NewParties(ctx context.Context) (parties *Parties)

func (*Parties) List

func (a *Parties) List() []*vegapb.Party

func (*Parties) Push

func (a *Parties) Push(evts ...events.Event)

func (*Parties) Types

func (a *Parties) Types() []events.Type

type PartiesStake

type PartiesStake struct {
	*subscribers.Base
	// contains filtered or unexported fields
}

func NewPartiesStake

func NewPartiesStake(ctx context.Context, log *logging.Logger) (svc *PartiesStake)

func (*PartiesStake) List

func (p *PartiesStake) List(party string) []*coreapipb.PartyStake

func (*PartiesStake) Push

func (p *PartiesStake) Push(evts ...events.Event)

func (*PartiesStake) Types

func (p *PartiesStake) Types() []events.Type

type Proposals

type Proposals struct {
	*subscribers.Base
	// contains filtered or unexported fields
}

func NewProposals

func NewProposals(ctx context.Context) (proposals *Proposals)

func (*Proposals) List

func (p *Proposals) List(proposal, party string) []*vegapb.Proposal

func (*Proposals) Push

func (p *Proposals) Push(evts ...events.Event)

func (*Proposals) Types

func (p *Proposals) Types() []events.Type

type StakeLinkingEvent

type StakeLinkingEvent interface {
	events.Event
	StakeLinking() eventspb.StakeLinking
}

type Validators

type Validators struct {
	*subscribers.Base
	// contains filtered or unexported fields
}

func NewValidators

func NewValidators(ctx context.Context) (assets *Validators)

func (*Validators) List

func (a *Validators) List() []*eventspb.ValidatorUpdate

func (*Validators) Push

func (a *Validators) Push(evts ...events.Event)

func (*Validators) Types

func (a *Validators) Types() []events.Type

type Votes

type Votes struct {
	*subscribers.Base
	// contains filtered or unexported fields
}

func NewVotes

func NewVotes(ctx context.Context) (votes *Votes)

func (*Votes) List

func (v *Votes) List(proposal, party string) ([]*vegapb.Vote, error)

func (*Votes) Push

func (v *Votes) Push(evts ...events.Event)

func (*Votes) Types

func (v *Votes) Types() []events.Type

Jump to

Keyboard shortcuts

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