Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CommonMessageConsumer ¶
type CommonMessageConsumer struct {
// contains filtered or unexported fields
}
func NewCommonMessageConsumer ¶
func NewCommonMessageConsumer(ctx context.Context, providers *factory.ProviderFactory, idt *idempotent.Idempotent, logger *writer.Writer) *CommonMessageConsumer
func (*CommonMessageConsumer) Consume ¶
func (l *CommonMessageConsumer) Consume(elem any) error
type UplinkMessageConsumer ¶
type UplinkMessageConsumer struct {
// contains filtered or unexported fields
}
func NewUplinkMessageConsumer ¶
func NewUplinkMessageConsumer(ctx context.Context, ds store.IStore, idt *idempotent.Idempotent, logger *writer.Writer) *UplinkMessageConsumer
func (*UplinkMessageConsumer) Consume ¶
func (l *UplinkMessageConsumer) Consume(elem any) error
type VerifyMessageConsumer ¶
type VerifyMessageConsumer struct {
// contains filtered or unexported fields
}
func NewVerifyMessageConsumer ¶
func NewVerifyMessageConsumer(ctx context.Context, providers *factory.ProviderFactory, idt *idempotent.Idempotent, logger *writer.Writer) *VerifyMessageConsumer
func (*VerifyMessageConsumer) Consume ¶
func (l *VerifyMessageConsumer) Consume(elem any) error
Source Files
Click to show internal directories.
Click to hide internal directories.