collector

package
v1.50.1 Latest Latest
Warning

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

 Go to latest Published: Aug 9, 2024 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ApiToOpenApiSpec 

func ApiToOpenApiSpec(apiRegistrationRequests map[string][]*apispb.RegistrationRequest, apiSecurityDefinitions map[string]map[string]*resourcespb.ApiSecurityDefinitionResource, projectErrors *ProjectErrors) (*openapi3.T, error)

func GetMigrationImageBuildContexts added in v1.42.0 

func GetMigrationImageBuildContexts(allServiceRequirements []*ServiceRequirements, fs afero.Fs) (map[string]*runtime.RuntimeBuildContext, error)

Collect a list of migration images that need to be built these requirements need to be supplied to the deployment serviceS

func ServiceRequirementsToSpec 

func ServiceRequirementsToSpec(projectName string, environmentVariables map[string]string, allServiceRequirements []*ServiceRequirements, defaultMigrationImage string) (*deploymentspb.Spec, error)

convert service requirements to a cloud bill of materials

Types

type ApiCollectorServer 

type ApiCollectorServer struct {
	apispb.UnimplementedApiServer
	// contains filtered or unexported fields
}

func (*ApiCollectorServer) Serve 

func (s *ApiCollectorServer) Serve(stream apispb.Api_ServeServer) error

type ProjectErrors 

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

func (*ProjectErrors) Add 

func (pe *ProjectErrors) Add(err error)

func (ProjectErrors) Error 

func (pe ProjectErrors) Error() error

type ServiceRequirements 

type ServiceRequirements struct {
	ApiServer apispb.ApiServer
	// contains filtered or unexported fields
}

ServiceRequirements - Cloud resource requirements for a Nitric Application Service

Hosts all Nitric resource servers in a collection-only mode, where services can call into the servers to request resources they require for their operation.

func NewServiceRequirements 

func NewServiceRequirements(serviceName string, serviceFile string, serviceType string) *ServiceRequirements

func (*ServiceRequirements) Access added in v1.48.1 

func (s *ServiceRequirements) Access(context.Context, *secretspb.SecretAccessRequest) (*secretspb.SecretAccessResponse, error)

Secrets

func (*ServiceRequirements) ApiDetails added in v1.48.1 

func (s *ServiceRequirements) ApiDetails(context.Context, *apispb.ApiDetailsRequest) (*apispb.ApiDetailsResponse, error)

API

func (*ServiceRequirements) CloseConnection added in v1.48.1 

func (s *ServiceRequirements) CloseConnection(context.Context, *websocketspb.WebsocketCloseConnectionRequest) (*websocketspb.WebsocketCloseConnectionResponse, error)

func (*ServiceRequirements) Complete added in v1.48.1 

func (s *ServiceRequirements) Complete(context.Context, *queuespb.QueueCompleteRequest) (*queuespb.QueueCompleteResponse, error)

func (*ServiceRequirements) ConnectionString added in v1.48.1 

func (s *ServiceRequirements) ConnectionString(context.Context, *sqlpb.SqlConnectionStringRequest) (*sqlpb.SqlConnectionStringResponse, error)

SQL

func (*ServiceRequirements) Declare 

func (s *ServiceRequirements) Declare(ctx context.Context, req *resourcespb.ResourceDeclareRequest) (*resourcespb.ResourceDeclareResponse, error)

func (*ServiceRequirements) Delete added in v1.48.1 

func (s *ServiceRequirements) Delete(context.Context, *storagepb.StorageDeleteRequest) (*storagepb.StorageDeleteResponse, error)

func (*ServiceRequirements) DeleteKey added in v1.48.1 

func (s *ServiceRequirements) DeleteKey(context.Context, *kvstorepb.KvStoreDeleteKeyRequest) (*kvstorepb.KvStoreDeleteKeyResponse, error)

func (*ServiceRequirements) Dequeue added in v1.48.1 

func (s *ServiceRequirements) Dequeue(context.Context, *queuespb.QueueDequeueRequest) (*queuespb.QueueDequeueResponse, error)

func (*ServiceRequirements) Enqueue added in v1.48.1 

func (s *ServiceRequirements) Enqueue(context.Context, *queuespb.QueueEnqueueRequest) (*queuespb.QueueEnqueueResponse, error)

Queues

func (*ServiceRequirements) Error 

func (s *ServiceRequirements) Error() error

Error - Returns an error if any requirements have been registered incorrectly, such as duplicates

func (*ServiceRequirements) Exists added in v1.48.1 

func (s *ServiceRequirements) Exists(context.Context, *storagepb.StorageExistsRequest) (*storagepb.StorageExistsResponse, error)

func (*ServiceRequirements) GetValue added in v1.48.1 

func (s *ServiceRequirements) GetValue(context.Context, *kvstorepb.KvStoreGetValueRequest) (*kvstorepb.KvStoreGetValueResponse, error)

KeyValue

func (*ServiceRequirements) HandleEvents 

func (s *ServiceRequirements) HandleEvents(stream websocketspb.WebsocketHandler_HandleEventsServer) error

func (*ServiceRequirements) HasDatabases added in v1.42.0 

func (s *ServiceRequirements) HasDatabases() bool

TODO: Remove when databases are no longer in preview

func (*ServiceRequirements) ListBlobs added in v1.48.1 

func (s *ServiceRequirements) ListBlobs(context.Context, *storagepb.StorageListBlobsRequest) (*storagepb.StorageListBlobsResponse, error)

func (*ServiceRequirements) Listen 

func (s *ServiceRequirements) Listen(stream storagepb.StorageListener_ListenServer) error

func (*ServiceRequirements) PreSignUrl added in v1.48.1 

func (s *ServiceRequirements) PreSignUrl(context.Context, *storagepb.StoragePreSignUrlRequest) (*storagepb.StoragePreSignUrlResponse, error)

func (*ServiceRequirements) Proxy 

func (s *ServiceRequirements) Proxy(stream httppb.Http_ProxyServer) error

func (*ServiceRequirements) Publish added in v1.48.1 

func (s *ServiceRequirements) Publish(context.Context, *topicspb.TopicPublishRequest) (*topicspb.TopicPublishResponse, error)

Topics

func (*ServiceRequirements) Put added in v1.48.1 

func (s *ServiceRequirements) Put(context.Context, *secretspb.SecretPutRequest) (*secretspb.SecretPutResponse, error)

func (*ServiceRequirements) Read added in v1.48.1 

func (s *ServiceRequirements) Read(context.Context, *storagepb.StorageReadRequest) (*storagepb.StorageReadResponse, error)

Buckets

func (*ServiceRequirements) ScanKeys added in v1.48.1 

func (s *ServiceRequirements) ScanKeys(*kvstorepb.KvStoreScanKeysRequest, kvstorepb.KvStore_ScanKeysServer) error

func (*ServiceRequirements) Schedule 

func (s *ServiceRequirements) Schedule(stream schedulespb.Schedules_ScheduleServer) error

func (*ServiceRequirements) SendMessage added in v1.48.1 

func (s *ServiceRequirements) SendMessage(context.Context, *websocketspb.WebsocketSendRequest) (*websocketspb.WebsocketSendResponse, error)

func (*ServiceRequirements) Serve 

func (s *ServiceRequirements) Serve(stream apispb.Api_ServeServer) error

func (*ServiceRequirements) SetValue added in v1.48.1 

func (s *ServiceRequirements) SetValue(context.Context, *kvstorepb.KvStoreSetValueRequest) (*kvstorepb.KvStoreSetValueResponse, error)

func (*ServiceRequirements) SocketDetails added in v1.48.1 

func (s *ServiceRequirements) SocketDetails(context.Context, *websocketspb.WebsocketDetailsRequest) (*websocketspb.WebsocketDetailsResponse, error)

Websockets

func (*ServiceRequirements) Subscribe 

func (s *ServiceRequirements) Subscribe(stream topicspb.Subscriber_SubscribeServer) error

func (*ServiceRequirements) WorkerCount 

func (s *ServiceRequirements) WorkerCount() int

func (*ServiceRequirements) Write added in v1.48.1 

func (s *ServiceRequirements) Write(context.Context, *storagepb.StorageWriteRequest) (*storagepb.StorageWriteResponse, error)

Source Files

View all Source files

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.