depsync

Documentation

Index

• Constants
• func LoadConfig(db *bolt.DB) (*config, error)
• func MarshalEvent(e *Event) ([]byte, error)
• func UnmarshalEvent(data []byte, e *Event) error
• type Event
  • func NewEvent(devices []dep.Device) *Event
• type Option
  • func WithClient(client dep.Client) Option
• type Syncer
  • func New(pub pubsub.PublishSubscriber, db *bolt.DB, opts ...Option) (Syncer, error)

Constants

const (
	SyncTopic    = "mdm.DepSync"
	ConfigBucket = "mdm.DEPConfig"
)

Functions

func LoadConfig

func LoadConfig(db *bolt.DB) (*config, error)

func MarshalEvent

func MarshalEvent(e *Event) ([]byte, error)

MarshalEvent serializes an event to a protocol buffer wire format.

func UnmarshalEvent

func UnmarshalEvent(data []byte, e *Event) error

UnmarshalEvent parses a protocol buffer representation of data into the Event.

Types

type Event

type Event struct {
	ID      string
	Time    time.Time
	Devices []dep.Device
}

func NewEvent

func NewEvent(devices []dep.Device) *Event

type Option

type Option func(*watcher)

func WithClient

func WithClient(client dep.Client) Option

type Syncer

type Syncer interface {
	// contains filtered or unexported methods
}

func New

func New(pub pubsub.PublishSubscriber, db *bolt.DB, opts ...Option) (Syncer, error)