quotes

Apr 12, 2024

Changes in this version

type Snapshot

+ func (this *Snapshot) DetectBiddingPhase() (head, tail bool)

Jan 27, 2024

Changes in this version

type StdApi

+ func (this *StdApi) AcquireAddress() *Server

+ func (this *StdApi) ReleaseAddress(srv *Server)

Jan 22, 2024

Changes in this version

+ var ErrInvalidServerAddress = errors.New("invalid server address")

+ var ErrTimeOut = exception.New(1, "connect timeout")

Jan 22, 2024

Changes in this version

type AllServers

+ func ProfileBestIPList() *AllServers

type ConnPool

+ func (p *ConnPool) GetMaxIdleCount() int

type Server

+ func (s Server) String() string

type StdApi

+ Servers []Server

+ func (this *StdApi) Acquire() Server

+ func (this *StdApi) GetMaxIdleCount() int

+ func (this *StdApi) Len() int

+ func (this *StdApi) Release(srv Server)

Jan 11, 2024

Changes in this version

type TickTransaction

+ Amount float64

Dec 25, 2023

Changes in this version

+ var ExtensionServerList = []Server

+ var StandardServerList = []Server

type Server

+ Source string

Dec 23, 2023

Changes in this version

+ var ExtensionServer = []Server

+ var NumberOfServers int = POOL_MAX

+ var ResourcesPath = "resources"

+ var StandardServer = []Server

type StdApi

+ func (this *StdApi) NumOfServers() int

Dec 17, 2023

Changes in this version

type SecurityQuote

+ TimeStamp string

type Snapshot

+ TimeStamp string

Nov 6, 2023

Changes in this version

type XdxrInfo

+ func (x *XdxrInfo) IsCapitalChange() bool

Sep 12, 2023

Changes in this version

+ type Options struct

+ ConnectionTimeout time.Duration

+ MaxRetryTimes int

+ ReadTimeout time.Duration

+ RetryDuration time.Duration

+ Servers []Server

+ WriteTimeout time.Duration

Aug 14, 2023

Changes in this version

type Snapshot

+ func (this *Snapshot) AverageBiddingVolume() int

Jun 27, 2023

Changes in this version

type ConnPool

+ func (p *ConnPool) CloseAll()

Jun 23, 2023

Changes in this version

type XdxrInfo

+ HouLiuTong float64

+ QianLiuTong float64

Jun 19, 2023

Changes in this version

+ type ExchangeState int8

+ const TDX_EXCHANGE_STATE_CLOSING

+ const TDX_EXCHANGE_STATE_DELISTING

+ const TDX_EXCHANGE_STATE_NORMAL

+ const TDX_EXCHANGE_STATE_PAUSE

type Snapshot

+ ExchangeState ExchangeState

+ SecurityCode string

+ func (this *Snapshot) CheckDirection() (biddingDirection, volumeDirection int)

Jun 16, 2023

Changes in this version

type XdxrInfo

+ func (x *XdxrInfo) Adjust() func(p float64) float64

Jun 13, 2023

Changes in this version

type Snapshot

+ Date string

Jun 13, 2023

Changes in this version

+ type Snapshot struct

+ Active uint16

+ Active2 uint16

+ Amount float64

+ Ask1 float64

+ Ask2 float64

+ Ask3 float64

+ Ask4 float64

+ Ask5 float64

+ AskVol1 int

+ AskVol2 int

+ AskVol3 int

+ AskVol4 int

+ AskVol5 int

+ BVol int

+ Bid1 float64

+ Bid2 float64

+ Bid3 float64

+ Bid4 float64

+ Bid5 float64

+ BidVol1 int

+ BidVol2 int

+ BidVol3 int

+ BidVol4 int

+ BidVol5 int

+ CloseVolume int

+ Code string

+ CurVol int

+ High float64

+ IndexDown int

+ IndexDownLimit int

+ IndexOpenAmount int

+ IndexUp int

+ IndexUpLimit int

+ LastClose float64

+ Low float64

+ Market uint8

+ Open float64

+ OpenVolume int

+ Price float64

+ Rate float64

+ ReversedBytes0 int

+ ReversedBytes1 int

+ ReversedBytes4 uint16

+ ReversedBytes5 int

+ ReversedBytes6 int

+ ReversedBytes7 int

+ ReversedBytes8 int

+ SVol int

+ ServerTime string

+ State TradeState

+ StockOpenAmount int

+ Vol int

type StdApi

+ func (this *StdApi) GetSnapshot(codes []string) (list []Snapshot, err error)

May 5, 2023

Changes in this version

+ const HQ_HOSTS_bak

May 5, 2023

Changes in this version

type SecurityQuote

+ CloseVolume int

+ IndexDown int

+ IndexDownLimit int

+ IndexUp int

+ IndexUpLimit int

May 3, 2023

Changes in this version

+ type CompanyInfoCategory struct

+ Filename string

+ Length uint32

+ Name string

+ Offset uint32

+ type CompanyInfoCategoryPackage struct

+ func NewCompanyInfoCategoryPackage() *CompanyInfoCategoryPackage

+ func (obj *CompanyInfoCategoryPackage) Reply() interface{}

+ func (obj *CompanyInfoCategoryPackage) Serialize() ([]byte, error)

+ func (obj *CompanyInfoCategoryPackage) SetParams(req *CompanyInfoCategoryRequest)

+ func (obj *CompanyInfoCategoryPackage) UnSerialize(header interface{}, data []byte) error

+ type CompanyInfoCategoryReply struct

+ Count uint16

+ Data []RawCompanyInfoCategory

+ type CompanyInfoCategoryRequest struct

+ Code [6]byte

+ Market uint16

+ Unknown uint32

+ type CompanyInfoContent struct

+ Code string

+ Content string

+ Length uint32

+ Market proto.MarketType

+ Name string

+ func (this *CompanyInfoContent) Map(unit string) *linkedhashmap.Map

+ type CompanyInfoContentPackage struct

+ func NewCompanyInfoContentPackage() *CompanyInfoContentPackage

+ func (obj *CompanyInfoContentPackage) Reply() interface{}

+ func (obj *CompanyInfoContentPackage) Serialize() ([]byte, error)

+ func (obj *CompanyInfoContentPackage) SetParams(req *CompanyInfoContentRequest)

+ func (obj *CompanyInfoContentPackage) UnSerialize(header interface{}, data []byte) error

+ type CompanyInfoContentReply struct

+ Code string

+ Data []byte

+ Length uint16

+ Market uint16

+ Unknown1 []byte

+ type CompanyInfoContentRequest struct

+ Code [6]byte

+ Filename [80]byte

+ Length uint32

+ Market uint16

+ Offset uint32

+ Unknown1 uint16

+ Unknown2 uint32

+ type RawCompanyInfoCategory struct

+ Filename []byte

+ Length uint32

+ Name []byte

+ Offset uint32

type StdApi

+ func (this *StdApi) GetCompanyInfoCategory(marketType proto.MarketType, symbol string) ([]CompanyInfoCategory, error)

+ func (this *StdApi) GetCompanyInfoContent(marketType proto.MarketType, symbol string, name string) (*CompanyInfoContent, error)

May 2, 2023

Changes in this version

type FinanceInfo

+ func (info FinanceInfo) IsDelisting() bool

May 1, 2023

Changes in this version

type TradeType

+ const TDX_TICK_UNKNOWN

May 1, 2023

Changes in this version

type FinanceInfo

+ Code string

Apr 29, 2023

Changes in this version

type SecurityQuote

+ State TradeState

+ type TradeState uint8

+ const Q_A

+ const Q_B

+ const Q_C

+ const TDX_SECURITY_TRADE_STATE_DELISTING

+ const TDX_SECURITY_TRADE_STATE_NORMAL

+ const TDX_SECURITY_TRADE_STATE_SUSPEND

Apr 28, 2023

Changes in this version

+ type TradeType = int32

+ const TDX_TICK_BUY

+ const TDX_TICK_NEUTRAL

+ const TDX_TICK_SELL

Apr 25, 2023

Changes in this version

type TcpClient

+ Addr string

Apr 25, 2023

Changes in this version

type Opt

+ ConnectionTimeout time.Duration

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

Apr 25, 2023

Changes in this version

type SecurityQuote

+ IndexOpenAmount int

+ OpenVolume int

+ StockOpenAmount int

Apr 20, 2023

Changes in this version

+ func ExamplePinger()

type TcpClient

+ func (client *TcpClient) Command(msg Message) error

Mar 17, 2023

Changes in this version

+ type HeartBeatPackage struct

+ func NewHeartBeat() *HeartBeatPackage

+ func (obj *HeartBeatPackage) Reply() interface{}

+ func (obj *HeartBeatPackage) Serialize() ([]byte, error)

+ func (obj *HeartBeatPackage) UnSerialize(header interface{}, data []byte) error

+ type HeartBeatReply struct

+ Info string

+ type HeartBeatRequest struct

type StdApi

+ func (this *StdApi) HeartBeat() (*HeartBeatReply, error)

Mar 17, 2023

Changes in this version

type StdRequestHeader

+ ZipFlag uint8

type StdResponseHeader

+ ZipFlag uint8

Mar 15, 2023

Changes in this version

+ const TDX_SECURITY_QUOTES_MAX_V2

type StdApi

+ func (this *StdApi) V2GetSecurityQuotes(markets []proto.Market, codes []string) (*V2SecurityQuotesReply, error)

+ type V2Level struct

+ Price float64

+ Vol int

+ type V2SecurityQuote struct

+ Active1 uint16

+ Active2 uint16

+ Amount float64

+ Ask1 float64

+ Ask2 float64

+ Ask3 float64

+ Ask4 float64

+ Ask5 float64

+ AskVol1 int

+ AskVol2 int

+ AskVol3 int

+ AskVol4 int

+ AskVol5 int

+ BVol int

+ Bid1 float64

+ Bid2 float64

+ Bid3 float64

+ Bid4 float64

+ Bid5 float64

+ BidVol1 int

+ BidVol2 int

+ BidVol3 int

+ BidVol4 int

+ BidVol5 int

+ Code string

+ CurVol int

+ High float64

+ LastClose float64

+ Low float64

+ Market uint8

+ Open float64

+ Price float64

+ Rate float64

+ ReversedBytes0 int

+ ReversedBytes1 int

+ ReversedBytes2 int

+ ReversedBytes3 int

+ ReversedBytes4 uint16

+ ReversedBytes5 int

+ ReversedBytes6 int

+ ReversedBytes7 int

+ ReversedBytes8 int

+ SVol int

+ ServerTime string

+ Vol int

+ type V2SecurityQuotesPackage struct

+ func NewV2SecurityQuotesPackage() *V2SecurityQuotesPackage

+ func (obj *V2SecurityQuotesPackage) Reply() interface{}

+ func (obj *V2SecurityQuotesPackage) Serialize() ([]byte, error)

+ func (obj *V2SecurityQuotesPackage) SetParams(req *V2SecurityQuotesRequest)

+ func (obj *V2SecurityQuotesPackage) UnSerialize(header interface{}, data []byte) error

+ type V2SecurityQuotesReply struct

+ Count uint16

+ List []V2SecurityQuote

+ type V2SecurityQuotesRequest struct

+ Count uint16

+ StockList []V2Stock

+ type V2Stock struct

+ Code string

+ Market uint8

Mar 15, 2023

Changes in this version

type SecurityQuotesPackage

+ func NewSecurityQuotesPackage() *SecurityQuotesPackage

Mar 15, 2023

Changes in this version

type SecurityQuotesRequest

+ Count uint16

Mar 15, 2023

Changes in this version

+ const RECV_TIMEOUT

Mar 13, 2023

Changes in this version

+ const TDX_SECURITY_QUOTES_MAX

Mar 11, 2023

Changes in this version

type ConnPool

+ func (p *ConnPool) CloseConn(conn interface{}) error

+ type LabClient struct

+ MaxRetryTimes int

+ RetryDuration time.Duration

+ Timeout time.Duration

+ func NewClientForTest(addr string) (*LabClient, error)

+ func (cli *LabClient) Close() error

+ func (cli *LabClient) Do(request std.Marshaler, response std.Unmarshaler) error

Mar 10, 2023

Changes in this version

+ const BLOCK_CHUNKS_SIZE

+ const BLOCK_DEFAULT

+ const BLOCK_FENGGE

+ const BLOCK_GAINIAN

+ const BLOCK_ZHISHU

+ const TDX_SECURITY_BARS_MAX

+ const TDX_SECURITY_LIST_MAX

+ const TDX_TRANSACTION_MAX

+ type BlockInfo struct

+ BlockName string

+ BlockType uint16

+ Codelist []string

+ StockCount uint16

+ type BlockInfoPackage struct

+ func NewBlockInfoPackage() *BlockInfoPackage

+ func (obj *BlockInfoPackage) Reply() interface{}

+ func (obj *BlockInfoPackage) Serialize() ([]byte, error)

+ func (obj *BlockInfoPackage) SetParams(req *BlockInfoRequest)

+ func (obj *BlockInfoPackage) UnSerialize(header interface{}, data []byte) error

+ type BlockInfoReply struct

+ Block []BlockInfo

+ BlockNum uint16

+ type BlockInfoRequest struct

+ BlockFile [100]byte

+ Size uint32

+ Start uint32

+ type BlockInfoResponse struct

+ Data []byte

+ Size uint32

+ type BlockMeta struct

+ C1 byte

+ C2 byte

+ HashValue [32]byte

+ Size uint32

+ type BlockMetaPackage struct

+ func NewBlockMetaPackage() *BlockMetaPackage

+ func (obj *BlockMetaPackage) Reply() interface{}

+ func (obj *BlockMetaPackage) Serialize() ([]byte, error)

+ func (obj *BlockMetaPackage) SetParams(req *BlockMetaRequest)

+ func (obj *BlockMetaPackage) UnSerialize(header interface{}, data []byte) error

+ type BlockMetaRequest struct

+ BlockFile [40]byte

type Security

+ Reversed1 [4]byte

+ Reversed2 [4]byte

type SecurityBar

+ DownCount uint16

+ UpCount uint16

type StdApi

+ func (this *StdApi) GetBlockInfo(block_file string) (*BlockInfoResponse, error)

+ func (this *StdApi) GetBlockMeta(block_file string) (*BlockMeta, error)

Feb 27, 2023

Changes in this version

+ var XDXR_CATEGORY_MAPPING = map[int]string

+ type RawXdxrInfo struct

+ Category int

+ Code string

+ Data []byte

+ Date uint32

+ Market int

+ Unknown int

type StdApi

+ func (this *StdApi) GetXdxrInfo(market proto.Market, code string) ([]XdxrInfo, error)

+ type XdxrInfo struct

+ Category int

+ Date string

+ FenHong float64

+ FenShu float64

+ HouZongGuBen float64

+ Name string

+ PanHouLiuTong float64

+ PanQianLiuTong float64

+ PeiGu float64

+ PeiGuJia float64

+ QianZongGuBen float64

+ SongZhuanGu float64

+ SuoGu float64

+ XingGuanJia float64

+ type XdxrInfoPackage struct

+ func NewXdxrInfoPackage() *XdxrInfoPackage

+ func (obj *XdxrInfoPackage) Reply() interface{}

+ func (obj *XdxrInfoPackage) Serialize() ([]byte, error)

+ func (obj *XdxrInfoPackage) SetParams(req *XdxrInfoRequest)

+ func (obj *XdxrInfoPackage) UnSerialize(header interface{}, data []byte) error

+ type XdxrInfoReply struct

+ Count uint16

+ List []RawXdxrInfo

+ Unknown []byte

+ type XdxrInfoRequest struct

+ Code [6]byte

+ Market uint8

Feb 19, 2023

Changes in this version

type FinanceInfoRequest

+ Count uint16

Feb 18, 2023

Changes in this version

type FinanceInfoReply

+ Count uint16

+ First RawFinanceInfo

type FinanceInfoRequest

+ Num uint16

+ type RawFinanceInfo struct

+ BGu float32

+ BaoLiu1 float32

+ BaoLiu2 float32

+ ChangQiFuZhai float32

+ Code [6]byte

+ CunHuo float32

+ FaQiRenFaRenGu float32

+ FaRenGu float32

+ GuDingZiChan float32

+ GuDongRenShu float32

+ GuoJiaGu float32

+ HGu float32

+ IPODate uint32

+ Industry uint16

+ JingLiRun float32

+ JingYingxianJinLiu float32

+ JingZiChan float32

+ LiRunZongHe float32

+ LiuDongFuZhai float32

+ LiuDongZiChan float32

+ LiuTongGuBen float32

+ Market uint8

+ Province uint16

+ ShuiHouLiRun float32

+ TouZiShouYu float32

+ UpdatedDate uint32

+ WeiFenLiRun float32

+ WuXingZiChan float32

+ Yingshouzhangkuan float32

+ YingyeLiRun float32

+ ZhiGongGu float32

+ ZhuYingLiRun float32

+ ZhuYingShouRu float32

+ ZiBenGongJiJin float32

+ ZongGuBen float32

+ ZongXianJinLiu float32

+ ZongZiChan float32

+ type RawFinanceInfo1 struct

+ BGu float32

+ BaoLiu1 float32

+ BaoLiu2 float32

+ BaoLiu3 [7]byte

+ ChangQiFuZhai float32

+ CunHuo float32

+ FaQiRenFaRenGu float32

+ FaRenGu float32

+ GuDingZiChan float32

+ GuDongRenShu float32

+ GuoJiaGu float32

+ HGu float32

+ IPODate uint32

+ Industry uint16

+ JingLiRun float32

+ JingYingxianJinLiu float32

+ JingZiChan float32

+ LiRunZongHe float32

+ LiuDongFuZhai float32

+ LiuDongZiChan float32

+ LiuTongGuBen float32

+ Province uint16

+ ShuiHouLiRun float32

+ TouZiShouYu float32

+ UpdatedDate uint32

+ WeiFenLiRun float32

+ WuXingZiChan float32

+ Yingshouzhangkuan float32

+ YingyeLiRun float32

+ ZhiGongGu float32

+ ZhuYingLiRun float32

+ ZhuYingShouRu float32

+ ZiBenGongJiJin float32

+ ZongGuBen float32

+ ZongXianJinLiu float32

+ ZongZiChan float32

type Server

+ func (s Server) Addr() string

Jan 29, 2023

Changes in this version

type StdApi

+ func NewStdApiWithServers(srvs []Server) (*StdApi, error)

Jan 29, 2023

Changes in this version

type Opt

+ Servers []Server

Jan 16, 2023

Changes in this version

+ const CONFIG

+ const CONN_TIMEOUT

+ const DefaultRetryTimes

+ const EX_HOSTS

+ const GP_HOSTS

+ const HQ_HOSTS

+ const MessageHeaderBytes

+ const MessageMaxBytes

+ const POOL_INITED

+ const POOL_MAX

+ const TDX_HOST_EX

+ const TDX_HOST_GP

+ const TDX_HOST_HQ

+ var ErrBadData = errors.New("more than 8M data")

+ func BestIP()

+ func CacheServers(as AllServers) error

+ func Command(pool *ConnPool, factory v2.Factory) v2.Unmarshaler

+ func CommandWithConn(cli *v2.Client, callback v2.Factory) v2.Unmarshaler

+ func Utf8ToGbk(text []byte) string

+ type AllServers struct

+ BestIP ServerGroup

+ Server ServerGroup

+ func OpenConfig() *AllServers

+ type ConnPool struct

+ func NewConnPool(addr string, size int, factory func(string) (interface{}, error), ...) *ConnPool

+ func NewConnPool2(host string, port int, size int, factory func(string) (interface{}, error), ...) *ConnPool

+ func (p *ConnPool) Close()

+ func (p *ConnPool) GetConn() interface{}

+ func (p *ConnPool) ReturnConn(conn interface{})

+ type FinanceInfo struct

+ BGu float64

+ BaoLiu2 float64

+ ChangQiFuZhai float64

+ CunHuo float64

+ FaQiRenFaRenGu float64

+ FaRenGu float64

+ GuDingZiChan float64

+ GuDongRenShu float64

+ GuoJiaGu float64

+ HGu float64

+ IPODate uint32

+ Industry uint16

+ JingLiRun float64

+ JingYingxianJinLiu float64

+ JingZiChan float64

+ LiRunZongHe float64

+ LiuDongFuZhai float64

+ LiuDongZiChan float64

+ LiuTongGuBen float64

+ MeiGuJingZiChan float64

+ Province uint16

+ ShuiHouLiRun float64

+ TouZiShouYu float64

+ UpdatedDate uint32

+ WeiFenLiRun float64

+ WuXingZiChan float64

+ YingShouZhangKuan float64

+ YingyeLiRun float64

+ ZhiGongGu float64

+ ZhuYingLiRun float64

+ ZhuYingShouRu float64

+ ZiBenGongJiJin float64

+ ZongGuBen float64

+ ZongXianJinLiu float64

+ ZongZiChan float64

+ type FinanceInfoPackage struct

+ func NewFinanceInfoPackage() *FinanceInfoPackage

+ func (obj *FinanceInfoPackage) Reply() interface{}

+ func (obj *FinanceInfoPackage) Serialize() ([]byte, error)

+ func (obj *FinanceInfoPackage) SetParams(req *FinanceInfoRequest)

+ func (obj *FinanceInfoPackage) UnSerialize(header interface{}, data []byte) error

+ type FinanceInfoReply struct

+ BGu float32

+ BaoLiu1 float32

+ BaoLiu2 float32

+ ChangQiFuZhai float32

+ Code [6]byte

+ CunHuo float32

+ FaQiRenFaRenGu float32

+ FaRenGu float32

+ GuDingZiChan float32

+ GuDongRenShu float32

+ GuoJiaGu float32

+ HGu float32

+ IPODate uint32

+ Industry uint16

+ JingLiRun float32

+ JingYingxianJinLiu float32

+ JingZiChan float32

+ LiRunZongHe float32

+ LiuDongFuZhai float32

+ LiuDongZiChan float32

+ LiuTongGuBen float32

+ Market uint8

+ Province uint16

+ ShuiHouLiRun float32

+ TouZiShouYu float32

+ Unknown1 [2]byte

+ UpdatedDate uint32

+ WeiFenLiRun float32

+ WuXingZiChan float32

+ Yingshouzhangkuan float32

+ YingyeLiRun float32

+ ZhiGongGu float32

+ ZhuYingLiRun float32

+ ZhuYingShouRu float32

+ ZiBenGongJiJin float32

+ ZongGuBen float32

+ ZongXianJinLiu float32

+ ZongZiChan float32

+ type FinanceInfoRequest struct

+ Code [6]byte

+ Market uint8

+ type Hello1Package struct

+ func NewHello1() *Hello1Package

+ func (obj *Hello1Package) Reply() interface{}

+ func (obj *Hello1Package) Serialize() ([]byte, error)

+ func (obj *Hello1Package) UnSerialize(header interface{}, data []byte) error

+ type Hello1Reply struct

+ Info string

+ type Hello1Request struct

+ type Hello2Package struct

+ func NewHello2() *Hello2Package

+ func (obj *Hello2Package) Reply() interface{}

+ func (obj *Hello2Package) Serialize() ([]byte, error)

+ func (obj *Hello2Package) UnSerialize(header interface{}, data []byte) error

+ type Hello2Reply struct

+ Info string

+ type Hello2Request struct

+ type HistoryMinuteTime struct

+ Price float32

+ Vol int

+ type HistoryMinuteTimePackage struct

+ func NewHistoryMinuteTimePackage() *HistoryMinuteTimePackage

+ func (obj *HistoryMinuteTimePackage) Reply() interface{}

+ func (obj *HistoryMinuteTimePackage) Serialize() ([]byte, error)

+ func (obj *HistoryMinuteTimePackage) SetParams(req *HistoryMinuteTimeRequest)

+ func (obj *HistoryMinuteTimePackage) UnSerialize(header interface{}, data []byte) error

+ type HistoryMinuteTimeReply struct

+ Count uint16

+ List []HistoryMinuteTime

+ type HistoryMinuteTimeRequest struct

+ Code [6]byte

+ Date uint32

+ Market uint8

+ type HistoryTransaction struct

+ BuyOrSell int

+ Num int

+ Price float64

+ Time string

+ Vol int

+ type HistoryTransactionPackage struct

+ func NewHistoryTransactionPackage() *HistoryTransactionPackage

+ func (obj *HistoryTransactionPackage) Reply() interface{}

+ func (obj *HistoryTransactionPackage) Serialize() ([]byte, error)

+ func (obj *HistoryTransactionPackage) SetParams(req *HistoryTransactionRequest)

+ func (obj *HistoryTransactionPackage) UnSerialize(header interface{}, data []byte) error

+ type HistoryTransactionReply struct

+ Count uint16

+ List []HistoryTransaction

+ type HistoryTransactionRequest struct

+ Code [6]byte

+ Count uint16

+ Date uint32

+ Market uint16

+ Start uint16

+ type IndexBar struct

+ Amount float64

+ Close float64

+ DateTime string

+ Day int

+ DownCount uint16

+ High float64

+ Hour int

+ Low float64

+ Minute int

+ Month int

+ Open float64

+ UpCount uint16

+ Vol float64

+ Year int

+ type IndexBarsPackage struct

+ func NewIndexBarsPackage() *IndexBarsPackage

+ func (obj *IndexBarsPackage) Reply() interface{}

+ func (obj *IndexBarsPackage) Serialize() ([]byte, error)

+ func (obj *IndexBarsPackage) SetParams(req *IndexBarsRequest)

+ func (obj *IndexBarsPackage) UnSerialize(header interface{}, data []byte) error

+ type IndexBarsReply struct

+ Count uint16

+ List []IndexBar

+ type IndexBarsRequest struct

+ Category uint16

+ Code [6]byte

+ Count uint16

+ I uint16

+ Market uint16

+ Start uint16

+ type Level struct

+ Price float64

+ Vol int

+ type Message interface

+ Reply func() interface{}

+ Serialize func() ([]byte, error)

+ UnSerialize func(head interface{}, in []byte) error

+ type MinuteTime struct

+ Price float32

+ Vol int

+ type MinuteTimePackage struct

+ func NewMinuteTimePackage() *MinuteTimePackage

+ func (obj *MinuteTimePackage) Reply() interface{}

+ func (obj *MinuteTimePackage) Serialize() ([]byte, error)

+ func (obj *MinuteTimePackage) SetParams(req *MinuteTimeRequest)

+ func (obj *MinuteTimePackage) UnSerialize(header interface{}, data []byte) error

+ type MinuteTimeReply struct

+ Count uint16

+ List []MinuteTime

+ type MinuteTimeRequest struct

+ Code [6]byte

+ Date uint32

+ Market uint16

+ type Opt struct

+ Host string

+ MaxRetryTimes int

+ Port int

+ RetryDuration time.Duration

+ Timeout time.Duration

+ type Security struct

+ Code string

+ DecimalPoint int8

+ Name string

+ PreClose float64

+ VolUnit uint16

+ type SecurityBar struct

+ Amount float64

+ Close float64

+ DateTime string

+ Day int

+ High float64

+ Hour int

+ Low float64

+ Minute int

+ Month int

+ Open float64

+ Vol float64

+ Year int

+ type SecurityBarsPackage struct

+ func NewSecurityBarsPackage() *SecurityBarsPackage

+ func (obj *SecurityBarsPackage) Reply() interface{}

+ func (obj *SecurityBarsPackage) Serialize() ([]byte, error)

+ func (obj *SecurityBarsPackage) SetParams(req *SecurityBarsRequest)

+ func (obj *SecurityBarsPackage) UnSerialize(header interface{}, data []byte) error

+ type SecurityBarsReply struct

+ Count uint16

+ List []SecurityBar

+ type SecurityBarsRequest struct

+ Category uint16

+ Code [6]byte

+ Count uint16

+ I uint16

+ Market uint16

+ Start uint16

+ type SecurityCountPackage struct

+ func NewSecurityCountPackage() *SecurityCountPackage

+ func (obj *SecurityCountPackage) Reply() interface{}

+ func (obj *SecurityCountPackage) Serialize() ([]byte, error)

+ func (obj *SecurityCountPackage) SetParams(req *SecurityCountRequest)

+ func (obj *SecurityCountPackage) UnSerialize(header interface{}, data []byte) error

+ type SecurityCountReply struct

+ Count uint16

+ type SecurityCountRequest struct

+ Market uint16

+ type SecurityListPackage struct

+ func NewSecurityListPackage() *SecurityListPackage

+ func (obj *SecurityListPackage) Reply() interface{}

+ func (obj *SecurityListPackage) Serialize() ([]byte, error)

+ func (obj *SecurityListPackage) SetParams(req *SecurityListRequest)

+ func (obj *SecurityListPackage) UnSerialize(header interface{}, data []byte) error

+ type SecurityListReply struct

+ Count uint16

+ List []Security

+ type SecurityListRequest struct

+ Market uint16

+ Start uint16

+ type SecurityQuote struct

+ Active1 uint16

+ Active2 uint16

+ Amount float64

+ Ask1 float64

+ Ask2 float64

+ Ask3 float64

+ Ask4 float64

+ Ask5 float64

+ AskLevels []Level

+ AskVol1 int

+ AskVol2 int

+ AskVol3 int

+ AskVol4 int

+ AskVol5 int

+ BVol int

+ Bid1 float64

+ Bid2 float64

+ Bid3 float64

+ Bid4 float64

+ Bid5 float64

+ BidLevels []Level

+ BidVol1 int

+ BidVol2 int

+ BidVol3 int

+ BidVol4 int

+ BidVol5 int

+ Code string

+ CurVol int

+ High float64

+ LastClose float64

+ Low float64

+ Market uint8

+ Open float64

+ Price float64

+ Rate float64

+ ReversedBytes0 int

+ ReversedBytes1 int

+ ReversedBytes2 int

+ ReversedBytes3 int

+ ReversedBytes4 uint16

+ ReversedBytes5 int

+ ReversedBytes6 int

+ ReversedBytes7 int

+ ReversedBytes8 int

+ SVol int

+ ServerTime string

+ Vol int

+ type SecurityQuotesPackage struct

+ func NewGetSecurityQuotesPackage() *SecurityQuotesPackage

+ func (obj *SecurityQuotesPackage) Reply() interface{}

+ func (obj *SecurityQuotesPackage) Serialize() ([]byte, error)

+ func (obj *SecurityQuotesPackage) SetParams(req *SecurityQuotesRequest)

+ func (obj *SecurityQuotesPackage) UnSerialize(header interface{}, data []byte) error

+ type SecurityQuotesReply struct

+ Count uint16

+ List []SecurityQuote

+ type SecurityQuotesRequest struct

+ StockList []Stock

+ type Server struct

+ CrossTime int64

+ Host string

+ Name string

+ Port int

+ var DefaultEXServer Server

+ var DefaultHQServer Server

+ func GetFastHost(key string) *Server

+ type ServerGroup struct

+ EX []Server

+ GP []Server

+ HQ []Server

+ type StdApi struct

+ func NewStdApi(srv Server) *StdApi

+ func NewStdApi2() *StdApi

+ func (this *StdApi) Close()

+ func (this *StdApi) GetFinanceInfo(market proto.Market, code string) (*FinanceInfo, error)

+ func (this *StdApi) GetHistoryMinuteTimeData(market proto.Market, code string, date uint32) (*HistoryMinuteTimeReply, error)

+ func (this *StdApi) GetHistoryTransactionData(market proto.Market, code string, date uint32, start uint16, count uint16) (*HistoryTransactionReply, error)

+ func (this *StdApi) GetIndexBars(market proto.Market, code string, category uint16, start uint16, count uint16) (*IndexBarsReply, error)

+ func (this *StdApi) GetKLine(market proto.Market, code string, category uint16, start uint16, count uint16) (*SecurityBarsReply, error)

+ func (this *StdApi) GetMinuteTimeData(market proto.Market, code string) (*MinuteTimeReply, error)

+ func (this *StdApi) GetSecurityCount(market proto.Market) (*SecurityCountReply, error)

+ func (this *StdApi) GetSecurityList(market proto.Market, start uint16) (*SecurityListReply, error)

+ func (this *StdApi) GetSecurityQuotes(markets []proto.Market, codes []string) (*SecurityQuotesReply, error)

+ func (this *StdApi) GetTransactionData(market proto.Market, code string, start uint16, count uint16) (*TransactionReply, error)

+ func (this *StdApi) Hello1() (*Hello1Reply, error)

+ func (this *StdApi) Hello2() (*Hello2Reply, error)

+ type StdRequestHeader struct

+ Method uint16

+ PacketType uint8

+ PkgLen1 uint16

+ PkgLen2 uint16

+ SeqID uint32

+ Zip uint8

+ type StdResponseHeader struct

+ I1 uint32

+ I2 uint8

+ I3 uint8

+ Method uint16

+ SeqID uint32

+ UnZipSize uint16

+ ZipSize uint16

+ type Stock struct

+ Code string

+ Market uint8

+ type TcpClient struct

+ func NewClient(opt *Opt) *TcpClient

+ func (client *TcpClient) Close() error

+ func (client *TcpClient) Connect() error

+ func (client *TcpClient) GetConn() net.Conn

+ func (client *TcpClient) GetOpt() Opt

+ type TdxMarket int

+ type TickTransaction struct

+ BuyOrSell int

+ Num int

+ Price float64

+ Time string

+ Vol int

+ type TransactionPackage struct

+ func NewTransactionPackage() *TransactionPackage

+ func (obj *TransactionPackage) Reply() interface{}

+ func (obj *TransactionPackage) Serialize() ([]byte, error)

+ func (obj *TransactionPackage) SetParams(req *TransactionRequest)

+ func (obj *TransactionPackage) UnSerialize(header interface{}, data []byte) error

+ type TransactionReply struct

+ Count uint16

+ List []TickTransaction

+ type TransactionRequest struct

+ Code [6]byte

+ Count uint16

+ Market uint16

+ Start uint16