kvprocessor

Documentation

Index

• type KVProcessor
  • func NewKVProcessor(trustedHeaderFetcher relay.TrustedHeaderFetcher, querier *tmquerier.Querier, ...) *KVProcessor
  • func (p *KVProcessor) ProcessAndSubmit(ctx context.Context, m *relay.MessageKV) error

Types

type KVProcessor

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

KVProcessor is implementation of relay.KVProcessor that processes event query KV type. Obtains the proof for a query we need to process, and sends it to the neutron

func NewKVProcessor

func NewKVProcessor(
	trustedHeaderFetcher relay.TrustedHeaderFetcher,
	querier *tmquerier.Querier,
	logger *zap.Logger,
	submitter relay.Submitter,
	targetChain *relayer.Chain,
	neutronChain *relayer.Chain) *KVProcessor

func (*KVProcessor) ProcessAndSubmit

func (p *KVProcessor) ProcessAndSubmit(ctx context.Context, m *relay.MessageKV) error

ProcessAndSubmit processes relay.MessageKV. The main method which does all the work of the KVProcessor