supervisor

Documentation

Index

• Variables
• type Supervisor
  • func NewSupervisor(c *conf.Porter, mq *libmq.MQ, auth *libauth.Auth, porter *client.Porter, ...) (*Supervisor, error)
  • func (s *Supervisor) DisablePorterContext(ctx context.Context, porterContext *modelsupervisor.PorterContext) error
  • func (s *Supervisor) GetContextController(ctx context.Context, id model.InternalID) *modelsupervisor.PorterContextController
  • func (s *Supervisor) GetFeatureSummary() *modelsupervisor.ServerFeatureSummary
  • func (s *Supervisor) GetHeartbeatInterval() time.Duration
  • func (s *Supervisor) GetInstanceController(ctx context.Context, address string) *modelsupervisor.PorterInstanceController
  • func (s *Supervisor) HasAccountPlatform(platform string) bool
  • func (s *Supervisor) HasAppInfoSource(source string) bool
  • func (s *Supervisor) HasFeedItemAction(request *modelsupervisor.FeatureRequest) bool
  • func (s *Supervisor) HasFeedSource(source *modelsupervisor.FeatureRequest) bool
  • func (s *Supervisor) HasNotifyDestination(destination *modelsupervisor.FeatureRequest) bool
  • func (s *Supervisor) QueuePorterContext(ctx context.Context, porterContext modelsupervisor.PorterContext) error
  • func (s *Supervisor) RefreshAliveInstances(ctx context.Context) ([]*modelsupervisor.PorterInstance, error)
  • func (s *Supervisor) WithAccountPlatform(ctx context.Context, platform string) context.Context
  • func (s *Supervisor) WithAppInfoSource(ctx context.Context, source string) context.Context
  • func (s *Supervisor) WithFeedItemAction(ctx context.Context, request *modelsupervisor.FeatureRequest) context.Context
  • func (s *Supervisor) WithFeedSource(ctx context.Context, source *modelsupervisor.FeatureRequest) context.Context
  • func (s *Supervisor) WithNotifyDestination(ctx context.Context, destination *modelsupervisor.FeatureRequest) context.Context

Variables

var ProviderSet = wire.NewSet(NewSupervisor)

Types

type Supervisor

type Supervisor struct {
	UUID int64
	// contains filtered or unexported fields
}

func NewSupervisor

func NewSupervisor(
	c *conf.Porter,
	mq *libmq.MQ,
	auth *libauth.Auth,
	porter *client.Porter,
	systemNotify *libmq.Topic[modelnetzach.SystemNotify],
	instanceCache *libcache.Map[string, modelsupervisor.PorterInstance],
	instanceContextCache *libcache.Map[model.InternalID, modelsupervisor.PorterContext],
) (*Supervisor, error)

func (*Supervisor) DisablePorterContext

func (s *Supervisor) DisablePorterContext(
	ctx context.Context,
	porterContext *modelsupervisor.PorterContext,
) error

func (*Supervisor) GetContextController

func (s *Supervisor) GetContextController(
	ctx context.Context,
	id model.InternalID,
) *modelsupervisor.PorterContextController

func (*Supervisor) GetFeatureSummary

func (s *Supervisor) GetFeatureSummary() *modelsupervisor.ServerFeatureSummary

func (*Supervisor) GetHeartbeatInterval

func (s *Supervisor) GetHeartbeatInterval() time.Duration

func (*Supervisor) GetInstanceController

func (s *Supervisor) GetInstanceController(
	ctx context.Context,
	address string,
) *modelsupervisor.PorterInstanceController

func (*Supervisor) HasAccountPlatform

func (s *Supervisor) HasAccountPlatform(platform string) bool

func (*Supervisor) HasAppInfoSource

func (s *Supervisor) HasAppInfoSource(source string) bool

func (*Supervisor) HasFeedItemAction

func (s *Supervisor) HasFeedItemAction(request *modelsupervisor.FeatureRequest) bool

func (*Supervisor) HasFeedSource

func (s *Supervisor) HasFeedSource(source *modelsupervisor.FeatureRequest) bool

func (*Supervisor) HasNotifyDestination

func (s *Supervisor) HasNotifyDestination(destination *modelsupervisor.FeatureRequest) bool

func (*Supervisor) QueuePorterContext

func (s *Supervisor) QueuePorterContext(
	ctx context.Context,
	porterContext modelsupervisor.PorterContext,
) error

func (*Supervisor) RefreshAliveInstances

func (s *Supervisor) RefreshAliveInstances(
	ctx context.Context,
) ([]*modelsupervisor.PorterInstance, error)

func (*Supervisor) WithAccountPlatform

func (s *Supervisor) WithAccountPlatform(ctx context.Context, platform string) context.Context

func (*Supervisor) WithAppInfoSource

func (s *Supervisor) WithAppInfoSource(ctx context.Context, source string) context.Context

func (*Supervisor) WithFeedItemAction

func (s *Supervisor) WithFeedItemAction(ctx context.Context, request *modelsupervisor.FeatureRequest) context.Context

func (*Supervisor) WithFeedSource

func (s *Supervisor) WithFeedSource(ctx context.Context, source *modelsupervisor.FeatureRequest) context.Context

func (*Supervisor) WithNotifyDestination

func (s *Supervisor) WithNotifyDestination(ctx context.Context, destination *modelsupervisor.FeatureRequest) context.Context