redis

Documentation

Index

• type GatewayConnectionStatsRegistry
  • func (r *GatewayConnectionStatsRegistry) Get(ctx context.Context, ids ttnpb.GatewayIdentifiers) (*ttnpb.GatewayConnectionStats, error)
  • func (r *GatewayConnectionStatsRegistry) Init(ctx context.Context) error
  • func (r *GatewayConnectionStatsRegistry) Set(ctx context.Context, ids ttnpb.GatewayIdentifiers, ...) error

Types

type GatewayConnectionStatsRegistry

type GatewayConnectionStatsRegistry struct {
	Redis   *ttnredis.Client
	LockTTL time.Duration
}

GatewayConnectionStatsRegistry implements the GatewayConnectionStatsRegistry interface.

func (*GatewayConnectionStatsRegistry) Get

func (r *GatewayConnectionStatsRegistry) Get(ctx context.Context, ids ttnpb.GatewayIdentifiers) (*ttnpb.GatewayConnectionStats, error)

Get returns the connection stats for a gateway.

func (*GatewayConnectionStatsRegistry) Init

func (r *GatewayConnectionStatsRegistry) Init(ctx context.Context) error

Init initializes the GatewayConnectionStatsRegistry.

func (*GatewayConnectionStatsRegistry) Set

func (r *GatewayConnectionStatsRegistry) Set(ctx context.Context, ids ttnpb.GatewayIdentifiers, stats *ttnpb.GatewayConnectionStats, paths []string, ttl time.Duration) error

Set sets or clears the connection stats for a gateway.