kafkaApi

package
v0.0.0-...-3beb7e2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 14, 2022 License: GPL-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.