processors

Documentation

Index

• type Processor
  • func NewProcessor(cfg *config.Config, rpcClient *client.Client, hd *handlers.SubHandler) (*Processor, error)
  • func (p *Processor) Close(ctx context.Context) error
  • func (p *Processor) Start(ctx context.Context) error
  • func (p *Processor) SubscribeEventType(ctx context.Context, eventType types.EventType) error
  • func (p *Processor) SubscribeEvents(ctx context.Context) error

Types

type Processor

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

func NewProcessor

func NewProcessor(cfg *config.Config, rpcClient *client.Client, hd *handlers.SubHandler) (*Processor, error)

NewProcessor creates a new processor

func (*Processor) Close

func (p *Processor) Close(ctx context.Context) error

func (*Processor) Start

func (p *Processor) Start(ctx context.Context) error

func (*Processor) SubscribeEventType

func (p *Processor) SubscribeEventType(ctx context.Context, eventType types.EventType) error

SubscribeEventType subscribes to one event type https://docs.sui.io/build/event_api#event-filters

func (*Processor) SubscribeEvents

func (p *Processor) SubscribeEvents(ctx context.Context) error