server

package
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 30, 2021 License: MIT Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrEmptyFile = errors.New("file contents cannot be empty")
)

Functions

func CustomError 

func CustomError(c common.Code, msg string) error

Types

type ErrorWrapper 

type ErrorWrapper struct {
	Status *common.Status
}

func (*ErrorWrapper) Error 

func (e *ErrorWrapper) Error() string

type Server 

type Server struct {
	AuthToken        string
	PersistentConfig *config.Config
	VCService        vcservice.IVCService
	GithubService    github.IGithub
	StatsService     stats.IStats
	ErrorsService    uierrors.IUIErrors
	Etcd             etcd.IEtcd
	Log              *logrus.Entry
	CLIOptions       *opts.CLIOptions
}

func (*Server) ApproveSchema 

func (s *Server) ApproveSchema(ctx context.Context, req *protos.ApproveSchemaVersionRequest) (*protos.ApproveSchemaVersionResponse, error)

func (*Server) CreateAlert 

func (s *Server) CreateAlert(ctx context.Context, req *protos.CreateAlertRequest) (*protos.CreateAlertResponse, error)

func (*Server) CreateComposite 

func (s *Server) CreateComposite(ctx context.Context, req *protos.CreateCompositeRequest) (*protos.CreateCompositeResponse, error)

func (*Server) CreateConnection 

func (s *Server) CreateConnection(ctx context.Context, req *protos.CreateConnectionRequest) (*protos.CreateConnectionResponse, error)

func (*Server) CreateMonitor 

func (s *Server) CreateMonitor(ctx context.Context, req *protos.CreateMonitorRequest) (*protos.CreateMonitorResponse, error)

func (*Server) CreatePullRequest 

func (s *Server) CreatePullRequest(ctx context.Context, req *protos.CreatePRRequest) (*protos.CreatePRResponse, error)

func (*Server) CreateRead 

func (s *Server) CreateRead(_ context.Context, req *protos.CreateReadRequest) (*protos.CreateReadResponse, error)

func (*Server) CreateRelay 

func (s *Server) CreateRelay(ctx context.Context, req *protos.CreateRelayRequest) (*protos.CreateRelayResponse, error)

func (*Server) CreateService 

func (s *Server) CreateService(ctx context.Context, req *protos.CreateServiceRequest) (*protos.CreateServiceResponse, error)

func (*Server) CreateValidation 

func (s *Server) CreateValidation(ctx context.Context, req *protos.CreateValidationRequest) (*protos.CreateValidationResponse, error)

func (*Server) DeleteAlert 

func (s *Server) DeleteAlert(ctx context.Context, req *protos.DeleteAlertRequest) (*protos.DeleteAlertResponse, error)

func (*Server) DeleteComposite 

func (s *Server) DeleteComposite(ctx context.Context, req *protos.DeleteCompositeRequest) (*protos.DeleteCompositeResponse, error)

func (*Server) DeleteConnection 

func (s *Server) DeleteConnection(ctx context.Context, req *protos.DeleteConnectionRequest) (*protos.DeleteConnectionResponse, error)

func (*Server) DeleteMonitor 

func (s *Server) DeleteMonitor(ctx context.Context, req *protos.DeleteMonitorRequest) (*protos.DeleteMonitorResponse, error)

func (*Server) DeleteRead 

func (s *Server) DeleteRead(_ context.Context, req *protos.DeleteReadRequest) (*protos.DeleteReadResponse, error)

func (*Server) DeleteRelay 

func (s *Server) DeleteRelay(ctx context.Context, req *protos.DeleteRelayRequest) (*protos.DeleteRelayResponse, error)

func (*Server) DeleteSchema 

func (s *Server) DeleteSchema(ctx context.Context, req *protos.DeleteSchemaRequest) (*protos.DeleteSchemaResponse, error)

func (*Server) DeleteSchemaVersion 

func (s *Server) DeleteSchemaVersion(ctx context.Context, req *protos.DeleteSchemaVersionRequest) (*protos.DeleteSchemaVersionResponse, error)

func (*Server) DeleteService 

func (s *Server) DeleteService(ctx context.Context, req *protos.DeleteServiceRequest) (*protos.DeleteServiceResponse, error)

func (*Server) DeleteValidation 

func (s *Server) DeleteValidation(ctx context.Context, req *protos.DeleteValidationRequest) (*protos.DeleteValidationResponse, error)

func (*Server) GetAlert 

func (s *Server) GetAlert(ctx context.Context, req *protos.GetMonitorRequest) (*protos.GetMonitorResponse, error)

func (*Server) GetAllComposites 

func (s *Server) GetAllComposites(ctx context.Context, req *protos.GetAllCompositesRequest) (*protos.GetAllCompositesResponse, error)

func (*Server) GetAllConnections 

func (s *Server) GetAllConnections(_ context.Context, req *protos.GetAllConnectionsRequest) (*protos.GetAllConnectionsResponse, error)

func (*Server) GetAllReads 

func (s *Server) GetAllReads(_ context.Context, req *protos.GetAllReadsRequest) (*protos.GetAllReadsResponse, error)

func (*Server) GetAllRelays 

func (s *Server) GetAllRelays(_ context.Context, req *protos.GetAllRelaysRequest) (*protos.GetAllRelaysResponse, error)

func (*Server) GetAllSchemas 

func (s *Server) GetAllSchemas(_ context.Context, req *protos.GetAllSchemasRequest) (*protos.GetAllSchemasResponse, error)

func (*Server) GetAllServices 

func (s *Server) GetAllServices(_ context.Context, req *protos.GetAllServicesRequest) (*protos.GetAllServicesResponse, error)

func (*Server) GetAllValidations 

func (s *Server) GetAllValidations(_ context.Context, req *protos.GetAllValidationsRequest) (*protos.GetAllValidationsResponse, error)

func (*Server) GetComposite 

func (s *Server) GetComposite(ctx context.Context, req *protos.GetCompositeRequest) (*protos.GetCompositeResponse, error)

func (*Server) GetConnection 

func (s *Server) GetConnection(_ context.Context, req *protos.GetConnectionRequest) (*protos.GetConnectionResponse, error)

func (*Server) GetCounterHistory 

func (s *Server) GetCounterHistory(ctx context.Context, req *protos.GetCounterHistoryRequest) (*protos.GetCounterHistoryResponse, error)

func (*Server) GetCurrentCounters 

func (s *Server) GetCurrentCounters(ctx context.Context, req *protos.GetCurrentCountersRequest) (*protos.GetCurrentCountersResponse, error)

func (*Server) GetErrorHistory 

func (s *Server) GetErrorHistory(ctx context.Context, req *protos.GetErrorHistoryRequest) (*protos.GetErrorHistoryResponse, error)

func (*Server) GetLiveErrors 

func (s *Server) GetLiveErrors(req *protos.GetLiveErrorsRequest, srv protos.PlumberServer_GetLiveErrorsServer) error

GetLiveErrors ships live errors from plumber that happen in the background outside of the normal lifecycle of a gRPC request/response

func (*Server) GetMonitor 

func (s *Server) GetMonitor(ctx context.Context, req *protos.GetMonitorRequest) (*protos.GetMonitorResponse, error)

func (*Server) GetRepoFile 

func (s *Server) GetRepoFile(ctx context.Context, req *protos.GetRepoFileRequest) (*protos.GetRepoFileResponse, error)

func (*Server) GetRepoList 

func (s *Server) GetRepoList(ctx context.Context, req *protos.GetRepoListRequest) (*protos.GetRepoListResponse, error)

func (*Server) GetRepoTree 

func (s *Server) GetRepoTree(ctx context.Context, req *protos.GetRepoTreeRequest) (*protos.GetRepoTreeResponse, error)

func (*Server) GetSchema 

func (s *Server) GetSchema(_ context.Context, req *protos.GetSchemaRequest) (*protos.GetSchemaResponse, error)

func (*Server) GetServerOptions 

func (s *Server) GetServerOptions(_ context.Context, req *protos.GetServerOptionsRequest) (*protos.GetServerOptionsResponse, error)

func (*Server) GetService 

func (s *Server) GetService(_ context.Context, req *protos.GetServiceRequest) (*protos.GetServiceResponse, error)

func (*Server) GetVCEvents 

func (s *Server) GetVCEvents(req *protos.GetVCEventsRequest, srv protos.PlumberServer_GetVCEventsServer) error

GetVCEvents reads the current stream of VC events from vc-service and sends them to the frontend for consumption

func (*Server) GetValidation 

func (s *Server) GetValidation(_ context.Context, req *protos.GetValidationRequest) (*protos.GetValidationResponse, error)

func (*Server) ImportGithub 

func (s *Server) ImportGithub(ctx context.Context, req *protos.ImportGithubRequest) (*protos.ImportGithubResponse, error)

func (*Server) ImportGithubSelect 

func (s *Server) ImportGithubSelect(ctx context.Context, req *protos.ImportGithubSelectRequest) (*protos.ImportGithubSelectResponse, error)

func (*Server) ImportLocal 

func (s *Server) ImportLocal(ctx context.Context, req *protos.ImportLocalRequest) (*protos.ImportLocalResponse, error)

func (*Server) InferJSONSchema 

func (s *Server) InferJSONSchema(r *types.Read, readRecord *records.ReadRecord) error

func (*Server) LinkRepoToService 

func (s *Server) LinkRepoToService(ctx context.Context, req *protos.LinkRepoToServiceRequest) (*protos.LinkRepoToServiceResponse, error)

func (*Server) LinkSchemaToService 

func (s *Server) LinkSchemaToService(ctx context.Context, req *protos.LinkSchemaToServiceRequest) (*protos.LinkSchemaToServiceResponse, error)

func (*Server) ResumeRead 

func (s *Server) ResumeRead(_ context.Context, req *protos.ResumeReadRequest) (*protos.ResumeReadResponse, error)

func (*Server) ResumeRelay 

func (s *Server) ResumeRelay(ctx context.Context, req *protos.ResumeRelayRequest) (*protos.ResumeRelayResponse, error)

func (*Server) SetServerOptions 

func (s *Server) SetServerOptions(ctx context.Context, req *protos.SetServerOptionsRequest) (*protos.SetServerOptionsResponse, error)

SetServerOptions is called by the frontend to update any necessary server config options. These changes will also be broadcast to other plumber instances.

func (*Server) StartRead 

func (s *Server) StartRead(req *protos.StartReadRequest, srv protos.PlumberServer_StartReadServer) error

func (*Server) StopRead 

func (s *Server) StopRead(_ context.Context, req *protos.StopReadRequest) (*protos.StopReadResponse, error)

TODO: Need to figure out how reads work with clustered plumber - do all nodes perform a read? If so, should StopRead() inform other nodes to stop reading as well?

func (*Server) StopRelay 

func (s *Server) StopRelay(_ context.Context, req *protos.StopRelayRequest) (*protos.StopRelayResponse, error)

func (*Server) TestConnection 

func (s *Server) TestConnection(ctx context.Context, req *protos.TestConnectionRequest) (*protos.TestConnectionResponse, error)

func (*Server) UnlinkRepoFromService 

func (s *Server) UnlinkRepoFromService(ctx context.Context, req *protos.UnlinkRepoFromServiceRequest) (*protos.UnlinkRepoFromServiceResponse, error)

func (*Server) UnlinkSchemaFromService 

func (s *Server) UnlinkSchemaFromService(ctx context.Context, req *protos.UnlinkSchemaFromServiceRequest) (*protos.UnlinkSchemaFromServiceResponse, error)

func (*Server) UpdateAlert 

func (s *Server) UpdateAlert(ctx context.Context, req *protos.UpdateAlertRequest) (*protos.UpdateAlertResponse, error)

func (*Server) UpdateComposite 

func (s *Server) UpdateComposite(ctx context.Context, req *protos.UpdateCompositeRequest) (*protos.UpdateCompositeResponse, error)

func (*Server) UpdateConnection 

func (s *Server) UpdateConnection(ctx context.Context, req *protos.UpdateConnectionRequest) (*protos.UpdateConnectionResponse, error)

func (*Server) UpdateMonitor 

func (s *Server) UpdateMonitor(ctx context.Context, req *protos.UpdateMonitorRequest) (*protos.UpdateMonitorResponse, error)

func (*Server) UpdateRelay 

func (s *Server) UpdateRelay(_ context.Context, req *protos.UpdateRelayRequest) (*protos.UpdateRelayResponse, error)

func (*Server) UpdateSchema 

func (s *Server) UpdateSchema(ctx context.Context, req *protos.UpdateSchemaRequest) (*protos.UpdateSchemaResponse, error)

func (*Server) UpdateService 

func (s *Server) UpdateService(ctx context.Context, req *protos.UpdateServiceRequest) (*protos.UpdateServiceResponse, error)

func (*Server) UpdateValidation 

func (s *Server) UpdateValidation(ctx context.Context, req *protos.UpdateValidationRequest) (*protos.UpdateValidationResponse, error)

func (*Server) Write 

func (s *Server) Write(ctx context.Context, req *protos.WriteRequest) (*protos.WriteResponse, error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.