batchutils

Documentation

Index

• func BatchGet(ctx context.Context, props *BatchGetRequest) (*BatchGetResponse, *BatchGetError)
• func BatchSet(ctx context.Context, props *BatchSetRequest) (*BatchSetResponse, *BatchSetError)
• func BatchSetIfNotExists(ctx context.Context, props *BatchSetIfNotExistsRequest) (*BatchSetIfNotExistsResponse, *BatchSetIfNotExistsError)
• func CreateErrorMapping(keys []momento.Key, err error) map[momento.Key]error
• func ExtractKeys(items Items) []momento.Key
• type BatchDeleteError
  • func BatchDelete(ctx context.Context, props *BatchDeleteRequest) *BatchDeleteError
  • func (e *BatchDeleteError) Error() string
  • func (e *BatchDeleteError) Errors() map[momento.Value]error
• type BatchDeleteRequest
• type BatchGetError
  • func (e *BatchGetError) Error() string
  • func (e *BatchGetError) Errors() map[momento.Value]error
• type BatchGetRequest
• type BatchGetResponse
  • func (e *BatchGetResponse) Responses() map[momento.Value]responses.GetResponse
• type BatchSetError
  • func (e *BatchSetError) Error() string
  • func (e *BatchSetError) Errors() map[momento.Value]error
• type BatchSetIfNotExistsError
  • func (e *BatchSetIfNotExistsError) Error() string
  • func (e *BatchSetIfNotExistsError) Errors() map[momento.Key]error
• type BatchSetIfNotExistsNotStored
• type BatchSetIfNotExistsRequest
• type BatchSetIfNotExistsResponse
• type BatchSetIfNotExistsStored
  • func (e BatchSetIfNotExistsStored) Responses() map[momento.Value]responses.SetResponse
• type BatchSetItem
• type BatchSetRequest
• type BatchSetResponse
  • func (e *BatchSetResponse) Responses() map[momento.Value]responses.SetResponse
• type Items

Functions

func BatchGet

func BatchGet(ctx context.Context, props *BatchGetRequest) (*BatchGetResponse, *BatchGetError)

BatchGet gets a slice of keys from the cache, returning a map from failing cache keys to their specific errors.

func BatchSet

func BatchSet(ctx context.Context, props *BatchSetRequest) (*BatchSetResponse, *BatchSetError)

BatchSet sets a slice of keys to the cache, returning a map from failing cache keys to their specific errors.

func BatchSetIfNotExists

func BatchSetIfNotExists(ctx context.Context, props *BatchSetIfNotExistsRequest) (*BatchSetIfNotExistsResponse, *BatchSetIfNotExistsError)

BatchSetIfNotExists will set the key-value pairs ONLY if all keys don't already exist

func CreateErrorMapping

func CreateErrorMapping(keys []momento.Key, err error) map[momento.Key]error

func ExtractKeys

func ExtractKeys(items Items) []momento.Key

Types

type BatchDeleteError

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

BatchDeleteError contains a map associating failing cache keys with their specific errors. It may be necessary to use a type assertion to access the errors:

errors := (err.(*BatchDeleteError)).Errors()

func BatchDelete

func BatchDelete(ctx context.Context, props *BatchDeleteRequest) *BatchDeleteError

BatchDelete deletes a slice of keys from the cache, returning a map from failing cache keys to their specific errors.

func (*BatchDeleteError) Error

func (e *BatchDeleteError) Error() string

func (*BatchDeleteError) Errors

func (e *BatchDeleteError) Errors() map[momento.Value]error

type BatchDeleteRequest

type BatchDeleteRequest struct {
	Client               momento.CacheClient
	CacheName            string
	Keys                 []momento.Key
	MaxConcurrentDeletes int
	// timeout for individual requests, defaults to 10 seconds
	RequestTimeout *time.Duration
}

type BatchGetError

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

BatchGetError contains a map associating failing cache keys with their specific errors. It may be necessary to use a type assertion to access the errors:

errors := (err.(*BatchGetError)).Errors()

func (*BatchGetError) Error

func (e *BatchGetError) Error() string

func (*BatchGetError) Errors

func (e *BatchGetError) Errors() map[momento.Value]error

type BatchGetRequest

type BatchGetRequest struct {
	Client            momento.CacheClient
	CacheName         string
	Keys              []momento.Key
	MaxConcurrentGets int
	// timeout for individual requests, defaults to 10 seconds
	RequestTimeout *time.Duration
}

type BatchGetResponse

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

BatchGetResponse contains a map associating successful get responses with their cache keys.

func (*BatchGetResponse) Responses

func (e *BatchGetResponse) Responses() map[momento.Value]responses.GetResponse

type BatchSetError

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

BatchSetError contains a map associating failing cache keys with their specific errors. It may be necessary to use a type assertion to access the errors:

errors := (err.(*BatchSetError)).Errors()

func (*BatchSetError) Error

func (e *BatchSetError) Error() string

func (*BatchSetError) Errors

func (e *BatchSetError) Errors() map[momento.Value]error

Errors contains a map associating unsuccessful set errors with their cache keys.

type BatchSetIfNotExistsError

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

BatchSetIfNotExistsError contains a map associating failing cache keys with their specific errors. Errors may be related to keys already existing or batch set failing. It may be necessary to use a type assertion to access the errors:

errors := (err.(*BatchSetIfNotExistsError)).Errors()

func (*BatchSetIfNotExistsError) Error

func (e *BatchSetIfNotExistsError) Error() string

func (*BatchSetIfNotExistsError) Errors

func (e *BatchSetIfNotExistsError) Errors() map[momento.Key]error

Errors contains a map associating errors with their cache keys.

type BatchSetIfNotExistsNotStored

type BatchSetIfNotExistsNotStored struct{}

BatchSetIfNotExistsNotStored indicates a successful set request where the value was already present.

type BatchSetIfNotExistsRequest

type BatchSetIfNotExistsRequest struct {
	Client            momento.CacheClient
	CacheName         string
	Items             []BatchSetItem
	MaxConcurrentSets int
	// timeout for individual requests, defaults to 10 seconds
	RequestTimeout *time.Duration
}

type BatchSetIfNotExistsResponse

type BatchSetIfNotExistsResponse interface {
	// contains filtered or unexported methods
}

BatchSetIfNotExistsResponse is the base response type for a BatchSetIfNotExists request

type BatchSetIfNotExistsStored

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

BatchSetIfNotExistsStored indicates a successful set request where the value was stored.

func (BatchSetIfNotExistsStored) Responses

func (e BatchSetIfNotExistsStored) Responses() map[momento.Value]responses.SetResponse

type BatchSetItem

type BatchSetItem struct {
	Key   momento.Key
	Value momento.Value
	Ttl   time.Duration
}

type BatchSetRequest

type BatchSetRequest struct {
	Client            momento.CacheClient
	CacheName         string
	Items             []BatchSetItem
	MaxConcurrentSets int
	// timeout for individual requests, defaults to 10 seconds
	RequestTimeout *time.Duration
}

type BatchSetResponse

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

BatchSetResponse contains a map associating successful set responses with their cache keys.

func (*BatchSetResponse) Responses

func (e *BatchSetResponse) Responses() map[momento.Value]responses.SetResponse

type Items

type Items []BatchSetItem