commandprocessor

Documentation

Index

• Constants
• Variables
• type CommandChannel
• type ICommandMessage
  • func NewCommandMessage(requestCtx context.Context, body []byte, appQName istructs.AppQName, ...) ICommandMessage
• type OperatorSyncActualizer
• type ServiceFactory
  • func ProvideServiceFactory(appParts appparts.IAppPartitions, now coreutils.TimeFunc, ...) ServiceFactory
• type SyncActualizerFactory
• type VVMName
• type ValidateFunc

Constants

const (
	CommandsTotal     = "voedger_cp_commands_total"
	CommandsSeconds   = "voedger_cp_commands_seconds"
	ErrorsTotal       = "voedger_cp_errors_total"
	ExecSeconds       = "voedger_cp_exec_seconds"
	ProjectorsSeconds = "voedger_cp_projectors_seconds"
)

Variables

var (
	ViewQNamePLogKnownOffsets = appdef.NewQName(appdef.SysPackage, "PLogKnownOffsets")
	ViewQNameWLogKnownOffsets = appdef.NewQName(appdef.SysPackage, "WLogKnownOffsets")
)

Types

type CommandChannel

type CommandChannel iprocbus.ServiceChannel

type ICommandMessage

type ICommandMessage interface {
	Body() []byte
	AppQName() istructs.AppQName
	WSID() istructs.WSID // url WSID
	Sender() ibus.ISender
	PartitionID() istructs.PartitionID
	RequestCtx() context.Context
	QName() appdef.QName
	Token() string
	Host() string
}

func NewCommandMessage

func NewCommandMessage(requestCtx context.Context, body []byte, appQName istructs.AppQName, wsid istructs.WSID, sender ibus.ISender,
	partitionID istructs.PartitionID, qName appdef.QName, token string, host string) ICommandMessage

type OperatorSyncActualizer

type OperatorSyncActualizer pipeline.ISyncOperator

type ServiceFactory

type ServiceFactory func(commandsChannel CommandChannel, partitionID istructs.PartitionID) pipeline.IService

func ProvideServiceFactory

func ProvideServiceFactory(appParts appparts.IAppPartitions, now coreutils.TimeFunc,
	n10nBroker in10n.IN10nBroker, metrics imetrics.IMetrics, vvm VVMName, authenticator iauthnz.IAuthenticator, authorizer iauthnz.IAuthorizer,
	secretReader isecrets.ISecretReader) ServiceFactory

syncActualizerFactory - это фабрика(разделИД), которая возвращает свитч, в бранчах которого по синхронному актуализатору на каждое приложение, внутри каждого - проекторы на каждое приложение

type SyncActualizerFactory

type SyncActualizerFactory func(vvmCtx context.Context, partitionID istructs.PartitionID) pipeline.ISyncOperator

type VVMName

type VVMName string

type ValidateFunc

type ValidateFunc func(ctx context.Context, appStructs istructs.IAppStructs, cudRow istructs.ICUDRow, wsid istructs.WSID) (err error)