services

Documentation

Index

• Variables
• type Accounts
  • func NewAccounts(ctx context.Context) *Accounts
  • func (a *Accounts) List(party, market string) []*coreapipb.Account
  • func (a *Accounts) Push(evts ...events.Event)
  • func (a *Accounts) Types() []events.Type
• type Assets
  • func NewAssets(ctx context.Context) (assets *Assets)
  • func (a *Assets) List(assetID string) []*vegapb.Asset
  • func (a *Assets) Push(evts ...events.Event)
  • func (a *Assets) Types() []events.Type
• type Delegations
  • func NewDelegations(ctx context.Context) (delegations *Delegations)
  • func (d *Delegations) List(party, node, epoch string) []*pb.Delegation
  • func (d *Delegations) Push(evts ...events.Event)
  • func (d *Delegations) Types() []events.Type
• type Links
  • func (l Links) IntoPointers() []*eventspb.StakeLinking
• type Markets
  • func NewMarkets(ctx context.Context) (markets *Markets)
  • func (m *Markets) List(marketID string) []*vegapb.Market
  • func (m *Markets) Push(evts ...events.Event)
  • func (m *Markets) Types() []events.Type
• type MarketsData
  • func NewMarketsData(ctx context.Context) (marketsData *MarketsData)
  • func (m *MarketsData) List(marketID string) []*vegapb.MarketData
  • func (m *MarketsData) Push(evts ...events.Event)
  • func (m *MarketsData) Types() []events.Type
• type NetLimits
  • func NewNetLimits(ctx context.Context) (netLimits *NetLimits)
  • func (n *NetLimits) Get() *vega.NetworkLimits
  • func (n *NetLimits) Push(evts ...events.Event)
  • func (n *NetLimits) Types() []events.Type
• type NetParams
  • func NewNetParams(ctx context.Context) (netParams *NetParams)
  • func (a *NetParams) List(netParamsID string) []*vegapb.NetworkParameter
  • func (a *NetParams) Push(evts ...events.Event)
  • func (a *NetParams) Types() []events.Type
• type Parties
  • func NewParties(ctx context.Context) (parties *Parties)
  • func (a *Parties) List() []*vegapb.Party
  • func (a *Parties) Push(evts ...events.Event)
  • func (a *Parties) Types() []events.Type
• type PartiesStake
  • func NewPartiesStake(ctx context.Context, log *logging.Logger) (svc *PartiesStake)
  • func (p *PartiesStake) List(party string) []*coreapipb.PartyStake
  • func (p *PartiesStake) Push(evts ...events.Event)
  • func (p *PartiesStake) Types() []events.Type
• type Proposals
  • func NewProposals(ctx context.Context) (proposals *Proposals)
  • func (p *Proposals) List(proposal, party string) []*vegapb.Proposal
  • func (p *Proposals) Push(evts ...events.Event)
  • func (p *Proposals) Types() []events.Type
• type StakeLinkingEvent
• type Validators
  • func NewValidators(ctx context.Context) (assets *Validators)
  • func (a *Validators) List() []*eventspb.ValidatorUpdate
  • func (a *Validators) Push(evts ...events.Event)
  • func (a *Validators) Types() []events.Type
• type Votes
  • func NewVotes(ctx context.Context) (votes *Votes)
  • func (v *Votes) List(proposal, party string) ([]*vegapb.Vote, error)
  • func (v *Votes) Push(evts ...events.Event)
  • func (v *Votes) Types() []events.Type

Variables

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

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

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