grpc

package
v0.10.0 Latest Latest
Warning

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

 Go to latest Published: Sep 1, 2021 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewDocumentServer 

func NewDocumentServer(docPlugin document.DocumentService) pb.DocumentServiceServer

func NewEventServiceServer added in v0.2.2 

func NewEventServiceServer(eventsPlugin events.EventService) pb.EventServiceServer

func NewGrpcError added in v0.2.3 

func NewGrpcError(operation string, err error) error

Provides GRPC error reporting

func NewPluginNotRegisteredError added in v0.6.1 

func NewPluginNotRegisteredError(plugin string) error

Provides generic error for unregistered plugins

func NewQueueServiceServer added in v0.2.2 

func NewQueueServiceServer(plugin queue.QueueService) pb.QueueServiceServer

func NewSecretServer added in v0.6.0 

func NewSecretServer(secretPlugin secret.SecretService) pb.SecretServiceServer

func NewStorageServiceServer added in v0.2.2 

func NewStorageServiceServer(storagePlugin storage.StorageService) pb.StorageServiceServer

func NewTopicServiceServer added in v0.2.2 

func NewTopicServiceServer(eventService events.EventService) pb.TopicServiceServer

Types

type DocumentServiceServer added in v0.2.3 

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

DocumentServiceServer - GRPC Interface for registered Nitric Document Plugin

func (*DocumentServiceServer) Delete added in v0.2.3 

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

func (*DocumentServiceServer) Get added in v0.2.3 

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

func (*DocumentServiceServer) Query added in v0.2.3 

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

func (*DocumentServiceServer) QueryStream added in v0.10.0 

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

func (*DocumentServiceServer) Set added in v0.2.3 

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

type EventServiceServer added in v0.2.2 

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

GRPC Interface for registered Nitric events Plugins

func (*EventServiceServer) Publish added in v0.2.2 

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 added in v0.2.2 

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

GRPC Interface for registered Nitric Storage Plugins

func (*QueueServiceServer) Complete added in v0.2.2 

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

func (*QueueServiceServer) Receive added in v0.2.2 

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

func (*QueueServiceServer) Send added in v0.2.2 

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

func (*QueueServiceServer) SendBatch added in v0.2.2 

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

type SecretServer added in v0.6.0 

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

GRPC Interface for registered Nitric Secret Plugins

func (*SecretServer) Access added in v0.6.0 

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

func (*SecretServer) Put added in v0.6.0 

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

type StorageServiceServer added in v0.2.2 

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

GRPC Interface for registered Nitric Storage Plugins

func (*StorageServiceServer) Delete added in v0.2.2 

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

func (*StorageServiceServer) Read added in v0.2.2 

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

func (*StorageServiceServer) Write added in v0.2.2 

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

type TopicServiceServer added in v0.2.2 

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

func (*TopicServiceServer) List added in v0.2.2 

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.