util

README

datasource

自建国内期货行情数据源

• 从ctp接收tick，上传更新生成各级k线.
• 主要是用来提供实时数据的推送, 因为dcenter取历史数据默认都是从三方网站或tdx
• goshare官方维护一个数据源，方便初学者上手(不用自己去配置CTP行情接收之类的)

client

自建数据源客户端

• 优先实现实时数据订阅推送, 因为dcenter取历史数据默认都是从三方网站或tdx

Documentation

Index

• func Decode(src string) (dst string)
• func Encode(src string) (dst string)
• func GetMD5(str string) string
• func ParseBeijingTime(layout, value string) int64
• func ParseFloat(src string) float64
• func ParseInt(src string) int
• func ParseInt32(src string) int32
• func PostSome(url string, token string, req, res interface{}) error
• func PrintStack(skip int)
• func RunTinyGateway(port int, ...) error
• func SendMail(user, password, host, to, subject, content string) error
• func StringFromGBK(src string) (dst string)
• func StringFromGBK2(src []byte) (dst string)
• type Stream
  • func NewStream(directory string, h handler) *Stream
  • func (s *Stream) Close()
  • func (s *Stream) Flush()
  • func (s *Stream) Reset()
  • func (s *Stream) Write(t int32, d []byte)

Functions

func Decode

func Decode(src string) (dst string)

Decode 转UTF8

func Encode

func Encode(src string) (dst string)

func GetMD5

func GetMD5(str string) string

GetMD5 转md5

func ParseBeijingTime

func ParseBeijingTime(layout, value string) int64

ParseBeijingTime 解析北京时间

func ParseFloat

func ParseFloat(src string) float64

ParseFloat ParseFloat

func ParseInt

func ParseInt(src string) int

ParseInt ParseInt

func ParseInt32

func ParseInt32(src string) int32

ParseInt32 ParseInt

func PostSome

func PostSome(url string, token string, req, res interface{}) error

PostSome post请求

func PrintStack

func PrintStack(skip int)

PrintStack 输出stack

func RunTinyGateway

func RunTinyGateway(port int, h func(string, http.ResponseWriter, *http.Request) (interface{}, error)) error

RunTinyGateway 小API入口

func SendMail

func SendMail(user, password, host, to, subject, content string) error

SendMail 发送邮件的逻辑函数

func StringFromGBK

func StringFromGBK(src string) (dst string)

StringFromGBK 转换GBK

func StringFromGBK2

func StringFromGBK2(src []byte) (dst string)

StringFromGBK2 StringFromGBK2

Types

type Stream

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

Stream stream

func NewStream

func NewStream(directory string, h handler) *Stream

NewStream create new stream

func (*Stream) Close

func (s *Stream) Close()

Close the stream

func (*Stream) Flush

func (s *Stream) Flush()

Flush steram

func (*Stream) Reset

func (s *Stream) Reset()

Reset switch to new stream

func (*Stream) Write

func (s *Stream) Write(t int32, d []byte)

Write write one message