controllers

Documentation

Index

• type ClusterIDs
  • func (p *ClusterIDs) Scan(src interface{}) error
  • func (p ClusterIDs) Value() (driver.Value, error)
• type CronScript
• type HandleNATSMessageFunc
• type Server
  • func New(db *sqlx.DB, dbKey string, nc *nats.Conn, ...) *Server
  • func (s *Server) CreateScript(ctx context.Context, req *cronscriptpb.CreateScriptRequest) (*cronscriptpb.CreateScriptResponse, error)
  • func (s *Server) DeleteScript(ctx context.Context, req *cronscriptpb.DeleteScriptRequest) (*cronscriptpb.DeleteScriptResponse, error)
  • func (s *Server) GetScript(ctx context.Context, req *cronscriptpb.GetScriptRequest) (*cronscriptpb.GetScriptResponse, error)
  • func (s *Server) GetScripts(ctx context.Context, req *cronscriptpb.GetScriptsRequest) (*cronscriptpb.GetScriptsResponse, error)
  • func (s *Server) HandleChecksumRequest(msg *cvmsgspb.V2CMessage)
  • func (s *Server) HandleScriptsRequest(msg *cvmsgspb.V2CMessage)
  • func (s *Server) Stop()
  • func (s *Server) UpdateScript(ctx context.Context, req *cronscriptpb.UpdateScriptRequest) (*cronscriptpb.UpdateScriptResponse, error)

Types

type ClusterIDs

type ClusterIDs []uuid.UUID

ClusterIDs represents an array of cluster IDs.

func (*ClusterIDs) Scan

func (p *ClusterIDs) Scan(src interface{}) error

Scan Scans the sqlx database type ([]bytes) into the ClusterIds type.

func (ClusterIDs) Value

func (p ClusterIDs) Value() (driver.Value, error)

Value Returns a golang database/sql driver value for ClusterIDs.

type CronScript

type CronScript struct {
	ID         uuid.UUID  `db:"id"`
	OrgID      uuid.UUID  `db:"org_id"`
	Script     string     `db:"script"`
	ClusterIDs ClusterIDs `db:"cluster_ids"`
	ConfigStr  string     `db:"configs"`
	Enabled    bool       `db:"enabled"`
	FrequencyS int64      `db:"frequency_s"`
}

CronScript contains metadata about a regularly scheduled script.

type HandleNATSMessageFunc

type HandleNATSMessageFunc func(*cvmsgspb.V2CMessage)

HandleNATSMessageFunc is the signature for a NATS message handler.

type Server

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

Server is a bridge implementation of the pluginService.

func New

func New(db *sqlx.DB, dbKey string, nc *nats.Conn, vzmgrClient vzmgrpb.VZMgrServiceClient) *Server

New creates a new server.

func (*Server) CreateScript

func (s *Server) CreateScript(ctx context.Context, req *cronscriptpb.CreateScriptRequest) (*cronscriptpb.CreateScriptResponse, error)

CreateScript creates a cron script.

func (*Server) DeleteScript

func (s *Server) DeleteScript(ctx context.Context, req *cronscriptpb.DeleteScriptRequest) (*cronscriptpb.DeleteScriptResponse, error)

DeleteScript deletes a cron script.

func (*Server) GetScript

func (s *Server) GetScript(ctx context.Context, req *cronscriptpb.GetScriptRequest) (*cronscriptpb.GetScriptResponse, error)

GetScript gets a script stored in the cron script service.

func (*Server) GetScripts

func (s *Server) GetScripts(ctx context.Context, req *cronscriptpb.GetScriptsRequest) (*cronscriptpb.GetScriptsResponse, error)

GetScripts gets scripts stored in the cron script service, given a set of IDs.

func (*Server) HandleChecksumRequest

func (s *Server) HandleChecksumRequest(msg *cvmsgspb.V2CMessage)

HandleChecksumRequest handles incoming requests for cronscript checksums.

func (*Server) HandleScriptsRequest

func (s *Server) HandleScriptsRequest(msg *cvmsgspb.V2CMessage)

HandleScriptsRequest handles incoming requests for cron scripts registered to the given vizier.

func (*Server) Stop

func (s *Server) Stop()

Stop performs any necessary cleanup before shutdown.

func (*Server) UpdateScript

func (s *Server) UpdateScript(ctx context.Context, req *cronscriptpb.UpdateScriptRequest) (*cronscriptpb.UpdateScriptResponse, error)

UpdateScript updates an existing cron script.