streamschedule

Documentation

Index

• Constants
• type Databaser
• type FailedOperation
• type Schedule
• type StreamSchedule
  • func New(logger ytfeed.Logger, databasePath string, workerInterval time.Duration) (s *StreamSchedule, err error)
  • func (s *StreamSchedule) CloseDatabase() (err error)
  • func (s *StreamSchedule) RegisterDataHandler(d ...ytfeed.DataHandlerFunc)
  • func (s *StreamSchedule) RegisterSchedule(runAt time.Time, data *ytfeed.Data) (err error)
  • func (s *StreamSchedule) RunWorker(ctx context.Context) (err error)

Constants

const (
	DefaultFilePermission      = 0666
	DefaultDatabaseOpenTimeout = time.Second
	DefaultBucketName          = "ytfeed"

	ErrFailedToDeleteKeysFormat = "failed to delete key(s): %s"
)

Types

type Databaser

type Databaser interface {
	Close() error
	Update(func(tx *bbolt.Tx) error) error
}

type FailedOperation

type FailedOperation struct {
	Error error
	Key   string
}

type Schedule

type Schedule struct {
	RunAt time.Time    `json:"run_at"`
	Data  *ytfeed.Data `json:"data"`
}

type StreamSchedule

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

func New

func New(logger ytfeed.Logger, databasePath string, workerInterval time.Duration) (s *StreamSchedule, err error)

func (*StreamSchedule) CloseDatabase

func (s *StreamSchedule) CloseDatabase() (err error)

func (*StreamSchedule) RegisterDataHandler

func (s *StreamSchedule) RegisterDataHandler(d ...ytfeed.DataHandlerFunc)

func (*StreamSchedule) RegisterSchedule

func (s *StreamSchedule) RegisterSchedule(runAt time.Time, data *ytfeed.Data) (err error)

func (*StreamSchedule) RunWorker

func (s *StreamSchedule) RunWorker(ctx context.Context) (err error)