redis

Documentation

Index

• type GatewayConnectionStatsRegistry
  • func (r *GatewayConnectionStatsRegistry) BatchGet(ctx context.Context, ids []*ttnpb.GatewayIdentifiers, paths []string) (map[string]*ttnpb.GatewayConnectionStats, error)
  • 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) BatchGet

func (r *GatewayConnectionStatsRegistry) BatchGet(
	ctx context.Context,
	ids []*ttnpb.GatewayIdentifiers,
	paths []string,
) (map[string]*ttnpb.GatewayConnectionStats, error)

BatchGet returns the connection stats for a batch of gateways. NotFound errors indicating that the gateway is either not connected or is connected to a different cluster, are ignored.

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.