pulsarclient

Documentation

Overview

// Code generated by protoc-gen-go. DO NOT EDIT. // source: deal.proto

Index

• Constants
• func InitTokenPairMap(ctx sdk.Context, dexKeeper types.DexKeeper)
• func RegisterNewTokenPair(tokenPairID int64, tokenPairName string, marketServiceURL string, ...) (err error)
• type MatchResultMsg
  • func (*MatchResultMsg) Descriptor() ([]byte, []int)
  • func (m *MatchResultMsg) GetBizType() int32
  • func (m *MatchResultMsg) GetBrokerId() int32
  • func (m *MatchResultMsg) GetCreatedTime() int64
  • func (m *MatchResultMsg) GetEventId() int64
  • func (m *MatchResultMsg) GetEventType() int32
  • func (m *MatchResultMsg) GetInstrumentId() int64
  • func (m *MatchResultMsg) GetInstrumentName() string
  • func (m *MatchResultMsg) GetIsCalc() bool
  • func (m *MatchResultMsg) GetMarketId() int64
  • func (m *MatchResultMsg) GetMarketType() int32
  • func (m *MatchResultMsg) GetOppositeBrokerId() int32
  • func (m *MatchResultMsg) GetOppositeOrderId() uint64
  • func (m *MatchResultMsg) GetOppositeUserId() int64
  • func (m *MatchResultMsg) GetOrderId() uint64
  • func (m *MatchResultMsg) GetOrderSide() int32
  • func (m *MatchResultMsg) GetPrice() float64
  • func (m *MatchResultMsg) GetSize() float64
  • func (m *MatchResultMsg) GetTradeId() int64
  • func (m *MatchResultMsg) GetTradeside() int32
  • func (m *MatchResultMsg) GetUserId() int64
  • func (*MatchResultMsg) ProtoMessage()
  • func (m *MatchResultMsg) Reset()
  • func (m *MatchResultMsg) String() string
  • func (m *MatchResultMsg) XXX_DiscardUnknown()
  • func (m *MatchResultMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (dst *MatchResultMsg) XXX_Merge(src proto.Message)
  • func (m *MatchResultMsg) XXX_Size() int
  • func (m *MatchResultMsg) XXX_Unmarshal(b []byte) error
• type PulsarData
  • func NewPulsarData() *PulsarData
  • func (p PulsarData) BlockHeight() int64
  • func (p PulsarData) DataType() types.StreamDataKind
  • func (p *PulsarData) SetData(ctx sdk.Context, orderKeeper types.OrderKeeper, cache *common.Cache)
• type PulsarProducer
  • func NewPulsarProducer(url string, cfg *appCfg.StreamConfig, logger log.Logger, asyncErrs *chan error) *PulsarProducer
  • func (p *PulsarProducer) RefreshMarketIDMap(data *PulsarData, logger log.Logger) error
  • func (p *PulsarProducer) SendAllMsg(data *PulsarData, logger log.Logger) (map[string]int, error)

Constants

const (
	MarketCalServiceDexSpotBizType    = int32(1001)
	MarketCalServiceDexSpotMarketType = int32(1)
)

Functions

func InitTokenPairMap

func InitTokenPairMap(ctx sdk.Context, dexKeeper types.DexKeeper)

func RegisterNewTokenPair

func RegisterNewTokenPair(tokenPairID int64, tokenPairName string, marketServiceURL string, logger log.Logger) (err error)

Types

type MatchResultMsg

type MatchResultMsg struct {
	BizType              *int32   `protobuf:"varint,1,req,name=bizType" json:"bizType,omitempty"`
	MarketId             *int64   `protobuf:"varint,2,req,name=marketId" json:"marketId,omitempty"`
	MarketType           *int32   `protobuf:"varint,3,req,name=marketType" json:"marketType,omitempty"`
	Size                 *float64 `protobuf:"fixed64,4,req,name=size" json:"size,omitempty"`
	Price                *float64 `protobuf:"fixed64,5,req,name=price" json:"price,omitempty"`
	CreatedTime          *int64   `protobuf:"varint,6,req,name=createdTime" json:"createdTime,omitempty"`
	UserId               *int64   `protobuf:"varint,7,opt,name=userId" json:"userId,omitempty"`
	BrokerId             *int32   `protobuf:"varint,8,opt,name=brokerId" json:"brokerId,omitempty"`
	OrderId              *uint64  `protobuf:"fixed64,9,opt,name=orderId" json:"orderId,omitempty"`
	InstrumentId         *int64   `protobuf:"varint,10,opt,name=instrument_id,json=instrumentId" json:"instrument_id,omitempty"`
	InstrumentName       *string  `protobuf:"bytes,11,opt,name=instrument_name,json=instrumentName" json:"instrument_name,omitempty"`
	TradeId              *int64   `protobuf:"varint,12,opt,name=tradeId" json:"tradeId,omitempty"`
	Tradeside            *int32   `protobuf:"varint,13,opt,name=tradeside" json:"tradeside,omitempty"`
	OppositeUserId       *int64   `protobuf:"varint,14,opt,name=oppositeUserId" json:"oppositeUserId,omitempty"`
	OppositeBrokerId     *int32   `protobuf:"varint,15,opt,name=oppositeBrokerId" json:"oppositeBrokerId,omitempty"`
	OppositeOrderId      *uint64  `protobuf:"fixed64,16,opt,name=oppositeOrderId" json:"oppositeOrderId,omitempty"`
	OrderSide            *int32   `protobuf:"varint,17,opt,name=orderSide" json:"orderSide,omitempty"`
	EventId              *int64   `protobuf:"varint,18,opt,name=eventId" json:"eventId,omitempty"`
	EventType            *int32   `protobuf:"varint,19,opt,name=eventType" json:"eventType,omitempty"`
	IsCalc               *bool    `protobuf:"varint,20,req,name=isCalc" json:"isCalc,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MatchResultMsg) Descriptor

func (*MatchResultMsg) Descriptor() ([]byte, []int)

func (*MatchResultMsg) GetBizType

func (m *MatchResultMsg) GetBizType() int32

func (*MatchResultMsg) GetBrokerId

func (m *MatchResultMsg) GetBrokerId() int32

func (*MatchResultMsg) GetCreatedTime

func (m *MatchResultMsg) GetCreatedTime() int64

func (*MatchResultMsg) GetEventId

func (m *MatchResultMsg) GetEventId() int64

func (*MatchResultMsg) GetEventType

func (m *MatchResultMsg) GetEventType() int32

func (*MatchResultMsg) GetInstrumentId

func (m *MatchResultMsg) GetInstrumentId() int64

func (*MatchResultMsg) GetInstrumentName

func (m *MatchResultMsg) GetInstrumentName() string

func (*MatchResultMsg) GetIsCalc

func (m *MatchResultMsg) GetIsCalc() bool

func (*MatchResultMsg) GetMarketId

func (m *MatchResultMsg) GetMarketId() int64

func (*MatchResultMsg) GetMarketType

func (m *MatchResultMsg) GetMarketType() int32

func (*MatchResultMsg) GetOppositeBrokerId

func (m *MatchResultMsg) GetOppositeBrokerId() int32

func (*MatchResultMsg) GetOppositeOrderId

func (m *MatchResultMsg) GetOppositeOrderId() uint64

func (*MatchResultMsg) GetOppositeUserId

func (m *MatchResultMsg) GetOppositeUserId() int64

func (*MatchResultMsg) GetOrderId

func (m *MatchResultMsg) GetOrderId() uint64

func (*MatchResultMsg) GetOrderSide

func (m *MatchResultMsg) GetOrderSide() int32

func (*MatchResultMsg) GetPrice

func (m *MatchResultMsg) GetPrice() float64

func (*MatchResultMsg) GetSize

func (m *MatchResultMsg) GetSize() float64

func (*MatchResultMsg) GetTradeId

func (m *MatchResultMsg) GetTradeId() int64

func (*MatchResultMsg) GetTradeside

func (m *MatchResultMsg) GetTradeside() int32

func (*MatchResultMsg) GetUserId

func (m *MatchResultMsg) GetUserId() int64

func (*MatchResultMsg) ProtoMessage

func (*MatchResultMsg) ProtoMessage()

func (*MatchResultMsg) Reset

func (m *MatchResultMsg) Reset()

func (*MatchResultMsg) String

func (m *MatchResultMsg) String() string

func (*MatchResultMsg) XXX_DiscardUnknown

func (m *MatchResultMsg) XXX_DiscardUnknown()

func (*MatchResultMsg) XXX_Marshal

func (m *MatchResultMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MatchResultMsg) XXX_Merge

func (dst *MatchResultMsg) XXX_Merge(src proto.Message)

func (*MatchResultMsg) XXX_Size

func (m *MatchResultMsg) XXX_Size() int

func (*MatchResultMsg) XXX_Unmarshal

func (m *MatchResultMsg) XXX_Unmarshal(b []byte) error

type PulsarData

type PulsarData struct {
	Height int64
	// contains filtered or unexported fields
}

func NewPulsarData

func NewPulsarData() *PulsarData

func (PulsarData) BlockHeight

func (p PulsarData) BlockHeight() int64

func (PulsarData) DataType

func (p PulsarData) DataType() types.StreamDataKind

func (*PulsarData) SetData

func (p *PulsarData) SetData(ctx sdk.Context, orderKeeper types.OrderKeeper, cache *common.Cache)

nolint

type PulsarProducer

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

func NewPulsarProducer

func NewPulsarProducer(url string, cfg *appCfg.StreamConfig, logger log.Logger, asyncErrs *chan error) *PulsarProducer

func (*PulsarProducer) RefreshMarketIDMap

func (p *PulsarProducer) RefreshMarketIDMap(data *PulsarData, logger log.Logger) error

func (*PulsarProducer) SendAllMsg

func (p *PulsarProducer) SendAllMsg(data *PulsarData, logger log.Logger) (map[string]int, error)