connection

Documentation

Index

• Constants
• type Connectable
• type State
  • func NewState() State
• type StateChangeCb
• type StateValue
• type Status
  • func NewStatus() *Status
  • func (c *Status) GetState() State
  • func (c *Status) GetStateValue() StateValue
  • func (c *Status) IsConnected() bool
  • func (c *Status) ResetStateValue()
  • func (c *Status) SetIsConnected(value bool)
  • func (c *Status) SetState(state State)
  • func (c *Status) SetStateChangeCb(stateChangeCb StateChangeCb)
• type StatusNotification
• type StatusNotifier
  • func NewStatusNotifier(statuses *sync.Map, eventType walletevent.EventType, feed *event.Feed) *StatusNotifier

Constants

const InvalidTimestamp = int64(-1)

Types

type Connectable

type Connectable interface {
	SetIsConnected(bool)
	IsConnected() bool
}

type State

type State struct {
	Value         StateValue `json:"value"`
	LastCheckedAt int64      `json:"last_checked_at"`
	LastSuccessAt int64      `json:"last_success_at"`
}

func NewState

func NewState() State

type StateChangeCb

type StateChangeCb func(State)

type StateValue

type StateValue int

const (
	StateValueUnknown StateValue = iota
	StateValueConnected
	StateValueDisconnected
)

type Status

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

func NewStatus

func NewStatus() *Status

func (*Status) GetState

func (c *Status) GetState() State

func (*Status) GetStateValue

func (c *Status) GetStateValue() StateValue

func (*Status) IsConnected

func (c *Status) IsConnected() bool

func (*Status) ResetStateValue

func (c *Status) ResetStateValue()

func (*Status) SetIsConnected

func (c *Status) SetIsConnected(value bool)

func (*Status) SetState

func (c *Status) SetState(state State)

func (*Status) SetStateChangeCb

func (c *Status) SetStateChangeCb(stateChangeCb StateChangeCb)

type StatusNotification

type StatusNotification map[string]State // id -> State

Client expects a single event with all states

type StatusNotifier

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

func NewStatusNotifier

func NewStatusNotifier(statuses *sync.Map, eventType walletevent.EventType, feed *event.Feed) *StatusNotifier