Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChainClient ¶
type ChainClient struct {
// contains filtered or unexported fields
}
ChainClient is responsible for quering chain data.
func NewChainClient ¶
func NewChainClient( cfg *ChainClientConfig, logger *zap.Logger, ) (*ChainClient, error)
NewChainClient creates a new ChainClient instance ready to subscribe to Neutron events.
func (*ChainClient) GetNeutronRegisteredQuery ¶
func (s *ChainClient) GetNeutronRegisteredQuery(ctx context.Context, queryId string) (*neutrontypes.RegisteredQuery, error)
getNeutronRegisteredQuery retrieves a registered query from Neutron.
type ChainClientConfig ¶
type ChainClientConfig struct { // RESTAddress represents the address for REST calls to the chain. RESTAddress string // Timeout defines time limit for requests executed by the ChainClient. Timeout time.Duration // ConnectionID is the Neutron's side connection ID used to filter out queries. ConnectionID string }
ChainClientConfig contains configurable fields for the ChainClient.
Click to show internal directories.
Click to hide internal directories.