repo_indexer

Documentation

Index

• func CheckRepoEventPermission(ctx context.Context, resourceId string) (*models.RepoEvent, error)
• func CheckRepoEventsPermission(ctx context.Context, resourceIds []string) ([]*models.RepoEvent, error)
• func Serve(cfg *config.Config)
• type EventController
  • func NewEventController(ctx context.Context) *EventController
  • func (i *EventController) Dequeue()
  • func (i *EventController) ExecuteEvent(ctx context.Context, repoEvent *models.RepoEvent, cb func())
  • func (i *EventController) GetEventLength() int32
  • func (i *EventController) NewRepoEvent(repoId, owner string) (*models.RepoEvent, error)
  • func (i *EventController) Serve()
• type Server
  • func (p *Server) Checker(ctx context.Context, req interface{}) error
  • func (p *Server) Cron()
  • func (p *Server) DescribeRepoEvents(ctx context.Context, req *pb.DescribeRepoEventsRequest) (*pb.DescribeRepoEventsResponse, error)
  • func (p *Server) IndexRepo(ctx context.Context, req *pb.IndexRepoRequest) (*pb.IndexRepoResponse, error)

Functions

func CheckRepoEventPermission

func CheckRepoEventPermission(ctx context.Context, resourceId string) (*models.RepoEvent, error)

func CheckRepoEventsPermission

func CheckRepoEventsPermission(ctx context.Context, resourceIds []string) ([]*models.RepoEvent, error)

func Serve

func Serve(cfg *config.Config)

Types

type EventController

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

func NewEventController

func NewEventController(ctx context.Context) *EventController

func (*EventController) Dequeue

func (i *EventController) Dequeue()

func (*EventController) ExecuteEvent

func (i *EventController) ExecuteEvent(ctx context.Context, repoEvent *models.RepoEvent, cb func())

func (*EventController) GetEventLength

func (i *EventController) GetEventLength() int32

func (*EventController) NewRepoEvent

func (i *EventController) NewRepoEvent(repoId, owner string) (*models.RepoEvent, error)

func (*EventController) Serve

func (i *EventController) Serve()

type Server

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

func (*Server) Checker

func (p *Server) Checker(ctx context.Context, req interface{}) error

func (*Server) Cron

func (p *Server) Cron()

func (*Server) DescribeRepoEvents

func (p *Server) DescribeRepoEvents(ctx context.Context, req *pb.DescribeRepoEventsRequest) (*pb.DescribeRepoEventsResponse, error)

func (*Server) IndexRepo

func (p *Server) IndexRepo(ctx context.Context, req *pb.IndexRepoRequest) (*pb.IndexRepoResponse, error)