eventstream

Documentation

Index

• func NewWebsocket(url string, onOpenMsg []byte, logger zerolog.Logger) *ws
• type Stream
  • func Dial(tendermintRPCEndpoint string, grpcEndpoint string, logger zerolog.Logger) *Stream
  • func (s *Stream) Close()
  • func (s *Stream) ParamsUpdate() <-chan types.Params
  • func (s *Stream) VotingPeriodStarted() <-chan types.VotingPeriod

Functions

func NewWebsocket

func NewWebsocket(url string, onOpenMsg []byte, logger zerolog.Logger) *ws

Types

type Stream

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

func Dial

func Dial(tendermintRPCEndpoint string, grpcEndpoint string, logger zerolog.Logger) *Stream

Dial opens two connections to the given endpoint, one for the websocket and one for the oracle grpc.

func (*Stream) Close

func (s *Stream) Close()

func (*Stream) ParamsUpdate

func (s *Stream) ParamsUpdate() <-chan types.Params

func (*Stream) VotingPeriodStarted

func (s *Stream) VotingPeriodStarted() <-chan types.VotingPeriod