corepubsubinf

package
v1.3.24 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 25, 2022 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AnyItemSubscribeFunc 

type AnyItemSubscribeFunc func(
	categoryRevealer coreinterface.CategoryRevealer,
	anyItem interface{},
)

type BaseJsonResulterSubscribeFunc added in v1.3.13 

type BaseJsonResulterSubscribeFunc func(
	categoryRevealer coreinterface.CategoryRevealer,
	result serializerinf.BaseJsonResulter,
)

type BaseLogModeler 

type BaseLogModeler interface {
	enuminf.LoggerTyperGetter
	enuminf.EventTyperGetter
	errcoreinf.BasicErrorTyperGetter
	errcoreinf.ErrorStringGetter
	coreinterface.StackTracesBytesGetter
	coreinterface.JsonErrorBytesGetter
	IsEmpty() bool
	LogMessage() string
}

type BooleanSubscribeFunc 

type BooleanSubscribeFunc func(
	categoryRevealer coreinterface.CategoryRevealer,
	isResult bool,
)

type BytesSubscribeFunc 

type BytesSubscribeFunc func(
	categoryRevealer coreinterface.CategoryRevealer,
	rawBytes []byte,
)

type CategoryNameAnyItemSubscriptionFunc 

type CategoryNameAnyItemSubscriptionFunc func(categoryName string, anyItem interface{})

type CommunicateModeler 

type CommunicateModeler interface {
	BaseLogModeler() BaseLogModeler
	PersistentId() uint
	IdAsStringer
	TableName() string

	SetCallerFileLineUsingStackSkip(
		stackSkip int,
	)

	loggerinf.SingleLogModeler
}

type CompletePublisher 

type CompletePublisher interface {
	errcoreinf.ErrorCompleter
}

type CompletionFunc 

type CompletionFunc func(subscriptionRecorder SubscriptionRecorder)

type DirectAnyItemSubscribeFunc 

type DirectAnyItemSubscribeFunc func(
	anyItem interface{},
)

type DirectBaseErrorOrCollectionWrapperSubscribeFunc 

type DirectBaseErrorOrCollectionWrapperSubscribeFunc func(
	basicErrorWrapper errcoreinf.BaseErrorOrCollectionWrapper,
)

type DirectBaseJsonResulterSubscribeFunc added in v1.3.13 

type DirectBaseJsonResulterSubscribeFunc func(
	result serializerinf.BaseJsonResulter,
)

type DirectBasicErrorSubscribeFunc 

type DirectBasicErrorSubscribeFunc func(
	basicErrorWrapper errcoreinf.BasicErrWrapper,
)

type DirectBooleanSubscribeFunc 

type DirectBooleanSubscribeFunc func(
	isResult bool,
)

type DirectBytesSubscribeFunc 

type DirectBytesSubscribeFunc func(
	rawBytes []byte,
)

type DirectJsonResultSubscribeFunc 

type DirectJsonResultSubscribeFunc func(
	jsonResult *corejson.Result,
)

type DirectJsonResulterSubscribeFunc added in v1.3.13 

type DirectJsonResulterSubscribeFunc func(
	result serializerinf.JsonResulter,
)

type DirectModelJsonSubscribeFunc 

type DirectModelJsonSubscribeFunc func(
	modelJson []byte,
)

type DirectSimpleBytesResulterSubscribeFunc added in v1.3.13 

type DirectSimpleBytesResulterSubscribeFunc func(
	result serializerinf.SimpleBytesResulter,
)

type DirectSingleLogModelerSubscribeFunc 

type DirectSingleLogModelerSubscribeFunc func(modeler loggerinf.SingleLogModeler)

type DirectStringSubscribeFunc 

type DirectStringSubscribeFunc func(
	message string,
)

type DirectSubscriber 

type DirectSubscriber interface {
	// SimpleSubscribe
	//
	//  All message listener
	SimpleSubscribe(
		subscribersFunctions ...SimpleSubscribeFunc,
	)

	All(
		subscribersFunctions ...SimpleSubscribeFunc,
	)

	BasicErrorWrapper(
		basicErrorWrapperSubscribeFunc DirectBasicErrorSubscribeFunc,
	)

	BaseErrorOrCollectionWrapper(
		subscriberFunc DirectBaseErrorOrCollectionWrapperSubscribeFunc,
	)

	JsonResultError(
		subscriberFunc DirectJsonResultSubscribeFunc,
	)

	String(
		messageFunc DirectStringSubscribeFunc,
	)

	AnyItem(
		subscribedFunc DirectAnyItemSubscribeFunc,
	)

	Bytes(
		subscribedFunc DirectBytesSubscribeFunc,
	) *sync.WaitGroup

	JsonBytes(
		subscribedFunc DirectModelJsonSubscribeFunc,
	)

	SimpleBytesResulter(
		subscribedFunc DirectSimpleBytesResulterSubscribeFunc,
	)

	JsonResulter(
		subscribedFunc DirectJsonResulterSubscribeFunc,
	)

	HashmapSubscriberFunc(
		subscriberFunc HashmapSubscribeFunc,
	)

	JsonResult(
		subscribedFunc DirectJsonResultSubscribeFunc,
	)

	SegmentAll(
		allSubscriberFunc SimpleSubscribeFunc,
		successSubscriberFunc SimpleSubscribeFunc,
		infoSubscriberFunc SimpleSubscribeFunc,
		traceSubscriberFunc SimpleSubscribeFunc,
		debugSubscriberFunc SimpleSubscribeFunc,
		errorSubscriberFunc SimpleSubscribeFunc,
		fatalSubscriberFunc SimpleSubscribeFunc,
		panicSubscriberFunc SimpleSubscribeFunc,
	)

	MessageSegmentAll(
		allSubscriberFunc DirectStringSubscribeFunc,
		successSubscriberFunc DirectStringSubscribeFunc,
		infoSubscriberFunc DirectStringSubscribeFunc,
		traceSubscriberFunc DirectStringSubscribeFunc,
		debugSubscriberFunc DirectStringSubscribeFunc,
		errorSubscriberFunc DirectStringSubscribeFunc,
		fatalSubscriberFunc DirectStringSubscribeFunc,
		panicSubscriberFunc DirectStringSubscribeFunc,
	)

	SegmentFew(
		allSubscriberFunc SimpleSubscribeFunc,
		errorSubscriberFunc SimpleSubscribeFunc,
		fatalSubscriberFunc SimpleSubscribeFunc,
	)

	MessageSegmentFew(
		allSubscriberFunc DirectStringSubscribeFunc,
		errorSubscriberFunc DirectStringSubscribeFunc,
		fatalSubscriberFunc DirectStringSubscribeFunc,
	)
}

type FilterAnyItemSubscriptionFunc added in v1.3.8 

type FilterAnyItemSubscriptionFunc func(filter string, anyItem interface{})

type FilterBytesSubscriptionFunc added in v1.3.8 

type FilterBytesSubscriptionFunc func(filter string, rawBytes []byte)

type FilterStringSubscribeFunc 

type FilterStringSubscribeFunc func(communicate CommunicateModeler, currentStringValue string)

type FilterSubscriber 

type FilterSubscriber interface {
	FilterText() string

	Filter(
		filterSubscribers SimpleCompletionFunc,
	)

	SkipFilter(
		skipFilterFunc SimpleCompletionFunc,
	)

	CategoryFilter(
		filterSubscribeFunc SimpleCompletionFunc,
	)

	FilterAnyItem(
		subscribers ...FilterAnyItemSubscriptionFunc,
	)

	FilterBytes(
		subscribers ...FilterBytesSubscriptionFunc,
	)
}

type GenericPublisher 

type GenericPublisher interface {
	EnvOptioner() enuminf.EnvironmentOptioner

	All(communicate CommunicateModeler) GenericPublisher

	Message(
		category coreinterface.CategoryRevealer,
		message string,
	) GenericPublisher

	Boolean(
		category coreinterface.CategoryRevealer,
		isResult bool,
	) GenericPublisher

	JsonResult(
		jsonResult *corejson.Result,
	) GenericPublisher

	CategoryMessage(
		categoryName,
		message string,
	) GenericPublisher

	AnyItem(
		categoryName string,
		anyItem interface{},
	) GenericPublisher

	AnyItemDirect(
		anyItem interface{},
	) GenericPublisher

	BytesDirect(
		rawBytes []byte,
	) GenericPublisher

	BooleanDirect(
		isResult bool,
	) GenericPublisher

	Jsoner(
		jsoner corejson.Jsoner,
	) GenericPublisher

	FilterJsoner(
		filterText string,
		jsoner corejson.Jsoner,
	) GenericPublisher

	FilterMessage(
		filterText,
		message string,
	) GenericPublisher

	FilterMetaCompiler(
		filterText,
		title string,
		compiler loggerinf.MetaAttributesCompiler,
	) GenericPublisher

	FilterJsonResult(
		filterText,
		jsonResult *corejson.Result,
	) GenericPublisher

	LogTyperAnyItem(
		logTyper enuminf.LoggerTyper,
		anyItem interface{},
	) GenericPublisher

	Fmt(
		format string,
		v ...interface{},
	) GenericPublisher

	FilterFmt(
		filter,
		format string,
		v ...interface{},
	) GenericPublisher

	LogTyperAnyItemCategory(
		logTyper enuminf.LoggerTyper,
		categoryName string,
		anyItem interface{},
	) GenericPublisher

	Success() LogTyperPublisher
	Info() LogTyperPublisher
	Debug() LogTyperPublisher
	Error() LogTyperPublisher
	Warn() LogTyperPublisher
	Failure() LogTyperPublisher
	Trace() LogTyperPublisher

	OnDebug() LogTyperPublisher
	OnVerbose() LogTyperPublisher

	OnCondition(isMatch bool) LogTyperPublisher
	OnFlag(name, value string) LogTyperPublisher
	OnFlagEnabled(flagName string) LogTyperPublisher
	OnFlagDisabled(flagName string) LogTyperPublisher

	OnMatcherFunc(
		logTyper enuminf.LoggerTyper,
		matcherFunc MatcherFunc,
	) LogTyperPublisher

	Write(p []byte) (n int, err error)
	AsWriter() io.Writer
	AsWriterByLogTyper(logTyper enuminf.LoggerTyper) io.Writer
	AsWriterByLogTyperFilterText(logTyper enuminf.LoggerTyper, filterText string) io.Writer

	AnErr(err error) GenericPublisher
	Err(title string, err error) GenericPublisher
	BaseErrOrCollection(baseErrOrCollection errcoreinf.BaseErrorOrCollectionWrapper) GenericPublisher
	BasicErrWrapper(basicErrWrapper errcoreinf.BasicErrWrapper) GenericPublisher
	BaseErrorWrapperCollectionDefiner(baseErrOrCollection errcoreinf.BaseErrorWrapperCollectionDefiner) GenericPublisher
	BaseRawErrCollectionDefiner(baseErrOrCollection errcoreinf.BaseRawErrCollectionDefiner) GenericPublisher

	loggerinf.AllLogWriter

	LogTyper(
		logTyper enuminf.LoggerTyper,
	) LogTyperPublisher

	CompletePublisher
	coreinterface.IsCompletedLockUnlockChecker
}

type GenericSubscriber 

type GenericSubscriber interface {
	EnvOptioner() enuminf.EnvironmentOptioner

	OnStart(
		subscribers ...StartFunc,
	) *sync.WaitGroup

	OnComplete(
		subscribers ...CompletionFunc,
	) *sync.WaitGroup

	OnStartComplete(
		startFunc StartFunc,
		completeFunc CompletionFunc,
	) *sync.WaitGroup

	CategoryAnyItem(
		subscribers ...CategoryNameAnyItemSubscriptionFunc,
	) GenericSubscriber

	LogTyperCategoryAnyItem(
		logTyper enuminf.LoggerTyper,
		subscribers ...CategoryNameAnyItemSubscriptionFunc,
	) *sync.WaitGroup

	SingleLogModeler(
		subscriberFunc func(modeler loggerinf.SingleLogModeler),
	) *sync.WaitGroup

	LogTyperSingleLogModeler(
		logTyper enuminf.LoggerTyper,
		subscriberFunc DirectSingleLogModelerSubscribeFunc,
	) *sync.WaitGroup

	JsonResultFunc(
		subscriberFunc JsonResultSubscribeFunc,
	) *sync.WaitGroup

	MessageSubscriberFunc(
		subscriberFunc StringSubscribeFunc,
	) *sync.WaitGroup

	JsonBytesSubscriberFunc(
		subscriberFunc ModelJsonSubscribeFunc,
	) *sync.WaitGroup

	MapAnySubscriberFunc(
		subscriberFunc func(
			category coreinterface.CategoryRevealer,
			mapAny map[string]interface{},
		),
	) *sync.WaitGroup

	CategorySimpleBytesResulter(
		subscribedFunc SimpleBytesResulterSubscribeFunc,
	)

	CategoryJsonResulter(
		subscribedFunc JsonResulterSubscribeFunc,
	)

	Success() GenericSubscriber
	Info() GenericSubscriber
	Debug() GenericSubscriber
	Warn() GenericSubscriber
	Error() GenericSubscriber
	Failure() GenericSubscriber
	Trace() GenericSubscriber

	OnDebug() GenericSubscriber
	OnVerbose() GenericSubscriber

	OnFlag(name, value string) GenericSubscriber
	OnAnyFlag(name string, value interface{}) GenericSubscriber
	OnFlagEnabled(name string) GenericSubscriber
	OnFlagDisabled(name string) GenericSubscriber
	StackSkip(index int) GenericSubscriber

	coreinterface.IsCompletedLockUnlockChecker

	OnMatch(isCondition bool) GenericSubscriber
	OnErr(err error) GenericSubscriber
	OnString(message string) GenericSubscriber
	OnConditionFunc(isSubscribed func() bool) GenericSubscriber

	WaitAll(waitGroups ...*sync.WaitGroup) errcoreinf.BasicErrWrapper
	WaitGroupUntilCompleteLazy() *sync.WaitGroup
	WaitUntilComplete()

	DirectSubscriber
	FilterSubscriber
}

type HashmapSubscribeFunc 

type HashmapSubscribeFunc func(
	categoryRevealer coreinterface.CategoryRevealer,
	hashmap map[string]string,
)

type IdAsStringer 

type IdAsStringer interface {
	internalinterface.IdAsStringer
}

type JsonResultSubscribeFunc 

type JsonResultSubscribeFunc func(
	categoryRevealer coreinterface.CategoryRevealer,
	jsonResult *corejson.Result,
)

type JsonResulterSubscribeFunc added in v1.3.13 

type JsonResulterSubscribeFunc func(
	categoryRevealer coreinterface.CategoryRevealer,
	result serializerinf.JsonResulter,
)

type LogSubscriberFunc 

type LogSubscriberFunc func(logRecord BaseLogModeler)

type LogTyperPublisher 

type LogTyperPublisher interface {
	LogTyper() enuminf.LoggerTyper
	FilterText() string

	Msg(message string) LogTyperPublisher
	Title(message string) LogTyperPublisher
	TitleAttr(message, attr string) LogTyperPublisher

	Message(
		category coreinterface.CategoryRevealer,
		message string,
	) LogTyperPublisher

	Boolean(
		category coreinterface.CategoryRevealer,
		isResult bool,
	) GenericPublisher

	MetaStacker() loggerinf.MetaAttributesStacker

	DirectMessage(
		message string,
	) LogTyperPublisher

	JsonResult(
		jsonResult *corejson.Result,
	) LogTyperPublisher

	CategoryMessage(
		categoryName,
		message string,
	) LogTyperPublisher

	SimpleModeler(
		communicate CommunicateModeler,
	) LogTyperPublisher

	AnyItem(
		categoryName string,
		anyItem interface{},
	) LogTyperPublisher

	AnyItemDirect(
		anyItem interface{},
	) LogTyperPublisher

	BytesDirect(
		rawBytes []byte,
	) LogTyperPublisher

	BooleanDirect(
		isResult bool,
	) LogTyperPublisher

	Jsoner(
		jsoner corejson.Jsoner,
	) LogTyperPublisher

	FilterJsoner(
		filterText string,
		jsoner corejson.Jsoner,
	) LogTyperPublisher

	FilterMessage(
		filterText,
		message string,
	) LogTyperPublisher

	FilterMetaCompiler(
		filterText,
		title string,
		compiler loggerinf.MetaAttributesCompiler,
	) LogTyperPublisher

	FilterJsonResult(
		filterText string,
		jsonResult *corejson.Result,
	) LogTyperPublisher

	FilterAnyItem(
		filterText string,
		anyItem interface{},
	) LogTyperPublisher

	FilterCategoryAnyItem(
		filterText, categoryName string,
		anyItem interface{},
	) LogTyperPublisher

	Fmt(
		format string,
		v ...interface{},
	) LogTyperPublisher

	FilterFmt(
		filter,
		format string,
		v ...interface{},
	) LogTyperPublisher

	Hashmap(
		categoryName string,
		hashmap map[string]string,
	) LogTyperPublisher

	HashmapFilter(
		filter, categoryName string,
		hashmap map[string]string,
	) LogTyperPublisher

	DirectHashmap(
		hashmap map[string]string,
	) LogTyperPublisher

	DirectHashset(
		hashset map[string]bool,
	) LogTyperPublisher

	StackSkip(stackSkip int) LogTyperPublisher

	AnErr(err error) LogTyperPublisher
	Err(title string, err error) LogTyperPublisher
	BaseErrOrCollection(baseErrOrCollection errcoreinf.BaseErrorOrCollectionWrapper) LogTyperPublisher
	BasicErrWrapper(basicErrWrapper errcoreinf.BasicErrWrapper) LogTyperPublisher
	BaseErrorWrapperCollectionDefiner(baseErrOrCollection errcoreinf.BaseErrorWrapperCollectionDefiner) LogTyperPublisher
	BaseRawErrCollectionDefiner(baseErrOrCollection errcoreinf.BaseRawErrCollectionDefiner) LogTyperPublisher

	OnMatch(isMatch bool) LogTyperPublisher
	OnMatcherFunc(matcherFunc MatcherFunc) LogTyperPublisher

	Write(p []byte) (n int, err error)
	AsWriter() io.Writer

	CompletePublisher
	Publisher() GenericPublisher
}

type MatcherFunc 

type MatcherFunc func() (isMatch bool)

type Middleware added in v1.3.13 

type Middleware interface {
	GenericSubscriber
}

type ModelJsonSubscribeFunc 

type ModelJsonSubscribeFunc func(
	categoryRevealer coreinterface.CategoryRevealer,
	modelJson []byte,
)

type PublisherSubscriber added in v1.3.13 

type PublisherSubscriber interface {
	Subscriber() GenericSubscriber
	Middleware() Middleware
	Publisher() PublisherSubscriber
}

type SimpleBytesResulterSubscribeFunc added in v1.3.13 

type SimpleBytesResulterSubscribeFunc func(
	categoryRevealer coreinterface.CategoryRevealer,
	result serializerinf.SimpleBytesResulter,
)

type SimpleCompletionFunc 

type SimpleCompletionFunc func(communicate CommunicateModeler)

type SimpleSubscribeFunc 

type SimpleSubscribeFunc func(communicate CommunicateModeler)

type StartEndSubscriptionFunc 

type StartEndSubscriptionFunc func(isStart bool, subscriptionRecorder SubscriptionRecorder)

type StartFunc 

type StartFunc func(subscriptionRecorder SubscriptionRecorder)

type StringSubscribeFunc 

type StringSubscribeFunc func(
	categoryRevealer coreinterface.CategoryRevealer,
	message string,
)

type SubscribeFunc 

type SubscribeFunc func(
	subscriptionRecorder SubscriptionRecorder,
)

type SubscriptionMainRecorder 

type SubscriptionMainRecorder interface {
	IdAsStringer
	TableName() string

	IsEmpty() bool

	pathextendinf.PathExtenderGetter

	HasRecordError() bool
	SetRecordError() bool
	IsArchivedRecord() bool
	IsCompletedRecord() bool
	IsMigratedRecord() bool
	CompletionTyper() enuminf.CompletionStateTyper

	// DefaultDelayMillis
	//
	//  Default delay in milliseconds
	DefaultDelayMillis() int
}

type SubscriptionRecorder 

type SubscriptionRecorder interface {
	MainRecord() SubscriptionMainRecorder
	CommunicateRecord() CommunicateModeler
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.