Session Based Ticker

session_based_ticker.go

package main

import (
	"fmt"
	"time"
)

type SessionBasedTicker struct {
	start time.Time
	end   time.Time
	tick  <-chan time.Time
}

func NewSessionBasedTicker(start, end time.Time, duration time.Duration) *SessionBasedTicker {
	return &SessionBasedTicker{
		start: start,
		end:   end,
		tick:  time.Tick(duration),
	}
}

func (sbt *SessionBasedTicker) Tick() <-chan time.Time {
	sessionTick := make(chan time.Time)
	go func() {
		for tickTime := range sbt.tick {
			if tickTime.After(sbt.start) && tickTime.Before(sbt.end) {
				sessionTick <- tickTime
			}
		}
	}()
	return sessionTick
}

func main() {
	// Ticks from now till the next hour, every second.
	sbt := NewSessionBasedTicker(time.Now().Add(time.Second*10), time.Now().Add(time.Hour), time.Second)
	for range sbt.Tick() {
		fmt.Println("hi")
	}
}

session_based_ticker_simple.go

package main

import (
	"time"
)

func NewSessionBasedTicker(start, end time.Time, duration time.Duration) <-chan time.Time {
	sessionTick := make(chan time.Time)
	go func() {
		for tickTime := range time.Tick(duration) {
			if tickTime.After(start) && tickTime.Before(end) {
				sessionTick <- tickTime
			}
		}
	}()

	return sessionTick
}


func main() {
	// Ticks from now till the next hour, every second.
	sbt := NewSessionBasedTicker(time.Now().Add(time.Second*10), time.Now().Add(time.Hour), time.Second)
	for range sbt {
		fmt.Println("hi")
	}
}