ogmigo

Dec 31, 2021

Changes in this version

type SubmitTxError

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

Dec 12, 2021

Changes in this version

+ type Response struct

+ MethodName string

+ Reflection interface{}

+ Result json.RawMessage

+ ServiceName string

+ Type string

+ Version string

+ type SubmitTxError struct

+ func (s SubmitTxError) Error() string

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

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

Dec 10, 2021

Changes in this version

+ type ChainSync struct

+ func (c *ChainSync) Close() error

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

type ChainSyncOption

+ func WithReconnect(enabled bool) ChainSyncOption

Dec 6, 2021

Changes in this version

type ChainSyncOption

+ func WithMinSlot(slot uint64) ChainSyncOption

Nov 29, 2021

Changes in this version

type Client

+ 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, signedTx []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 Map map[string]interface

Nov 27, 2021

Changes in this version

type Store

+ func NewLoggingStore(logger Logger) Store

Nov 26, 2021

Changes in this version

+ var DefaultLogger = defaultLogger

+ var NopLogger = nopLogger

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

+ type ChainSyncOption func(opts *ChainSyncOptions)

+ func WithPoints(points ...chainsync.Point) 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) (io.Closer, error)

+ 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 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 Store interface

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

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