connectivity

Documentation

Index

• type ConnectivityRepo
  • func NewConnectivityRepo(chConn clickhouse.Conn, objGetter indexrepo.ObjectGetter, ...) *ConnectivityRepo
  • func (r *ConnectivityRepo) GetAutoPiEvents(ctx context.Context, device *models.PairedDevice, after, before time.Time, ...) ([]cloudevent.CloudEvent[json.RawMessage], error)
  • func (r *ConnectivityRepo) GetHashDogEvents(ctx context.Context, device *models.PairedDevice, after, before time.Time, ...) ([]cloudevent.CloudEvent[json.RawMessage], error)
  • func (r *ConnectivityRepo) GetRuptelaStatusEvents(ctx context.Context, vehicleDID cloudevent.NFTDID, after, before time.Time, ...) ([]cloudevent.CloudEvent[json.RawMessage], error)
  • func (r *ConnectivityRepo) GetSyntheticstatusEvents(ctx context.Context, vehicleDID cloudevent.NFTDID, after, before time.Time, ...) ([]cloudevent.CloudEvent[json.RawMessage], error)

Types

type ConnectivityRepo

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

ConnectivityRepo is a repository for retrieving connectivity events.

func NewConnectivityRepo

func NewConnectivityRepo(chConn clickhouse.Conn, objGetter indexrepo.ObjectGetter, autoPiDataType, autoPiBucketName, hashDogDataType, hashDogBucketName, statusDataType, statusBucketName, cloudEventBucketName string) *ConnectivityRepo

NewConnectivityRepo creates a new instance of ConnectivityRepoImpl.

func (*ConnectivityRepo) GetAutoPiEvents

func (r *ConnectivityRepo) GetAutoPiEvents(ctx context.Context, device *models.PairedDevice, after, before time.Time, limit int) ([]cloudevent.CloudEvent[json.RawMessage], error)

GetAutoPiEvents returns the twilio events for a autopi device.

func (*ConnectivityRepo) GetHashDogEvents

func (r *ConnectivityRepo) GetHashDogEvents(ctx context.Context, device *models.PairedDevice, after, before time.Time, limit int) ([]cloudevent.CloudEvent[json.RawMessage], error)

GetHashDogEvents returns the lorawan events for a hashdog device.

func (*ConnectivityRepo) GetRuptelaStatusEvents

func (r *ConnectivityRepo) GetRuptelaStatusEvents(ctx context.Context, vehicleDID cloudevent.NFTDID, after, before time.Time, limit int) ([]cloudevent.CloudEvent[json.RawMessage], error)

GetRuptelaStatusEvents returns the status events for a vehicle.

func (*ConnectivityRepo) GetSyntheticstatusEvents

func (r *ConnectivityRepo) GetSyntheticstatusEvents(ctx context.Context, vehicleDID cloudevent.NFTDID, after, before time.Time, limit int) ([]cloudevent.CloudEvent[json.RawMessage], error)

GetSyntheticstatusEvents returns the status events for a vehicle.