messaging

Documentation

Index

• type LogStream
  • func NewLogStream(client *redis.Client, log *logrus.Logger, streamName string) *LogStream
• type Stream
  • func (s *Stream[T]) GetStream() string
  • func (s *Stream[T]) Send(ctx context.Context, event T) error

Types

type LogStream

type LogStream struct {
	Stream[*model.LogAuditTrailEvent]
}

func NewLogStream

func NewLogStream(
	client *redis.Client,
	log *logrus.Logger,
	streamName string,
) *LogStream

type Stream

type Stream[T model.Event] struct {
	StreamName string
	Log        *logrus.Logger
	// contains filtered or unexported fields
}

func (*Stream[T]) GetStream

func (s *Stream[T]) GetStream() string

func (*Stream[T]) Send

func (s *Stream[T]) Send(ctx context.Context, event T) error