subscriptions

Documentation

Index

• func CallEventsPlatformGRPCWithRetry[T any](operation func() (T, error)) (T, error)
• func WaitCheckNodeExistsInNeo4j(ctx context.Context, neo4jRepository *neo4jrepository.Repositories, ...) bool
• type Subscriptions
  • func NewSubscriptions(log logger.Logger, db *esdb.Client, cfg *config.Config) *Subscriptions
  • func (s *Subscriptions) RefreshSubscriptions(ctx context.Context) error
• type Worker

Functions

func CallEventsPlatformGRPCWithRetry

func CallEventsPlatformGRPCWithRetry[T any](operation func() (T, error)) (T, error)

func WaitCheckNodeExistsInNeo4j

func WaitCheckNodeExistsInNeo4j(ctx context.Context, neo4jRepository *neo4jrepository.Repositories, tenant, id, nodeLabel string) bool

Types

type Subscriptions

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

func NewSubscriptions

func NewSubscriptions(log logger.Logger, db *esdb.Client, cfg *config.Config) *Subscriptions

func (*Subscriptions) RefreshSubscriptions

func (s *Subscriptions) RefreshSubscriptions(ctx context.Context) error

type Worker

type Worker func(ctx context.Context, sub *esdb.PersistentSubscription, workerID int) error