processor

Documentation

Index

• func WithConfig(cfg config.Config) builderFunc
• func WithController(c weak.Pointer[control.Controller]) builderFunc
• func WithSender(b service.ServiceSender) builderFunc
• type ClientHelloProcessor
  • func (p *ClientHelloProcessor) Process(ctx context.Context) error
• type ConnProcessorBuilder
  • func NewConnProcessorBuilder() *ConnProcessorBuilder
  • func (cpb *ConnProcessorBuilder) Build() (Processor, error)
  • func (cpb *ConnProcessorBuilder) SetBase(builderFuncs ...builderFunc) *ConnProcessorBuilder
  • func (cpb *ConnProcessorBuilder) SetConnTask(task *task.ConnTask) *ConnProcessorBuilder
• type EntryProcessor
  • func (ep *EntryProcessor) Process(ctx context.Context) error
• type EventProcessorBuilder
  • func NewEventProcessorBuilder() *EventProcessorBuilder
  • func (epb *EventProcessorBuilder) Build() (Processor, error)
  • func (epb *EventProcessorBuilder) SetBase(builderFuncs ...builderFunc) *EventProcessorBuilder
  • func (epb *EventProcessorBuilder) SetEventTask(task *task.EventTask) *EventProcessorBuilder
• type GetConnectedPeersProcessor
  • func (p *GetConnectedPeersProcessor) Process(ctx context.Context) error
• type GetEntryProcessor
  • func (p *GetEntryProcessor) Process(ctx context.Context) error
• type InitConnectionProcessor
  • func (p *InitConnectionProcessor) Process(ctx context.Context) error
• type IsPeerConnectedProcessor
  • func (p *IsPeerConnectedProcessor) Process(ctx context.Context) error
• type ListenerProcessorBuilder
  • func NewListenerProcessorBuilder() *ListenerProcessorBuilder
  • func (fpb *ListenerProcessorBuilder) Build() (Processor, error)
  • func (fpb *ListenerProcessorBuilder) SetBase(builderFuncs ...builderFunc) *ListenerProcessorBuilder
  • func (fpb *ListenerProcessorBuilder) SetListenerTask(task *task.ListenerTask) *ListenerProcessorBuilder
• type Processor
• type ServerHelloProcessor
  • func (p *ServerHelloProcessor) Process(ctx context.Context) error

Functions

func WithConfig

func WithConfig(cfg config.Config) builderFunc

func WithController

func WithController(c weak.Pointer[control.Controller]) builderFunc

func WithSender

func WithSender(b service.ServiceSender) builderFunc

Types

type ClientHelloProcessor

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

func (*ClientHelloProcessor) Process

func (p *ClientHelloProcessor) Process(ctx context.Context) error

type ConnProcessorBuilder

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

func NewConnProcessorBuilder

func NewConnProcessorBuilder() *ConnProcessorBuilder

func (*ConnProcessorBuilder) Build

func (cpb *ConnProcessorBuilder) Build() (Processor, error)

func (*ConnProcessorBuilder) SetBase

func (cpb *ConnProcessorBuilder) SetBase(builderFuncs ...builderFunc) *ConnProcessorBuilder

func (*ConnProcessorBuilder) SetConnTask

func (cpb *ConnProcessorBuilder) SetConnTask(task *task.ConnTask) *ConnProcessorBuilder

type EntryProcessor

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

func (*EntryProcessor) Process

func (ep *EntryProcessor) Process(ctx context.Context) error

type EventProcessorBuilder

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

func NewEventProcessorBuilder

func NewEventProcessorBuilder() *EventProcessorBuilder

func (*EventProcessorBuilder) Build

func (epb *EventProcessorBuilder) Build() (Processor, error)

func (*EventProcessorBuilder) SetBase

func (epb *EventProcessorBuilder) SetBase(builderFuncs ...builderFunc) *EventProcessorBuilder

func (*EventProcessorBuilder) SetEventTask

func (epb *EventProcessorBuilder) SetEventTask(task *task.EventTask) *EventProcessorBuilder

type GetConnectedPeersProcessor

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

func (*GetConnectedPeersProcessor) Process

func (p *GetConnectedPeersProcessor) Process(ctx context.Context) error

type GetEntryProcessor

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

func (*GetEntryProcessor) Process

func (p *GetEntryProcessor) Process(ctx context.Context) error

type InitConnectionProcessor

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

func (*InitConnectionProcessor) Process

func (p *InitConnectionProcessor) Process(ctx context.Context) error

TODO: check if the peer is already connected before processing the event. TODO: handle the case where we trying to connect to the peer which is being connected to by another worker or another event.

type IsPeerConnectedProcessor

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

func (*IsPeerConnectedProcessor) Process

func (p *IsPeerConnectedProcessor) Process(ctx context.Context) error

type ListenerProcessorBuilder

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

func NewListenerProcessorBuilder

func NewListenerProcessorBuilder() *ListenerProcessorBuilder

func (*ListenerProcessorBuilder) Build

func (fpb *ListenerProcessorBuilder) Build() (Processor, error)

func (*ListenerProcessorBuilder) SetBase

func (fpb *ListenerProcessorBuilder) SetBase(builderFuncs ...builderFunc) *ListenerProcessorBuilder

func (*ListenerProcessorBuilder) SetListenerTask

func (fpb *ListenerProcessorBuilder) SetListenerTask(task *task.ListenerTask) *ListenerProcessorBuilder

type Processor

type Processor interface {
	// Processes the given task.
	Process(ctx context.Context) error
}

type ServerHelloProcessor

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

func (*ServerHelloProcessor) Process

func (p *ServerHelloProcessor) Process(ctx context.Context) error