util

Documentation

Index

• func FanIn(done <-chan interface{}, channels ...<-chan interface{}) chan interface{}
• func GetMaximumPartitionKeyToDelete(purgeRecordsOlderThanDays int) string
• func LogPeriods(splits []Period)
• func Repeat(done <-chan interface{}, values ...interface{}) <-chan interface{}
• func RepeatFn(done <-chan interface{}, fn func() interface{}) <-chan interface{}
• func SenderWithLogging(s storage.Sender) storage.Sender
• func Take(done <-chan interface{}, valueStream <-chan interface{}, num int) <-chan interface{}
• func TicksAscendingWithLeadingZero(ticks int64) string
• func TicksFromTime(t time.Time) int64
• func TicksFromTime2(t time.Time) int64
• func TimeFromTicks(ticks int64) time.Time
• func TimeFromTicksAscendingWithLeadingZero(ticksStr string) time.Time
• type Period
  • func NewPeriod(start, end time.Time) (*Period, error)
  • func ParsePeriod(start, end string) (*Period, error)
  • func (p *Period) Duration() time.Duration
  • func (p *Period) Split(duration time.Duration) []Period
  • func (p *Period) SplitsFrom(numSplits int) []Period
  • func (p Period) String() string
• type SenderFunc
  • func (sf SenderFunc) Send(c *storage.Client, r *http.Request) (*http.Response, error)

Functions

func FanIn

func FanIn(done <-chan interface{}, channels ...<-chan interface{}) chan interface{}

FanIn FanIn

func GetMaximumPartitionKeyToDelete

func GetMaximumPartitionKeyToDelete(purgeRecordsOlderThanDays int) string

GetMaximumPartitionKeyToDelete TicksAscendingWithLeadingZero

func LogPeriods

func LogPeriods(splits []Period)

func Repeat

func Repeat(done <-chan interface{}, values ...interface{}) <-chan interface{}

Repeat repeat

func RepeatFn

func RepeatFn(done <-chan interface{}, fn func() interface{}) <-chan interface{}

RepeatFn repeat with function

func SenderWithLogging

func SenderWithLogging(s storage.Sender) storage.Sender

SenderWithLogging returns a SendDecorator that implements simple before and after logging of the request.

func Take

func Take(done <-chan interface{}, valueStream <-chan interface{}, num int) <-chan interface{}

Take Take

func TicksAscendingWithLeadingZero

func TicksAscendingWithLeadingZero(ticks int64) string

TicksAscendingWithLeadingZero asdf

func TicksFromTime

func TicksFromTime(t time.Time) int64

TicksFromTime converts time to ticks

func TicksFromTime2

func TicksFromTime2(t time.Time) int64

TicksFromTime2 converts time to ticks

func TimeFromTicks

func TimeFromTicks(ticks int64) time.Time

TimeFromTicks convert ticks to time

func TimeFromTicksAscendingWithLeadingZero

func TimeFromTicksAscendingWithLeadingZero(ticksStr string) time.Time

Types

type Period

type Period struct {
	Start time.Time
	End   time.Time
}

Period represet a period iof time

func NewPeriod

func NewPeriod(start, end time.Time) (*Period, error)

NewPeriod creates a new period instance

func ParsePeriod

func ParsePeriod(start, end string) (*Period, error)

ParsePeriod parse RFC3339 formated strings into Period

func (*Period) Duration

func (p *Period) Duration() time.Duration

Duration the Periods's time.Duration

func (*Period) Split

func (p *Period) Split(duration time.Duration) []Period

func (*Period) SplitsFrom

func (p *Period) SplitsFrom(numSplits int) []Period

SplitsFrom dsfg

func (Period) String

func (p Period) String() string

type SenderFunc

type SenderFunc func(c *storage.Client, r *http.Request) (*http.Response, error)

SenderFunc is a method that implements the Sender interface.

func (SenderFunc) Send

func (sf SenderFunc) Send(c *storage.Client, r *http.Request) (*http.Response, error)

Send implements the Sender interface on SenderFunc.