devo

Documentation

Index

• type DevoClient
  • func Init(sp *DevoClient) DevoClient
  • func (s *DevoClient) ContinuousQuery(from int64, query string, resultmsg chan string) (err error)
  • func (s *DevoClient) QueryRaw(from int64, to int64, query string, resultmsg chan string) (lastLine string, err error)
• type DevoRequest
• type SDevoResponse
• type SMode

Types

type DevoClient

type DevoClient struct {
	APIKey     string
	APISecret  string
	SerreaURL  string
	Debug      bool
	HTTPClient *http.Client
	BufferSize int
}

func Init

func Init(sp *DevoClient) DevoClient

func (*DevoClient) ContinuousQuery

func (s *DevoClient) ContinuousQuery(from int64, query string, resultmsg chan string) (err error)

func (*DevoClient) QueryRaw

func (s *DevoClient) QueryRaw(from int64, to int64, query string, resultmsg chan string) (lastLine string, err error)

type DevoRequest

type DevoRequest struct {
	DateFrom int64  `json:"from"`
	DateTo   int64  `json:"to"`
	Query    string `json:"query"`
	Mode     SMode  `json:"mode"`
}

type SDevoResponse

type SDevoResponse struct {
	Message   string        `json:"msg"`
	Timestamp int64         `json:"timestamp"`
	CID       string        `json:"cid"`
	Status    int           `json:"status"`
	Object    []interface{} `json:"object"`
}

type SMode

type SMode struct {
	Type string `json:"type"`
}