cryptocompare

Documentation

Index

• Constants
• func HasSubscription(subs string) bool
• func Init(systemConfig *config.SystemConfig) error
• func ProcessMessage(msg *pubsub.Message) error
• func RunWebsockerStub()
• func SendMessage(message []byte) error
• func Shutdown()
• func ShutdownWebsockerStub()
• func WebsocketStubReadMessage() []byte
• type JSONParams

Constants

const (
	Vendor = "cryptocompare"
)

Functions

func HasSubscription

func HasSubscription(subs string) bool

func Init

func Init(systemConfig *config.SystemConfig) error

func ProcessMessage

func ProcessMessage(msg *pubsub.Message) error

func RunWebsockerStub

func RunWebsockerStub()

func SendMessage

func SendMessage(message []byte) error

func Shutdown

func Shutdown()

func ShutdownWebsockerStub

func ShutdownWebsockerStub()

func WebsocketStubReadMessage

func WebsocketStubReadMessage() []byte

Types

type JSONParams

type JSONParams struct {
	Action string   `json:"action"`
	Subs   []string `json:"subs"`
}