eventlog

type Event struct {
	Type      EventType `json:"type"`
	Timestamp int64     `json:"ts"`
	LogID     string    `json:"log_id"`
	Offset    int64     `json:"offset"`
	Data      []byte    `json:"data"`
}

type EventManager interface {
	EventPusher
	EventSubscriber
	control.ServiceController
}

type EventPusher interface {
	Push(eventType EventType, data interface{}) error
}

type EventSubscriber interface {
	Subscribe(ctx context.Context, subscriberId string, opts ...SubscribeOption) (*Subscription, error)
	Unsubscribe(ctx context.Context, subscriberId string) error
}

type EventType int32

type EventlogPosition struct {
	LogID  string
	Offset int64
}

type File interface {
	io.Reader
	io.Writer
	io.Seeker
	io.Closer
	Stat() (os.FileInfo, error)
	Sync() error
}

type StorageConfig struct {
	// path to a log dir
	Dir string `json:"dir"`
	// number of files to maintain
	MaxFiles int `json:"max_files"`
	// for how long we want to write to a single logfile
	Period time.Duration `json:"period"`
	// how many bytes we want to write to a single logfile
	Size int64 `json:"size"`
}

type SubscribeOption func(opts *subscribeOptions) error

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

type WriteSyncCloser interface {
	io.Writer
	io.Closer
	Sync() error
}