claimcheck

package
v0.0.0-...-64decf6 Latest Latest
Warning

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

Go to latest
Published: Nov 7, 2024 License: Apache-2.0 Imports: 14 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InitMetrics

func InitMetrics(registry *prometheus.Registry)

InitMetrics registers all claim check related metrics

func NewFileName

func NewFileName() string

NewFileName return the file name for the message which is delivered to the external storage system. UUID V4 is used to generate random and unique file names. This should not exceed the S3 object name length limit. ref https://docs.aws.amazon.com/AmazonS3/latest/userguide/object-keys.html

Types

type ClaimCheck

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

ClaimCheck manage send message to the claim-check external storage.

func New

New return a new ClaimCheck.

func (*ClaimCheck) CleanMetrics

func (c *ClaimCheck) CleanMetrics()

CleanMetrics the claim check by clean up the metrics.

func (*ClaimCheck) FileNameWithPrefix

func (c *ClaimCheck) FileNameWithPrefix(fileName string) string

FileNameWithPrefix returns the file name with prefix, the full path.

func (*ClaimCheck) WriteMessage

func (c *ClaimCheck) WriteMessage(ctx context.Context, key, value []byte, fileName string) (err error)

WriteMessage write message to the claim check external storage.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL