idempotency

Documentation

Overview

Package idempotency implements methods to maintain idempotency with the commands received

Index

• Constants
• func CleanupOldIdempotencyEntries(idemCtx context.T)
• func CreateIdempotencyDirectory(idemCtx context.T)
• func CreateIdempotencyEntry(idemCtx context.T, message *contracts.DocumentState) error
• func IsDocumentAlreadyReceived(idemCtx context.T, message *contracts.DocumentState) bool

Constants

const (

	// Name represents idempotency name
	Name = "Idempotency"
)

Functions

func CleanupOldIdempotencyEntries

func CleanupOldIdempotencyEntries(idemCtx context.T)

CleanupOldIdempotencyEntries deletes the commands in idempotency folder after persistenceTimeout minutes

func CreateIdempotencyDirectory

func CreateIdempotencyDirectory(idemCtx context.T)

CreateIdempotencyDirectory creates idempotency directory and logs warn message if could not be created This function passes if the directory is already present

func CreateIdempotencyEntry

func CreateIdempotencyEntry(idemCtx context.T, message *contracts.DocumentState) error

CreateIdempotencyEntry writes command id to the idempotency directory

func IsDocumentAlreadyReceived

func IsDocumentAlreadyReceived(idemCtx context.T, message *contracts.DocumentState) bool

IsDocumentAlreadyReceived checks whether the document was received already