grpc

package
v0.14.1-rc.6 Latest Latest
Warning

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

 Go to latest Published: Mar 2, 2022 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func LogArg 

func LogArg(arg interface{}) string

func NewDocumentServer 

func NewDocumentServer(docPlugin document.DocumentService) pb.DocumentServiceServer

func NewEventServiceServer 

func NewEventServiceServer(eventsPlugin events.EventService) pb.EventServiceServer

func NewGrpcError 

func NewGrpcError(operation string, err error) error

Provides GRPC error reporting

func NewPluginNotRegisteredError 

func NewPluginNotRegisteredError(plugin string) error

Provides generic error for unregistered plugins

func NewQueueServiceServer 

func NewQueueServiceServer(plugin queue.QueueService) pb.QueueServiceServer

func NewResourcesServiceServer added in v0.13.0 

func NewResourcesServiceServer() v1.ResourceServiceServer

func NewSecretServer 

func NewSecretServer(secretPlugin secret.SecretService) pb.SecretServiceServer

func NewStorageServiceServer 

func NewStorageServiceServer(storagePlugin storage.StorageService) pb.StorageServiceServer

func NewTopicServiceServer 

func NewTopicServiceServer(eventService events.EventService) pb.TopicServiceServer

Types

type DocumentServiceServer 

type DocumentServiceServer struct {
	pb.UnimplementedDocumentServiceServer
	// contains filtered or unexported fields
}

DocumentServiceServer - GRPC Interface for registered Nitric Document Plugin

func (*DocumentServiceServer) Delete 

func (s *DocumentServiceServer) Delete(ctx context.Context, req *pb.DocumentDeleteRequest) (*pb.DocumentDeleteResponse, error)

func (*DocumentServiceServer) Get 

func (s *DocumentServiceServer) Get(ctx context.Context, req *pb.DocumentGetRequest) (*pb.DocumentGetResponse, error)

func (*DocumentServiceServer) Query 

func (s *DocumentServiceServer) Query(ctx context.Context, req *pb.DocumentQueryRequest) (*pb.DocumentQueryResponse, error)

func (*DocumentServiceServer) QueryStream 

func (s *DocumentServiceServer) QueryStream(req *pb.DocumentQueryStreamRequest, srv pb.DocumentService_QueryStreamServer) error

func (*DocumentServiceServer) Set 

func (s *DocumentServiceServer) Set(ctx context.Context, req *pb.DocumentSetRequest) (*pb.DocumentSetResponse, error)

type EventServiceServer 

type EventServiceServer struct {
	pb.UnimplementedEventServiceServer
	// contains filtered or unexported fields
}

GRPC Interface for registered Nitric events Plugins

func (*EventServiceServer) Publish 

func (s *EventServiceServer) Publish(ctx context.Context, req *pb.EventPublishRequest) (*pb.EventPublishResponse, error)

type FaasServer 

type FaasServer struct {
	pb.UnimplementedFaasServiceServer
	// contains filtered or unexported fields
}

func NewFaasServer 

func NewFaasServer(workerPool worker.WorkerPool) *FaasServer

func (*FaasServer) TriggerStream 

func (s *FaasServer) TriggerStream(stream pb.FaasService_TriggerStreamServer) error

Starts a new stream A reference to this stream will be passed on to a new worker instance This represents a new server that is ready to begin processing

type QueueServiceServer 

type QueueServiceServer struct {
	pb.UnimplementedQueueServiceServer
	// contains filtered or unexported fields
}

GRPC Interface for registered Nitric Storage Plugins

func (*QueueServiceServer) Complete 

func (s *QueueServiceServer) Complete(ctx context.Context, req *pb.QueueCompleteRequest) (*pb.QueueCompleteResponse, error)

func (*QueueServiceServer) Receive 

func (s *QueueServiceServer) Receive(ctx context.Context, req *pb.QueueReceiveRequest) (*pb.QueueReceiveResponse, error)

func (*QueueServiceServer) Send 

func (s *QueueServiceServer) Send(ctx context.Context, req *pb.QueueSendRequest) (*pb.QueueSendResponse, error)

func (*QueueServiceServer) SendBatch 

func (s *QueueServiceServer) SendBatch(ctx context.Context, req *pb.QueueSendBatchRequest) (*pb.QueueSendBatchResponse, error)

type ResourcesServiceServer added in v0.13.0 

type ResourcesServiceServer struct {
	v1.UnimplementedResourceServiceServer
}

func (*ResourcesServiceServer) Declare added in v0.13.0 

func (rs *ResourcesServiceServer) Declare(ctx context.Context, req *v1.ResourceDeclareRequest) (*v1.ResourceDeclareResponse, error)

type SecretServer 

type SecretServer struct {
	pb.UnimplementedSecretServiceServer
	// contains filtered or unexported fields
}

GRPC Interface for registered Nitric Secret Plugins

func (*SecretServer) Access 

func (s *SecretServer) Access(ctx context.Context, req *pb.SecretAccessRequest) (*pb.SecretAccessResponse, error)

func (*SecretServer) Put 

func (s *SecretServer) Put(ctx context.Context, req *pb.SecretPutRequest) (*pb.SecretPutResponse, error)

type StorageServiceServer 

type StorageServiceServer struct {
	pb.UnimplementedStorageServiceServer
	// contains filtered or unexported fields
}

GRPC Interface for registered Nitric Storage Plugins

func (*StorageServiceServer) Delete 

func (s *StorageServiceServer) Delete(ctx context.Context, req *pb.StorageDeleteRequest) (*pb.StorageDeleteResponse, error)

func (*StorageServiceServer) PreSignUrl 

func (s *StorageServiceServer) PreSignUrl(ctx context.Context, req *pb.StoragePreSignUrlRequest) (*pb.StoragePreSignUrlResponse, error)

func (*StorageServiceServer) Read 

func (s *StorageServiceServer) Read(ctx context.Context, req *pb.StorageReadRequest) (*pb.StorageReadResponse, error)

func (*StorageServiceServer) Write 

func (s *StorageServiceServer) Write(ctx context.Context, req *pb.StorageWriteRequest) (*pb.StorageWriteResponse, error)

type TopicServiceServer 

type TopicServiceServer struct {
	pb.UnimplementedTopicServiceServer
	// contains filtered or unexported fields
}

func (*TopicServiceServer) List 

func (s *TopicServiceServer) List(ctx context.Context, req *pb.TopicListRequest) (*pb.TopicListResponse, 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.