pkg

Documentation

Index

• Constants
• func GetItemFromSteamWebApi(hashedName, key string) (*domain.SteamWebApi, error)
• func PostToCoreService(csItem domain.CsItem, coreServiceUrl string) error
• type KafkaReader
  • func NewKafkaReader(topic, username, password, url string) *KafkaReader
  • func (kr *KafkaReader) Close() error
  • func (kr *KafkaReader) ReadMessage(ctx context.Context) (kafka.Message, error)

Constants

const (
	SteamApiUrl = "https://steamcommunity.com/market/priceoverview"
	CsAppId     = 730
	Currency    = 17 //Turkish Lira

	SteamWebApiUrl      = "https://www.steamwebapi.com/steam/api/item"
	SteamWebApiCurrency = "TRY"
)

Functions

func GetItemFromSteamWebApi

func GetItemFromSteamWebApi(hashedName, key string) (*domain.SteamWebApi, error)

func PostToCoreService

func PostToCoreService(csItem domain.CsItem, coreServiceUrl string) error

Types

type KafkaReader

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

func NewKafkaReader

func NewKafkaReader(topic, username, password, url string) *KafkaReader

func (*KafkaReader) Close

func (kr *KafkaReader) Close() error

func (*KafkaReader) ReadMessage

func (kr *KafkaReader) ReadMessage(ctx context.Context) (kafka.Message, error)