recording

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Apr 10, 2023 License: LGPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type RecordedMessage 

type RecordedMessage struct {
	Offset float64

	Exchange   string
	RoutingKey string

	Pub amqp.Publishing
	// contains filtered or unexported fields
}

func DeliveryToRecordedMessage 

func DeliveryToRecordedMessage(d amqp.Delivery) RecordedMessage

func (RecordedMessage) Publish 

func (rm RecordedMessage) Publish(ch *amqp.Channel) error

type Recording 

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

func NewRecording 

func NewRecording(ctx context.Context, name string, startTimeImmediatly bool) (*Recording, error)

func OpenRecording 

func OpenRecording(ctx context.Context, name string) (*Recording, error)

func (*Recording) Close 

func (r *Recording) Close()

func (*Recording) PlayRecording 

func (r *Recording) PlayRecording() (<-chan RecordedMessage, error)

func (*Recording) RecordMessage 

func (r *Recording) RecordMessage(msg RecordedMessage) error

func (*Recording) StartRecordingTime 

func (r *Recording) StartRecordingTime()

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.