livebroadcastd

Documentation

Index

• Constants
• type Journals
• type Logger
• type Server
  • func New(ctx context.Context, lg Logger, authn auth.Authenticator, ...) *Server
  • func (srv *Server) AggregateSignals(req *pb.AggregateSignalsI, stream pb.LiveBroadcast_AggregateSignalsServer) error

Constants

const AABroadcastRead = fsoauthz.AABroadcastRead

const ChannelAllAggregateSignals = "allaggsig"

const ConfigMaxPendingSignalsLen = 4 * 1024

const ConfigUpdatesQueueSize = 100

Types

type Journals

type Journals struct {
	Main               *events.Journal
	Registry           *events.Journal
	Repos              *events.Journal
	Workflows          *events.Journal
	EphemeralWorkflows *events.Journal
}

type Logger

type Logger interface {
	Infow(msg string, kv ...interface{})
	Warnw(msg string, kv ...interface{})
	Errorw(msg string, kv ...interface{})
}

type Server

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

func New

func New(
	ctx context.Context,
	lg Logger,
	authn auth.Authenticator,
	authz auth.Authorizer,
	journals *Journals,
) *Server

func (*Server) AggregateSignals

func (srv *Server) AggregateSignals(
	req *pb.AggregateSignalsI,
	stream pb.LiveBroadcast_AggregateSignalsServer,
) error