lastseen

Documentation

Index

• type BatchLastSeenProvider
  • func NewBatchLastSeenProvider(ctx context.Context, batchSize int, ticker <-chan time.Time, ...) *BatchLastSeenProvider
  • func (ls *BatchLastSeenProvider) PushLastSeenFromUplink(ctx context.Context, ids *ttnpb.EndDeviceIdentifiers, ...) error
• type LastSeenProvider
  • func NewBatchLastSeen(ctx context.Context, batchSize int, ticker <-chan time.Time, ...) (LastSeenProvider, error)
  • func NewNoopLastSeenProvider() (LastSeenProvider, error)

Types

type BatchLastSeenProvider

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

BatchLastSeenProvider represents

func NewBatchLastSeenProvider

func NewBatchLastSeenProvider(ctx context.Context, batchSize int, ticker <-chan time.Time, cluster metadata.ClusterPeerAccess) *BatchLastSeenProvider

NewBatchLastSeenProvider returns a new BatchLastSeenProvider struct.

func (*BatchLastSeenProvider) PushLastSeenFromUplink

func (ls *BatchLastSeenProvider) PushLastSeenFromUplink(ctx context.Context, ids *ttnpb.EndDeviceIdentifiers, lastSeen *timestamppb.Timestamp) error

PushLastSeenFromUplink pushes the timestamp of the device uplink to the last seen provider. If the data structure for storing last seen timestamps is full, the timestamps are updated in batch in Identity Server.

type LastSeenProvider

type LastSeenProvider interface {
	PushLastSeenFromUplink(ctx context.Context, ids *ttnpb.EndDeviceIdentifiers, lastSeen *timestamppb.Timestamp) error
}

LastSeenProvider is an interface for storing device last seen timestamp from uplink.

func NewBatchLastSeen

func NewBatchLastSeen(ctx context.Context, batchSize int, ticker <-chan time.Time, cluster metadata.ClusterPeerAccess) (LastSeenProvider, error)

NewBatchLastSeen creates a new BatchLastSeenProvider that manages batch updates of last seen timestamps in Identity Server.

func NewNoopLastSeenProvider

func NewNoopLastSeenProvider() (LastSeenProvider, error)

NewNoopLastSeenProvider returns a noop LastSeenProvider.