instance

Documentation

Index

• type AutoScaler
• type K8S
• type Monitoring
• type MonitoringWaterHoseMaster
• type MonitoringWaterHoseSlave
• type RateLimiter
• type Redis
• type Twitch

Types

type AutoScaler

type AutoScaler interface {
	AllocateChannels(channels []*pb.Channel) error
	GetChannelsForSlave(idx int) []structures.Channel
	Load() error
}

type K8S

type K8S interface {
	GetStatefulSet(ctx context.Context, name string) (*appsv1.StatefulSet, error)
	CreateStatefulSet(ctx context.Context, statefulSet appsv1.StatefulSet) (*appsv1.StatefulSet, error)
	UpdateStatefulSet(ctx context.Context, statefulSet *appsv1.StatefulSet) (*appsv1.StatefulSet, error)
	DeleteStatefulSet(ctx context.Context, name string) error
}

type Monitoring

type Monitoring interface {
	Register(prometheus.Registerer)
	WaterHoseMaster() MonitoringWaterHoseMaster
	WaterHoseSlave() MonitoringWaterHoseSlave
}

type MonitoringWaterHoseMaster

type MonitoringWaterHoseMaster struct {
	TotalChannels prometheus.Histogram
}

type MonitoringWaterHoseSlave

type MonitoringWaterHoseSlave struct {
	TotalChannelsBannedIn    prometheus.Histogram
	TotalChannelsSuspended   prometheus.Histogram
	TotalChannelsConnectedTo prometheus.Histogram
	TotalMessages            prometheus.Histogram
}

type RateLimiter

type RateLimiter interface {
	RequestJoin(ctx context.Context, channel *pb.Channel) error
	Start()
}

type Redis

type Redis interface {
	Pipeline(ctx context.Context) rawRedis.Pipeliner
	Publish(ctx context.Context, channel string, value string) error

	RateLimitNewConnection(ctx context.Context) (bool, time.Duration, error)
	RateLimitJoin(ctx context.Context, count int) (int, time.Duration, error)

	redis.Instance
}

type Twitch

type Twitch interface {
	GetOAuth(ctx context.Context, id string) (helix.AccessCredentials, error)
	GetUser(id string) (helix.User, error)
	GetUsers(id []string) ([]helix.User, []error)
}