stream

Documentation

Index

• type Interactor
• type Stream
  • func NewStream(i Interactor) *Stream
  • func (s *Stream) GetEvents(c *gin.Context)

Types

type Interactor

type Interactor interface {
	SubscribeEvent(fn func(e *ent.Event)) error
	UnsubscribeEvent(fn func(e *ent.Event)) error
	FindDeploymentByID(ctx context.Context, id int) (*ent.Deployment, error)
	FindDeploymentStatusByID(ctx context.Context, id int) (*ent.DeploymentStatus, error)
	FindReviewByID(ctx context.Context, id int) (*ent.Review, error)
	FindPermOfRepo(ctx context.Context, r *ent.Repo, u *ent.User) (*ent.Perm, error)
}

type Stream

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

func NewStream

func NewStream(i Interactor) *Stream

func (*Stream) GetEvents

func (s *Stream) GetEvents(c *gin.Context)

GetEvents streams events of deployment, or review.