exchange

Documentation

Index

• type ExchangeConfig
• type ExchangeProcessor
  • func StartExchangeProcessor(cfg *ExchangeConfig, backend *storage.RedisClient) *ExchangeProcessor
  • func (u *ExchangeProcessor) Start()
• type ExchangeReply
• type RestClient
  • func NewRestClient(name, url, timeout string) *RestClient
  • func (r *RestClient) GetData() (ExchangeReply, error)

Types

type ExchangeConfig

type ExchangeConfig struct {
	Enabled         bool   `json:"enabled"`
	Name            string `json:"name"`
	Url             string `json:"url"`
	Timeout         string `json:"timeout"`
	RefreshInterval string `json:"refreshInterval"`
}

type ExchangeProcessor

type ExchangeProcessor struct {
	ExchangeConfig *ExchangeConfig
	// contains filtered or unexported fields
}

func StartExchangeProcessor

func StartExchangeProcessor(cfg *ExchangeConfig, backend *storage.RedisClient) *ExchangeProcessor

func (*ExchangeProcessor) Start

func (u *ExchangeProcessor) Start()

type ExchangeReply

type ExchangeReply []map[string]interface{}

type RestClient

type RestClient struct {
	sync.RWMutex
	Url  string
	Name string
	// contains filtered or unexported fields
}

func NewRestClient

func NewRestClient(name, url, timeout string) *RestClient

func (*RestClient) GetData

func (r *RestClient) GetData() (ExchangeReply, error)