fx

Documentation

Overview

Json i/o Json in: execute & decode http requests Json out: handle & encode http responses, server-side streaming

Index

• func Node(ctx context.Context) (*rpc.Client, *ethclient.Client, error)
• type Data
  • func Source(dbName string, ctx context.Context) (*Data, error)
  • func (d *Data) ConnectPostgres(dbName string) error
  • func (d *Data) ConnectRedis(dbNumber int, ctx context.Context) error
• type JSON
  • func Json(http http.Client, ctx context.Context) *JSON
  • func (j *JSON) In(url, apiKey string) ([]byte, error)
  • func (j *JSON) Out(w http.ResponseWriter, input func() (any, error), locker sync.Locker)
  • func (j *JSON) OutSSE(w http.ResponseWriter, r *http.Request, input func() (any, error), ...)
  • func (j *JSON) Print(value any)
  • func (j *JSON) Simplify(input []any, prefix string) []any
• type Math
  • func (m *Math) Down(from int64, callback func(int64))
  • func (m *Math) Int(value string) *big.Int
  • func (m *Math) Up(from int64, callback func(int64))
• type State
  • func NewState(data *Data, ctx context.Context) *State
  • func (s *State) AddToPackage(pkg string, key string, value any) error
  • func (s *State) GetFromPackage(pkg string, key string) (any, error)
  • func (s *State) GetPackage(pkg string) (map[string]any, error)
  • func (s *State) LoadState() error

Functions

func Node

func Node(ctx context.Context) (*rpc.Client, *ethclient.Client, error)

Establish geth.ipc connection (http, websocket disabled)

Types

type Data

type Data struct {
	Pg  *sql.DB
	RB  *redis.Client
	Ctx context.Context
}

func Source

func Source(dbName string, ctx context.Context) (*Data, error)

func (*Data) ConnectPostgres

func (d *Data) ConnectPostgres(dbName string) error

func (*Data) ConnectRedis

func (d *Data) ConnectRedis(dbNumber int, ctx context.Context) error

type JSON

type JSON struct {
	HTTP *http.Client
	CTX  context.Context
}

func Json

func Json(http http.Client, ctx context.Context) *JSON

Json initializes and returns a new JSON utility instance, using http.Client and context.Context created in NewFactory.

func (*JSON) In

func (j *JSON) In(url, apiKey string) ([]byte, error)

Execute HTTP GET requests, with X-API-KEY headers as needed, and return the response body as bytes.

func (*JSON) Out

func (j *JSON) Out(w http.ResponseWriter, input func() (any, error), locker sync.Locker)

Out writes single response for http requests, using a function to source data and a locker to synchronize access or an HTTP 500 error when the input function fails or JSON encoding fails.

func (*JSON) OutSSE

func (j *JSON) OutSSE(w http.ResponseWriter, r *http.Request, input func() (any, error), interval time.Duration)

OutSSE is Out at a defined interval, streams responses until the client disconnects or the context is canceled.

func (*JSON) Print

func (j *JSON) Print(value any)

Print value as indented JSON to the standard output or logs error when value cannot be marshaled.

func (*JSON) Simplify

func (j *JSON) Simplify(input []any, prefix string) []any

Simplify processes a slice of objects ([]any), flattens each object, and removes empty fields.

type Math

type Math struct{}

func (*Math) Down

func (m *Math) Down(from int64, callback func(int64))

func (*Math) Int

func (m *Math) Int(value string) *big.Int

func (*Math) Up

func (m *Math) Up(from int64, callback func(int64))

type State

type State struct {
	Mu   *sync.Mutex
	Data *Data
	Ctx  context.Context
	Map  map[string]map[string]any
}

func NewState

func NewState(data *Data, ctx context.Context) *State

func (*State) AddToPackage

func (s *State) AddToPackage(pkg string, key string, value any) error

func (*State) GetFromPackage

func (s *State) GetFromPackage(pkg string, key string) (any, error)

func (*State) GetPackage

func (s *State) GetPackage(pkg string) (map[string]any, error)

func (*State) LoadState

func (s *State) LoadState() error