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,
	f func(*ttnpb.GatewayConnectionStats) (*ttnpb.GatewayConnectionStats, []string, error),
	ttl time.Duration,
	gets ...string,
) error

Set sets or clears the connection stats for a gateway.