ogmigo

Apr 17, 2024

Changes in this version

type Client

+ func (c *Client) SubmitTxV6(ctx context.Context, cborHex string) (err error)

Sep 8, 2023

Changes in this version

type ChainSyncOption

+ func WithUseV6(useV6 bool) ChainSyncOption

Aug 4, 2023

Changes in this version

type Client

+ func (c *Client) EvaluateTxV6(ctx context.Context, cborHex string) (redeemer chainsync.Redeemer, err error)

Apr 12, 2023

Changes in this version

type Option

+ func WithTimeout(timeout time.Duration) Option

Apr 11, 2023

Changes in this version

type Client

+ func (c *Client) EvaluateTx(ctx context.Context, cborHex string) (redeemer chainsync.Redeemer, err error)

+ type EvaluateTxError struct

+ func (s EvaluateTxError) Error() string

+ func (s EvaluateTxError) Messages() json.RawMessage

+ type EvaluationResponse struct

+ MethodName string

+ Reflection interface{}

+ Result json.RawMessage

+ ServiceName string

+ Type string

+ Version string

Apr 11, 2023

Changes in this version

+ func NewWrappedReadMessageError(message string, originalErr error) error

+ type WrappedReadMessageError struct

+ func (e *WrappedReadMessageError) Error() string

+ func (e *WrappedReadMessageError) Temporary() bool

Mar 24, 2023

Changes in this version

type Logger

+ Error func(error error, message string, kvs ...KeyValue)

Mar 21, 2023

Changes in this version

+ var DefaultLogger = defaultLogger

+ var NopLogger = nopLogger

+ type ChainSync struct

+ func (c *ChainSync) Close() error

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

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

+ type ChainSyncOption func(opts *ChainSyncOptions)

+ func WithMinSlot(slot uint64) ChainSyncOption

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

+ func WithReconnect(enabled bool) ChainSyncOption

+ func WithStore(store Store) ChainSyncOption

+ type ChainSyncOptions struct

+ type Client struct

+ func New(opts ...Option) *Client

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

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

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

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

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

+ func (c *Client) SubmitTx(ctx context.Context, data []byte) (err error)

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

+ func (c *Client) UtxosByTxIn(ctx context.Context, txIns ...chainsync.TxIn) ([]statequery.Utxo, error)

+ type Error struct

+ Fault Fault

+ ServiceName string

+ Type string

+ Version string

+ func (e Error) Error() string

+ type Fault struct

+ Code string

+ String string

+ type KeyValue struct

+ Key string

+ Value string

+ func KV(key, value string) KeyValue

+ type Logger interface

+ Debug func(message string, kvs ...KeyValue)

+ Info func(message string, kvs ...KeyValue)

+ With func(kvs ...KeyValue) Logger

+ type Map map[string]interface

+ type Option func(*Options)

+ func WithEndpoint(endpoint string) Option

+ func WithInterval(n int) Option

+ func WithLogger(logger Logger) Option

+ func WithPipeline(n int) Option

+ type Options struct

+ type Response struct

+ MethodName string

+ Reflection interface{}

+ Result json.RawMessage

+ ServiceName string

+ Type string

+ Version string

+ type Store interface

+ Load func(ctx context.Context) (chainsync.Points, error)

+ Save func(ctx context.Context, point chainsync.Point) error

+ func NewLoggingStore(logger Logger) Store

+ type SubmitTxError struct

+ func (s SubmitTxError) Error() string

+ func (s SubmitTxError) ErrorCodes() (keys []string, err error)

+ func (s SubmitTxError) HasErrorCode(errorCode string) bool

+ func (s SubmitTxError) Messages() []json.RawMessage