common

Documentation

Overview

Package common contains utility methods used by all adapters.

Index

• func DecodeUidString(str string) int64
• func DisjunctionSql(req [][]string, fieldName string) (string, []any)
• func EncodeUidString(str string) t.Uid
• func ExtractTags(update map[string]any) []string
• func FilterFoundTags(setTags t.StringSlice, index map[string]struct{}) []string
• func FromJSON(src any) any
• func RangesToSql(in []t.Range) (string, []any)
• func SelectEarliestUpdatedSubs(subs []t.Subscription, opts *t.QueryOpt, maxResults int) []t.Subscription
• func SelectLatestTime(t1, t2 time.Time) time.Time
• func ToJSON(src any) []byte
• func UpdateByMap(update map[string]any) (cols []string, args []any)

Functions

func DecodeUidString

func DecodeUidString(str string) int64

DecodeUidString takes UID as string, converts it to int64 representation. UIDs are stored as decoded int64 values.

func DisjunctionSql

func DisjunctionSql(req [][]string, fieldName string) (string, []any)

DisjunctionSql converts a slice of disjunctions to SQL HAVING clause and arguments.

func EncodeUidString

func EncodeUidString(str string) t.Uid

EncodeUidString takes decoded string representation of int64, produce UID. UIDs are stored as decoded int64 values.

func ExtractTags

func ExtractTags(update map[string]any) []string

If Tags field is updated, get the tags so tags table cab be updated too.

func FilterFoundTags

func FilterFoundTags(setTags t.StringSlice, index map[string]struct{}) []string

FilterFoundTags keeps only those tags in setTags that are present in the index.

func FromJSON

func FromJSON(src any) any

Deserialize JSON data from DB.

func RangesToSql

func RangesToSql(in []t.Range) (string, []any)

RangesToSql converts a slice of ranges to SQL BETWEEN or IN() constraint and arguments.

func SelectEarliestUpdatedSubs

func SelectEarliestUpdatedSubs(subs []t.Subscription, opts *t.QueryOpt, maxResults int) []t.Subscription

SelectEarliestUpdatedSubs selects no more than the given number of subscriptions from the given slice satisfying the query. When the number of subscriptions is greater than the limit, the subscriptions with the earliest timestamp are selected.

func SelectLatestTime

func SelectLatestTime(t1, t2 time.Time) time.Time

SelectLatestTime picks the latest update timestamp out of the two.

func ToJSON

func ToJSON(src any) []byte

Convert to JSON before storing to JSON field.

func UpdateByMap

func UpdateByMap(update map[string]any) (cols []string, args []any)

Convert update to a list of columns and arguments.