model

Documentation

Index

• Constants
• Variables
• type Circle
• type CircleCountData
  • func (c CircleCountData) FromProto(in *analyticsV1.GetCircleCountDataResponse_CircleCountDataHolder) CircleCountData
• type CircleCountDataList
  • func (c CircleCountDataList) ToCircleCountDataProto() []*analyticsV1.GetCircleCountDataResponse_CircleCountDataHolder
• type CircleData
  • func (c CircleData) ToProto() *analyticsV1.CircleData
• type CircleDataSlice
  • func (cds CircleDataSlice) ToProto() []*analyticsV1.CircleData
• type Circles
  • func (c Circles) GetStringArray() []string
• type CountData
• type CountDataArray
  • func (c CountDataArray) SortByTimeAscending()
  • func (c CountDataArray) ToCountDataHolderPB() []*analyticsV1.CountDataHolder
• type ExecutedJob
• type Job
  • func (j Job) GetColumNames() []string
  • func (j Job) GetNextExecutionTime() (*time.Time, error)
• type Name
• type Period
  • func PeriodFromProto(p analyticsV1.Period) (*Period, error)
  • func PeriodFromString(period string) (Period, error)
  • func (p Period) GetTimeFromForQuerying(isSubtract bool) time.Time
  • func (p Period) ToDuration() time.Duration
  • func (p Period) ToString() string
• type Timeunit

Constants

const (
	ColID                = "Id"
	ColNextExecutionTime = "NextExecutionTime"
	ColLastExecutedAt    = "LastExecutedAt"
	ColDeletedAt         = "DeletedAt"
	ColCreatedAt         = "CreatedAt"
	ColCircleID          = "CircleId"
	ColName              = "Name"
	ColExecutionInterval = "ExecutionInterval"
	ColIsLocked          = "IsLocked"
)

const (
	TableJobs         = "Jobs"
	TableExecutedJobs = "ExecutedJobs"
	TableCircles      = "Circles"
	TableCircleData   = "CircleData"
)

Variables

var InitialJobs = []Job{
	{
		ID:   "1",
		Name: "Circle_Single",
		ExecutionInterval: Period{
			Count:    1,
			Timeunit: Hour,
		}.ToString(),
		NextExecutionTime: time.Now().Add(time.Hour),
		CreatedAt:         spanner.CommitTimestamp,
	},
}

Types

type Circle

type Circle struct {
	CircleId  string           `spanner:"CircleId"`
	CreatedAt time.Time        `spanner:"CreatedAt"`
	DeletedAt spanner.NullTime `spanner:"DeletedAt"`
}

type CircleCountData

type CircleCountData struct {
	Count int64
	Time  time.Time
}

func (CircleCountData) FromProto

func (c CircleCountData) FromProto(in *analyticsV1.GetCircleCountDataResponse_CircleCountDataHolder) CircleCountData

type CircleCountDataList

type CircleCountDataList []CircleCountData

func (CircleCountDataList) ToCircleCountDataProto

func (c CircleCountDataList) ToCircleCountDataProto() []*analyticsV1.GetCircleCountDataResponse_CircleCountDataHolder

type CircleData

type CircleData struct {
	ID           string    `spanner:"Id"`
	CircleID     string    `spanner:"CircleId"`
	MembersCount int64     `spanner:"MembersCount"`
	ViewsCount   int64     `spanner:"ViewsCount"`
	PostsCount   int64     `spanner:"PostsCount"`
	CreatedAt    time.Time `spanner:"CreatedAt"`
}

func (CircleData) ToProto

func (c CircleData) ToProto() *analyticsV1.CircleData

type CircleDataSlice

type CircleDataSlice []CircleData

func (CircleDataSlice) ToProto

func (cds CircleDataSlice) ToProto() []*analyticsV1.CircleData

type Circles

type Circles []Circle

func (Circles) GetStringArray

func (c Circles) GetStringArray() []string

type CountData

type CountData struct {
	Count int64
	Time  time.Time
}

type CountDataArray

type CountDataArray []CountData

func (CountDataArray) SortByTimeAscending

func (c CountDataArray) SortByTimeAscending()

func (CountDataArray) ToCountDataHolderPB

func (c CountDataArray) ToCountDataHolderPB() []*analyticsV1.CountDataHolder

type ExecutedJob

type ExecutedJob struct {
	ExecutionID string    `spanner:"ExecutionId"`
	JobID       string    `spanner:"JobId"`
	ExecutedAt  time.Time `spanner:"ExecutedAt"`
}

type Job

type Job struct {
	ID                string           `spanner:"Id"`
	Name              string           `spanner:"Name"`
	ExecutionInterval string           `spanner:"ExecutionInterval"`
	LastExecutedAt    spanner.NullTime `spanner:"LastExecutedAt"`
	NextExecutionTime time.Time        `spanner:"NextExecutionTime"`
	IsLocked          bool             `spanner:"IsLocked"`
	CreatedAt         time.Time        `spanner:"CreatedAt"`
}

func (Job) GetColumNames

func (j Job) GetColumNames() []string

func (Job) GetNextExecutionTime

func (j Job) GetNextExecutionTime() (*time.Time, error)

type Name

type Name string

var (
	JobNameCircleSingle Name = "Circle_Single"
	JobNameCircleMany   Name = "Circle_Many"
)

type Period

type Period struct {
	Count    int16
	Timeunit Timeunit
}

func PeriodFromProto

func PeriodFromProto(p analyticsV1.Period) (*Period, error)

func PeriodFromString

func PeriodFromString(period string) (Period, error)

func (Period) GetTimeFromForQuerying

func (p Period) GetTimeFromForQuerying(isSubtract bool) time.Time

func (Period) ToDuration

func (p Period) ToDuration() time.Duration

func (Period) ToString

func (p Period) ToString() string

type Timeunit

type Timeunit string

const (
	Minute Timeunit = "minute"
	Hour   Timeunit = "hour"
	Day    Timeunit = "day"
	Week   Timeunit = "week"
	Month  Timeunit = "month"
)