datasync

Documentation

Overview

Package datasync contains interfaces for syncing data from robots to the app.viam.com cloud.

Index

• func NewClient(conn rpc.ClientConn) v1.DataSyncServiceClient
• func NewConnection(logger *zap.SugaredLogger, address string, rpcOpts []rpc.DialOption) (rpc.ClientConn, error)
• type Manager
  • func NewDefaultManager(logger golog.Logger, cfg *config.Config) (Manager, error)
  • func NewManager(logger golog.Logger, partID string, client v1.DataSyncServiceClient, ...) (Manager, error)
• type ManagerConstructor

Functions

func NewClient

func NewClient(conn rpc.ClientConn) v1.DataSyncServiceClient

NewClient constructs a new v1.DataSyncServiceClient using the passed in connection.

func NewConnection

func NewConnection(logger *zap.SugaredLogger, address string, rpcOpts []rpc.DialOption) (rpc.ClientConn, error)

NewConnection builds a connection to the passed address with the passed rpcOpts.

Types

type Manager

type Manager interface {
	Sync(paths []string)
	Close()
}

Manager is responsible for enqueuing files in captureDir and uploading them to the cloud.

func NewDefaultManager

func NewDefaultManager(logger golog.Logger, cfg *config.Config) (Manager, error)

NewDefaultManager returns the default Manager that syncs data to app.viam.com.

func NewManager

func NewManager(logger golog.Logger, partID string, client v1.DataSyncServiceClient,
	conn rpc.ClientConn,
) (Manager, error)

NewManager returns a new syncer.

type ManagerConstructor

type ManagerConstructor func(logger golog.Logger, cfg *config.Config) (Manager, error)

ManagerConstructor is a function for building a Manager.