broadcastd

Documentation

Index

• Constants
• Variables
• type Logger
• type Server
  • func New(ctx context.Context, lg Logger, authn auth.Authenticator, ...) *Server
  • func (srv *Server) Events(req *pb.BroadcastEventsI, stream pb.Broadcast_EventsServer) error
  • func (srv *Server) PostGitRefUpdated(ctx context.Context, i *pb.PostGitRefUpdatedI) (*pb.PostGitRefUpdatedO, error)
  • func (srv *Server) Serve() error

Constants

const (
	NsBroadcast  = "broadcast"
	BroadcastAll = "all"
)

const AABroadcastRead = fsoauthz.AABroadcastRead

const AABroadcastWrite = fsoauthz.AABroadcastWrite

const MaxPostBatchLen = 100

const PostQueueLen = 200

Variables

var ErrPostQueueFull = errors.New("post queue full")

Types

type Logger

type Logger interface {
	Errorw(msg string, kv ...interface{})
	Infow(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,
	names *shorteruuid.Names,
	broadcastJ *events.Journal,
) *Server

func (*Server) Events

func (srv *Server) Events(
	req *pb.BroadcastEventsI, stream pb.Broadcast_EventsServer,
) error

func (*Server) PostGitRefUpdated

func (srv *Server) PostGitRefUpdated(
	ctx context.Context, i *pb.PostGitRefUpdatedI,
) (*pb.PostGitRefUpdatedO, error)

func (*Server) Serve

func (srv *Server) Serve() error