OracleListener

Documentation

Index

• Variables
• type OraclePool
  • func NewOraclePool() *OraclePool
  • func (pool *OraclePool) IsSubscribed(id int) bool
  • func (pool *OraclePool) Subscribe(msg *Messages.SubscribeMsg)
  • func (pool *OraclePool) Unsubscribe(msg *Messages.UnsubscribeMsg)
• type SafeConnection

Variables

var Host = "127.0.0.1:8383/"

Types

type OraclePool

type OraclePool struct {
	Connections map[string]*SafeConnection

	SubscribeChan   chan *Messages.SubscribeMsg
	UnsubscribeChan chan *Messages.UnsubscribeMsg
	Subscribers     map[int][]*Messages.SubscribeMsg
	// contains filtered or unexported fields
}

func NewOraclePool

func NewOraclePool() *OraclePool

func (*OraclePool) IsSubscribed

func (pool *OraclePool) IsSubscribed(id int) bool

func (*OraclePool) Subscribe

func (pool *OraclePool) Subscribe(msg *Messages.SubscribeMsg)

func (*OraclePool) Unsubscribe

func (pool *OraclePool) Unsubscribe(msg *Messages.UnsubscribeMsg)

type SafeConnection

type SafeConnection struct {
	Url   string
	Conn  *websocket.Conn
	Count int
	// contains filtered or unexported fields
}