tmwsproxy

Documentation

Index

• Variables
• func NewProxy(logger *zap.SugaredLogger) *proxy
• type Config
  • func ReadConfig() (*Config, error)
  • func (c *Config) Validate() error
• type TendermintClient
  • func NewTendermintClient(endpoint string, logger *zap.SugaredLogger, db *database.Instance) (*TendermintClient, error)
  • func (t *TendermintClient) Subscribe(evtString string) error

Variables

var (
	ErrOtherSideAbsent = fmt.Errorf("other side absent")
)

Functions

func NewProxy

func NewProxy(logger *zap.SugaredLogger) *proxy

Types

type Config

type Config struct {
	TendermintNode        string `validate:"required"`
	ListenAddr            string `validate:"required"`
	DatabaseConnectionURL string `validate:"required"`
	Debug                 bool
}

func ReadConfig

func ReadConfig() (*Config, error)

func (*Config) Validate

func (c *Config) Validate() error

type TendermintClient

type TendermintClient struct {
	DataChannel chan json.RawMessage
	// contains filtered or unexported fields
}

func NewTendermintClient

func NewTendermintClient(endpoint string, logger *zap.SugaredLogger, db *database.Instance) (*TendermintClient, error)

func (*TendermintClient) Subscribe

func (t *TendermintClient) Subscribe(evtString string) error