kafkaApi

Documentation

Index

• Variables
• func Process(c *gin.Context, topic int)
• func SendError(c *gin.Context, errorCode int, err error)
• type APIError
• type FiltersBlock
• type RestApi
  • func NewRestApi(topic int) *RestApi
  • func (s *RestApi) Get(offset int64, elements int) (map[string]interface{}, error)
• type Trades
• type TradesBlock

Variables

var (
	Apis = map[int]*RestApi{
		kafkaHelper.TopicFiltersBlock: NewRestApi(kafkaHelper.TopicFiltersBlock),
		kafkaHelper.TopicTrades:       NewRestApi(kafkaHelper.TopicTrades),
		kafkaHelper.TopicTradesBlock:  NewRestApi(kafkaHelper.TopicTradesBlock),
	}
)

Functions

func Process

func Process(c *gin.Context, topic int)

func SendError

func SendError(c *gin.Context, errorCode int, err error)

Types

type APIError

type APIError struct {
	ErrorCode    int    `json:"errorcode"`
	ErrorMessage string `json:"errormessage"`
}

type FiltersBlock

type FiltersBlock struct {
	Offset   int `json:"offset"`
	Messages []dia.FiltersBlock
}

type RestApi

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

func NewRestApi

func NewRestApi(topic int) *RestApi

func (*RestApi) Get

func (s *RestApi) Get(offset int64, elements int) (map[string]interface{}, error)

type Trades

type Trades struct {
	Offset   int `json:"offset"`
	Messages []dia.Trade
}

type TradesBlock

type TradesBlock struct {
	Offset   int `json:"offset"`
	Messages []dia.TradesBlock
}