supervisor

Documentation

Index

• Variables
• type Supervisor
  • func NewSupervisor(c *conf.Porter, auth *libauth.Auth, porter *client.Porter) (*Supervisor, error)
  • func (s *Supervisor) CallAccountPlatform(ctx context.Context, platform string) context.Context
  • func (s *Supervisor) CallAppInfoSource(ctx context.Context, source string) context.Context
  • func (s *Supervisor) CallFeedSource(ctx context.Context, source string) context.Context
  • func (s *Supervisor) CallNotifyDestination(ctx context.Context, destination string) context.Context
  • func (s *Supervisor) CheckAccountPlatform(platform string) bool
  • func (s *Supervisor) CheckAppInfoSource(source string) bool
  • func (s *Supervisor) CheckFeedSource(source string) bool
  • func (s *Supervisor) CheckNotifyDestination(destination string) bool
  • func (s *Supervisor) GetFeatureSummary() *modeltiphereth.ServerFeatureSummary
  • func (s *Supervisor) GetInstanceConnectionStatus(ctx context.Context, address string) modeltiphereth.PorterConnectionStatus
  • func (s *Supervisor) KnownInstancesOutdated()
  • func (s *Supervisor) KnownInstancesRequireUpdate() bool
  • func (s *Supervisor) RefreshAliveInstances(ctx context.Context) ([]*modeltiphereth.PorterInstance, error)
  • func (s *Supervisor) UpdateKnownInstances(instances []*modeltiphereth.PorterInstance)

Variables

var ProviderSet = wire.NewSet(NewSupervisor)

Types

type Supervisor

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

func NewSupervisor

func NewSupervisor(
	c *conf.Porter,
	auth *libauth.Auth,
	porter *client.Porter,
) (*Supervisor, error)

func (*Supervisor) CallAccountPlatform

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

func (*Supervisor) CallAppInfoSource

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

func (*Supervisor) CallFeedSource

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

func (*Supervisor) CallNotifyDestination

func (s *Supervisor) CallNotifyDestination(ctx context.Context, destination string) context.Context

func (*Supervisor) CheckAccountPlatform

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

func (*Supervisor) CheckAppInfoSource

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

func (*Supervisor) CheckFeedSource

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

func (*Supervisor) CheckNotifyDestination

func (s *Supervisor) CheckNotifyDestination(destination string) bool

func (*Supervisor) GetFeatureSummary

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

func (*Supervisor) GetInstanceConnectionStatus

func (s *Supervisor) GetInstanceConnectionStatus(
	ctx context.Context,
	address string,
) modeltiphereth.PorterConnectionStatus

func (*Supervisor) KnownInstancesOutdated

func (s *Supervisor) KnownInstancesOutdated()

func (*Supervisor) KnownInstancesRequireUpdate

func (s *Supervisor) KnownInstancesRequireUpdate() bool

func (*Supervisor) RefreshAliveInstances

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

func (*Supervisor) UpdateKnownInstances

func (s *Supervisor) UpdateKnownInstances(instances []*modeltiphereth.PorterInstance)