collector

Documentation

Overview

Package collector is the daemon collector main goroutine

Index

• Variables
• type ObjectWithoutConfig
• type T
  • func New(ctx context.Context, subQS pubsub.QueueSizer, opts ...funcopt.O) *T
  • func (t *T) Start(ctx context.Context) error
  • func (t *T) Stop() error

Variables

var (
	Headers = []string{
		"svcname",
		"action",
		"hostname",
		"sid",
		"version",
		"begin",
		"status_log",
		"cron",
	}
	WatchDir = filepath.Join(rawconfig.Paths.Log, "actions")

	FeedPingerInterval = time.Second * 5
)

var (
	ErrZeroPath = errors.New("zero path")
)

Types

type ObjectWithoutConfig

type ObjectWithoutConfig struct {
	ObjectWithoutConfig *[]string `json:"object_without_config"`
}

ObjectWithoutConfig used to decode response of post feed daemon status and ping

type T

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

func New

func New(ctx context.Context, subQS pubsub.QueueSizer, opts ...funcopt.O) *T

func (*T) Start

func (t *T) Start(ctx context.Context) error

func (*T) Stop

func (t *T) Stop() error