event

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Mar 18, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewStream 

func NewStream(cfg *config.Config) (events.Stream, error)

NewStream prepares the requested nats stream and returns it.

Types

type PurgeTrashBin 

type PurgeTrashBin struct {
	ExecutantID   *apiUser.UserId
	ExecutionTime time.Time
}

PurgeTrashBin wraps all needed information to purge a trash-bin

func (PurgeTrashBin) Unmarshal 

func (PurgeTrashBin) Unmarshal(v []byte) (interface{}, error)

Unmarshal to fulfill umarshaller interface

type Service 

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

Service wraps all common logic that is needed to react to incoming events.

func NewService 

func NewService(ctx context.Context, gatewaySelector pool.Selectable[apiGateway.GatewayAPIClient], eventStream events.Stream, logger log.Logger, conf config.Config) (Service, error)

NewService prepares and returns a Service implementation.

func (Service) Run 

func (s Service) Run() error

Run to fulfil Runner interface

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.