ogmigo

package module
v0.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 27, 2025 License: Apache-2.0 Imports: 19 Imported by: 3

README

ogmigo

ogmigo is a go client for ogmios.

This library is under heavy development, use at your own risk.

Example

package example

import (
	"context"
	"github.com/SundaeSwap-finance/ogmigo"
)

func example(ctx context.Context) error {
	var callback ogmigo.ChainSyncFunc = func(ctx context.Context, data []byte) error {
		// do work
		return nil
	}

	client := ogmigo.New(ogmigo.WithEndpoint("ws://example.com:1337"))
	closer, err := client.ChainSync(ctx, callback)
	if err != nil {
		return err
	}
	if err := closer.Close(); err != nil {
		return err
	}

	return nil
}

Submodules

ogmigo imports ogmios as a submodule for testing purposes. To fetch the submodules,

git submodule update --init --recursive

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DefaultLogger = defaultLogger{}

DefaultLogger logs via the log package

View Source 
var NopLogger = nopLogger{}

NopLogger logs nothing

Functions

func SlotToElapsedMilliseconds added in v0.9.0 

func SlotToElapsedMilliseconds(history *EraHistory, slot uint64) uint64

Types

type AcquireMempoolResponse added in v0.9.0 

type AcquireMempoolResponse struct {
	Method string
	Result struct {
		Acquired string
		Slot     uint64
	}
}

type ChainSync 

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

ChainSync provides control over a given ChainSync connection

func (*ChainSync) Close 

func (c *ChainSync) Close() error

Close the ChainSync connection

func (*ChainSync) Done 

func (c *ChainSync) Done() <-chan struct{}

Done indicates the ChainSync has terminated prematurely

func (*ChainSync) Err added in v0.9.0 

func (c *ChainSync) Err() <-chan error

type ChainSyncFunc 

type ChainSyncFunc func(ctx context.Context, data []byte) error

ChainSyncFunc callback containing json encoded chainsync.Response

type ChainSyncOption 

type ChainSyncOption func(opts *ChainSyncOptions)

ChainSyncOption provides functional options for ChainSync

func WithMinSlot 

func WithMinSlot(slot uint64) ChainSyncOption

WithMinSlot ignores any activity prior to the specified slot

func WithPoints 

func WithPoints(points ...chainsync.Point) ChainSyncOption

WithPoints allows starting from an optional point

func WithReconnect 

func WithReconnect(enabled bool) ChainSyncOption

WithReconnect attempt to reconnect to ogmios if connection drops

func WithStore 

func WithStore(store Store) ChainSyncOption

WithStore specifies store to persist points to; defaults to no persistence

type ChainSyncOptions 

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

ChainSyncOptions configuration parameters

type Client 

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

Client provides a client for the chain sync protocol only

func New 

func New(opts ...Option) *Client

New returns a new Client

func (*Client) ChainSync 

func (c *Client) ChainSync(ctx context.Context, callback ChainSyncFunc, opts ...ChainSyncOption) (*ChainSync, error)

ChainSync replays the blockchain by invoking the callback for each block By default, ChainSync stores no checkpoints and always restarts from origin. These can be overridden via WithPoints and WithStore

func (*Client) ChainTip 

func (c *Client) ChainTip(ctx context.Context) (chainsync.Point, error)

func (*Client) CurrentEpoch 

func (c *Client) CurrentEpoch(ctx context.Context) (uint64, error)

func (*Client) CurrentProtocolParameters 

func (c *Client) CurrentProtocolParameters(ctx context.Context) (json.RawMessage, error)

func (*Client) EraStart 

func (c *Client) EraStart(ctx context.Context) (statequery.EraStart, error)

func (*Client) EraSummaries 

func (c *Client) EraSummaries(ctx context.Context) (*EraHistory, error)

func (*Client) EvaluateTx added in v0.9.0 

func (c *Client) EvaluateTx(ctx context.Context, data string) (response *EvaluateTxResponse, err error)

EvaluateTx measures the script execution costs of a transaction. https://ogmios.dev/mini-protocols/local-tx-submission/ https://github.com/CardanoSolutions/ogmios/blob/v6.0/docs/content/mini-protocols/local-tx-submission.md

func (*Client) EvaluateTxWithAdditionalUtxos added in v0.9.0 

func (c *Client) EvaluateTxWithAdditionalUtxos(ctx context.Context, data string, additionalUtxos []shared.Utxo) (response *EvaluateTxResponse, err error)

func (*Client) GenesisConfig added in v0.9.0 

func (c *Client) GenesisConfig(ctx context.Context, era string) (json.RawMessage, error)

func (*Client) MonitorMempool added in v0.9.0 

func (c *Client) MonitorMempool(ctx context.Context, callback MonitorMempoolFunc, opts ...MonitorMempoolOption) (*MonitorMempool, error)

func (*Client) StartTime added in v0.9.0 

func (c *Client) StartTime(ctx context.Context) (string, error)

func (*Client) SubmitTx 

func (c *Client) SubmitTx(ctx context.Context, data string) (s *SubmitTxResponse, err error)

SubmitTx submits the transaction via ogmios https://ogmios.dev/mini-protocols/local-tx-submission/

func (*Client) UtxosByAddress 

func (c *Client) UtxosByAddress(ctx context.Context, addresses ...string) ([]shared.Utxo, error)

func (*Client) UtxosByTxIn 

func (c *Client) UtxosByTxIn(ctx context.Context, txIns ...chainsync.TxInQuery) ([]shared.Utxo, error)

type EraBound 

type EraBound struct {
	Time  statequery.EraSeconds `json:"time"`
	Slot  uint64                `json:"slot"`
	Epoch uint64                `json:"epoch"`
}

type EraHistory 

type EraHistory struct {
	Summaries []EraSummary
}

type EraParameters 

type EraParameters struct {
	EpochLength uint64                     `json:"epochLength"`
	SlotLength  statequery.EraMilliseconds `json:"slotLength"`
	SafeZone    uint64                     `json:"safeZone"`
}

type EraSummary 

type EraSummary struct {
	Start      EraBound      `json:"start"`
	End        EraBound      `json:"end"`
	Parameters EraParameters `json:"parameters"`
}

type Error 

type Error struct {
	Type        string `json:"type,omitempty"`
	Version     string `json:"version,omitempty"`
	ServiceName string `json:"servicename,omitempty"`
	Fault       Fault  `json:"fault,omitempty"`
}

Error encapsulates errors from ogmios

func (Error) Error 

func (e Error) Error() string

Error implements error interface

type EvaluateResponse added in v0.9.0 

type EvaluateResponse struct {
	Type        string
	Version     string
	ServiceName string `json:"servicename"`
	MethodName  string `json:"methodname"`
	Reflection  interface{}
	Result      json.RawMessage
}

type EvaluateTx added in v0.9.0 

type EvaluateTx struct {
	Cbor string `json:"cbor"`
}

type EvaluateTxError added in v0.9.0 

type EvaluateTxError struct {
	Code    int
	Message string
	Data    json.RawMessage
}

type EvaluateTxResponse added in v0.9.0 

type EvaluateTxResponse struct {
	ExUnits []ExUnits
	Error   *EvaluateTxError
}

type ExUnits added in v0.9.0 

type ExUnits struct {
	Validator Validator     `json:"validator"`
	Budget    ExUnitsBudget `json:"budget"`
}

type ExUnitsBudget added in v0.9.0 

type ExUnitsBudget struct {
	Memory uint64 `json:"memory"`
	Cpu    uint64 `json:"cpu"`
}

type Fault 

type Fault struct {
	Code   string `json:"code,omitempty"`   // Code identifies error
	String string `json:"string,omitempty"` // String provides human readable description
}

Fault provides additional context for ogmios errors

type KeyValue 

type KeyValue struct {
	Key   string
	Value string
}

func KV 

func KV(key, value string) KeyValue

type Logger 

type Logger interface {
	Debug(message string, kvs ...KeyValue)
	Info(message string, kvs ...KeyValue)
	With(kvs ...KeyValue) Logger
}

type Map 

type Map map[string]interface{}

Map provides a simple type alias

type MonitorMempool added in v0.9.0 

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

func (*MonitorMempool) Close added in v0.9.0 

func (c *MonitorMempool) Close() error

func (*MonitorMempool) Done added in v0.9.0 

func (c *MonitorMempool) Done() <-chan struct{}

func (*MonitorMempool) Err added in v0.9.0 

func (c *MonitorMempool) Err() <-chan error

type MonitorMempoolFunc added in v0.9.0 

type MonitorMempoolFunc func(ctx context.Context, data []*chainsync.Tx, slot uint64) error

type MonitorMempoolOption added in v0.9.0 

type MonitorMempoolOption func(opts *MonitorMempoolOptions)

type MonitorMempoolOptions added in v0.9.0 

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

type MonitorState added in v0.9.0 

type MonitorState int
const (
	AcquireMempool MonitorState = iota
	NextTransaction
)

type NextTransactionResponse added in v0.9.0 

type NextTransactionResponse struct {
	Method string
	Result struct {
		Transaction *chainsync.Tx
	}
}

type Option 

type Option func(*Options)

Option to cardano client

func WithEndpoint 

func WithEndpoint(endpoint string) Option

WithEndpoint allows ogmios endpoint to set; defaults to ws://127.0.0.1:1337

func WithInterval 

func WithInterval(n int) Option

WithInterval specifies how frequently to save checkpoints when reading

func WithLogger 

func WithLogger(logger Logger) Option

WithLogger allows custom logger to be specified

func WithPipeline 

func WithPipeline(n int) Option

WithPipeline allows number of pipelined ogmios requests to be provided

type Options 

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

Options available to ogmios client

type Response 

type Response struct {
	Transaction ResponseTx `json:"transaction,omitempty"  dynamodbav:"transaction,omitempty"`
}

type ResponseTx added in v0.9.0 

type ResponseTx struct {
	ID string `json:"id,omitempty" dynamodbav:"id,omitempty"`
}

type Store 

type Store interface {
	// Save the point; save will be called multiple times and should only
	// keep track of the most recent points
	Save(ctx context.Context, point chainsync.Point) error
	// Load saved points
	Load(ctx context.Context) (chainsync.Points, error)
}

Store allows points to be saved and retrieved to allow graceful recovery after shutdown

func NewLoggingStore 

func NewLoggingStore(logger Logger) Store

NewLoggingStore logs Save requests, but does not actually save points

type SubmitTx added in v0.9.0 

type SubmitTx struct {
	Cbor string `json:"cbor"`
}

type SubmitTxError 

type SubmitTxError struct {
	Code    int
	Message string
	Data    json.RawMessage
}

type SubmitTxPayload added in v0.9.0 

type SubmitTxPayload struct {
	CBOR string `json:"cbor"`
}

type SubmitTxResponse added in v0.9.0 

type SubmitTxResponse struct {
	ID    string
	Error *SubmitTxError
}

type Validator added in v0.9.0 

type Validator struct {
	Purpose string `json:"purpose"`
	Index   uint64 `json:"index"`
}

Source Files

View all Source files

Directories

Path Synopsis
cmd
test_client
test_mempool_client
logger
zaplogger Module
ouroboros
chainsync
chainsync/num
shared
statequery

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.