commandprocessor

package

v1.202405300917.1 Latest Latest Go to latest Published: May 30, 2024 License: MIT Imports: 31 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/voedger/voedger

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 ¶

View Source

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 ¶

View Source

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

Functions ¶

This section is empty.

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)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL