pkg

package
v0.0.0-...-811e4ca Latest Latest
Warning

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

Go to latest
Published: Nov 26, 2023 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

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

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

Variables

This section is empty.

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL