OracleConnection

Documentation

Index

• Variables
• type BroadcastMsg
• type OraclePool
  • func NewOraclePool() *OraclePool
• type ResponseMsg
• type SafeConnection
• type SubscribeMsg
• type UnsubscribeMsg

Variables

var Host = "127.0.0.1:8383/"

Types

type BroadcastMsg

type BroadcastMsg struct {
	Key       string `json:"key"`
	Value     string `json:"value"`
	Type      string `json:"type"`
	Timestamp string `json:"timestamp"`
	Index     int
	Error     error
}

type OraclePool

type OraclePool struct {
	Connections map[string]*SafeConnection

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

func NewOraclePool

func NewOraclePool() *OraclePool

type ResponseMsg

type ResponseMsg struct {
	Key       string `json:"key"`
	Value     string `json:"value"`
	Timestamp string `json:"timestamp"`
}

type SafeConnection

type SafeConnection struct {
	Url string

	Count int
	// contains filtered or unexported fields
}

type SubscribeMsg

type SubscribeMsg struct {
	VM            int
	Url           string
	OracleKey     string
	Index         int
	BroadcastChan chan *BroadcastMsg
}

type UnsubscribeMsg

type UnsubscribeMsg struct {
	VM int
}