grpc

package
v0.0.2 Latest Latest
Warning

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

 Go to latest Published: May 24, 2021 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewEventServer 

func NewEventServer(eventingPlugin sdk.EventService) pb.EventServer

func NewKeyValueServer 

func NewKeyValueServer(kvPlugin sdk.KeyValueService) pb.KeyValueServer

func NewQueueServer 

func NewQueueServer(plugin sdk.QueueService) pb.QueueServer

func NewStorageServer 

func NewStorageServer(storagePlugin sdk.StorageService) pb.StorageServer

func NewTopicServer 

func NewTopicServer(eventService sdk.EventService) pb.TopicServer

func NewUserServer 

func NewUserServer(plugin sdk.UserService) pb.UserServer

NewUserServer - Returns a new concrete instance of the GRCP implementation for the Nitric User plugin

Types

type EventServer 

type EventServer struct {
	pb.UnimplementedEventServer
	// contains filtered or unexported fields
}

GRPC Interface for registered Nitric Eventing Plugins

func (*EventServer) Publish 

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

type KeyValueServer 

type KeyValueServer struct {
	pb.UnimplementedKeyValueServer
	// contains filtered or unexported fields
}

GRPC Interface for registered Nitric KV Plugin

func (*KeyValueServer) Delete 

func (s *KeyValueServer) Delete(ctx context.Context, req *pb.KeyValueDeleteRequest) (*pb.KeyValueDeleteResponse, error)

func (*KeyValueServer) Get 

func (s *KeyValueServer) Get(ctx context.Context, req *pb.KeyValueGetRequest) (*pb.KeyValueGetResponse, error)

func (*KeyValueServer) Put 

func (s *KeyValueServer) Put(ctx context.Context, req *pb.KeyValuePutRequest) (*pb.KeyValuePutResponse, error)

type QueueServer 

type QueueServer struct {
	pb.UnimplementedQueueServer
	// contains filtered or unexported fields
}

GRPC Interface for registered Nitric Storage Plugins

func (*QueueServer) Complete 

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

func (*QueueServer) Receive 

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

func (*QueueServer) Send 

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

func (*QueueServer) SendBatch 

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

type StorageServer 

type StorageServer struct {
	pb.UnimplementedStorageServer
	// contains filtered or unexported fields
}

GRPC Interface for registered Nitric Storage Plugins

func (*StorageServer) Delete 

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

func (*StorageServer) Read 

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

func (*StorageServer) Write 

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

type TopicServer 

type TopicServer struct {
	pb.UnimplementedTopicServer
	// contains filtered or unexported fields
}

func (*TopicServer) List 

func (s *TopicServer) List(context.Context, *pb.TopicListRequest) (*pb.TopicListResponse, error)

type UserServer 

type UserServer struct {
	pb.UnimplementedUserServer
	// contains filtered or unexported fields
}

UserServer - GRPC API for the nitric user plugin

func (*UserServer) Create 

func (s *UserServer) Create(ctx context.Context, req *pb.UserCreateRequest) (*pb.UserCreateResponse, error)

Create - Creates a new user

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.