proc

Documentation

Index

• type Dependencies
• type PassState
  • func NewPassState(msg payload.Meta) *PassState
  • func (p *PassState) Proceed(ctx context.Context) error
• type Replication
  • func NewReplication(msg payload.Meta, cfg configuration.Ledger) *Replication
  • func (p *Replication) Dep(replicator executor.HeavyReplicator)
  • func (p *Replication) Proceed(ctx context.Context) error
• type SearchIndex
  • func NewSearchIndex(meta payload.Meta) *SearchIndex
  • func (p *SearchIndex) Dep(indexes object.IndexAccessor, pulseCalculator pulse.Calculator, ...)
  • func (p *SearchIndex) Proceed(ctx context.Context) error
• type SendCode
  • func NewSendCode(msg payload.Meta) *SendCode
  • func (p *SendCode) Proceed(ctx context.Context) error
• type SendIndex
  • func NewSendIndex(meta payload.Meta) *SendIndex
  • func (p *SendIndex) Dep(indexes object.IndexAccessor, sender bus.Sender)
  • func (p *SendIndex) Proceed(ctx context.Context) error
• type SendInitialState
  • func NewSendInitialState(meta payload.Meta) *SendInitialState
  • func (p *SendInitialState) Dep(startPulse pulse.StartPulse, jetKeeper executor.JetKeeper, ...)
  • func (p *SendInitialState) Proceed(ctx context.Context) error
• type SendJet
  • func NewSendJet(meta payload.Meta) *SendJet
  • func (p *SendJet) Dep(jets jet.Accessor, sender bus.Sender)
  • func (p *SendJet) Proceed(ctx context.Context) error
• type SendRequest
  • func NewSendRequest(meta payload.Meta) *SendRequest
  • func (p *SendRequest) Dep(records object.RecordAccessor, sender bus.Sender)
  • func (p *SendRequest) Proceed(ctx context.Context) error
• type SendRequests
  • func NewSendRequests(meta payload.Meta) *SendRequests
  • func (p *SendRequests) Dep(sender bus.Sender, records object.RecordAccessor, indexes object.IndexAccessor)
  • func (p *SendRequests) Proceed(ctx context.Context) error

Types

type Dependencies

type Dependencies struct {
	PassState        func(*PassState)
	SendCode         func(*SendCode)
	SendRequests     func(*SendRequests)
	SendRequest      func(*SendRequest)
	Replication      func(*Replication)
	SendJet          func(*SendJet)
	SendIndex        func(*SendIndex)
	SearchIndex      func(*SearchIndex)
	SendInitialState func(*SendInitialState)
}

type PassState

type PassState struct {
	Dep struct {
		Sender  bus.Sender
		Records object.RecordAccessor
		Pulses  pulse.Accessor
	}
	// contains filtered or unexported fields
}

func NewPassState

func NewPassState(msg payload.Meta) *PassState

func (*PassState) Proceed

func (p *PassState) Proceed(ctx context.Context) error

type Replication

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

func NewReplication

func NewReplication(msg payload.Meta, cfg configuration.Ledger) *Replication

func (*Replication) Dep

func (p *Replication) Dep(
	replicator executor.HeavyReplicator,
)

func (*Replication) Proceed

func (p *Replication) Proceed(ctx context.Context) error

type SearchIndex

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

func NewSearchIndex

func NewSearchIndex(meta payload.Meta) *SearchIndex

func (*SearchIndex) Dep

func (p *SearchIndex) Dep(
	indexes object.IndexAccessor,
	pulseCalculator pulse.Calculator,
	pulseStorage pulse.Accessor,
	sender bus.Sender,
)

func (*SearchIndex) Proceed

func (p *SearchIndex) Proceed(ctx context.Context) error

type SendCode

type SendCode struct {
	Dep struct {
		RecordAccessor object.RecordAccessor
		Sender         bus.Sender
	}
	// contains filtered or unexported fields
}

func NewSendCode

func NewSendCode(msg payload.Meta) *SendCode

func (*SendCode) Proceed

func (p *SendCode) Proceed(ctx context.Context) error

type SendIndex

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

func NewSendIndex

func NewSendIndex(meta payload.Meta) *SendIndex

func (*SendIndex) Dep

func (p *SendIndex) Dep(
	indexes object.IndexAccessor,
	sender bus.Sender,
)

func (*SendIndex) Proceed

func (p *SendIndex) Proceed(ctx context.Context) error

type SendInitialState

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

func NewSendInitialState

func NewSendInitialState(meta payload.Meta) *SendInitialState

func (*SendInitialState) Dep

func (p *SendInitialState) Dep(
	startPulse pulse.StartPulse,
	jetKeeper executor.JetKeeper,
	initialState executor.InitialStateAccessor,
	pulseAccessor pulse.Accessor,
	sender bus.Sender,
)

func (*SendInitialState) Proceed

func (p *SendInitialState) Proceed(ctx context.Context) error

type SendJet

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

func NewSendJet

func NewSendJet(meta payload.Meta) *SendJet

func (*SendJet) Dep

func (p *SendJet) Dep(
	jets jet.Accessor,
	sender bus.Sender,
)

func (*SendJet) Proceed

func (p *SendJet) Proceed(ctx context.Context) error

type SendRequest

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

func NewSendRequest

func NewSendRequest(meta payload.Meta) *SendRequest

func (*SendRequest) Dep

func (p *SendRequest) Dep(records object.RecordAccessor, sender bus.Sender)

func (*SendRequest) Proceed

func (p *SendRequest) Proceed(ctx context.Context) error

type SendRequests

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

func NewSendRequests

func NewSendRequests(meta payload.Meta) *SendRequests

func (*SendRequests) Dep

func (p *SendRequests) Dep(sender bus.Sender, records object.RecordAccessor, indexes object.IndexAccessor)

func (*SendRequests) Proceed

func (p *SendRequests) Proceed(ctx context.Context) error