tsnclient

Documentation

Index

• type Client
  • func NewClient(ctx context.Context, provider string, options ...Option) (*Client, error)
  • func (c *Client) Address() util.EthereumAddress
  • func (c *Client) DeployStream(ctx context.Context, streamId util.StreamId, streamType clientType.StreamType) (transactions.TxHash, error)
  • func (c *Client) DestroyStream(ctx context.Context, streamId util.StreamId) (transactions.TxHash, error)
  • func (c *Client) GetKwilClient() *kwilClientPkg.Client
  • func (c *Client) GetSigner() auth.Signer
  • func (c *Client) LoadComposedStream(streamLocator clientType.StreamLocator) (clientType.IComposedStream, error)
  • func (c *Client) LoadPrimitiveStream(streamLocator clientType.StreamLocator) (clientType.IPrimitiveStream, error)
  • func (c *Client) LoadStream(streamLocator clientType.StreamLocator) (clientType.IStream, error)
  • func (c *Client) OwnStreamLocator(streamId util.StreamId) clientType.StreamLocator
  • func (c *Client) Validate() error
  • func (c *Client) WaitForTx(ctx context.Context, txHash transactions.TxHash, interval time.Duration) (*transactions.TcTxQueryResponse, error)
• type Option
  • func WithLogger(logger log.Logger) Option
  • func WithSigner(signer auth.Signer) Option

Types

type Client

type Client struct {
	Signer auth.Signer `validate:"required"`
	// contains filtered or unexported fields
}

func NewClient

func NewClient(ctx context.Context, provider string, options ...Option) (*Client, error)

func (*Client) Address

func (c *Client) Address() util.EthereumAddress

func (*Client) DeployStream

func (c *Client) DeployStream(ctx context.Context, streamId util.StreamId, streamType clientType.StreamType) (transactions.TxHash, error)

func (*Client) DestroyStream

func (c *Client) DestroyStream(ctx context.Context, streamId util.StreamId) (transactions.TxHash, error)

func (*Client) GetKwilClient

func (c *Client) GetKwilClient() *kwilClientPkg.Client

func (*Client) GetSigner

func (c *Client) GetSigner() auth.Signer

func (*Client) LoadComposedStream

func (c *Client) LoadComposedStream(streamLocator clientType.StreamLocator) (clientType.IComposedStream, error)

func (*Client) LoadPrimitiveStream

func (c *Client) LoadPrimitiveStream(streamLocator clientType.StreamLocator) (clientType.IPrimitiveStream, error)

func (*Client) LoadStream

func (c *Client) LoadStream(streamLocator clientType.StreamLocator) (clientType.IStream, error)

func (*Client) OwnStreamLocator

func (c *Client) OwnStreamLocator(streamId util.StreamId) clientType.StreamLocator

func (*Client) Validate

func (c *Client) Validate() error

func (*Client) WaitForTx

func (c *Client) WaitForTx(ctx context.Context, txHash transactions.TxHash, interval time.Duration) (*transactions.TcTxQueryResponse, error)

type Option

type Option func(*Client)

func WithLogger

func WithLogger(logger log.Logger) Option

func WithSigner

func WithSigner(signer auth.Signer) Option