grpcserver

Documentation

Overview

Package grpcserver services gRPC requests.

Index

• Constants
• type GrpcServer
• type SimpleGrpcServer
  • func (grpcServer *SimpleGrpcServer) GracefulStop(ctx context.Context) error
  • func (grpcServer *SimpleGrpcServer) Serve(ctx context.Context) error
  • func (grpcServer *SimpleGrpcServer) UpdateObserver(ctx context.Context, request *observerpb.UpdateObserverRequest) (*observerpb.UpdateObserverResponse, error)

Constants

const ComponentID = 6464

Identfier of the package found messages having the format "senzing-6464xxxx".

Types

type GrpcServer

type GrpcServer interface {
	GracefulStop(ctx context.Context) error
	Serve(ctx context.Context) error
}

type SimpleGrpcServer

type SimpleGrpcServer struct {
	Port          int
	ServerOptions []grpc.ServerOption
	Subject       subject.Subject
	observerpb.UnimplementedObserverServer
	// contains filtered or unexported fields
}

SimpleGrpcServer is the default implementation of the GrpcServer interface.

func (*SimpleGrpcServer) GracefulStop

func (grpcServer *SimpleGrpcServer) GracefulStop(ctx context.Context) error

The Serve method starts the gRPC server.

Input

• ctx: A context to control lifecycle.

func (*SimpleGrpcServer) Serve

func (grpcServer *SimpleGrpcServer) Serve(ctx context.Context) error

The Serve method starts the gRPC server.

Input

• ctx: A context to control lifecycle.

func (*SimpleGrpcServer) UpdateObserver

func (grpcServer *SimpleGrpcServer) UpdateObserver(ctx context.Context, request *observerpb.UpdateObserverRequest) (*observerpb.UpdateObserverResponse, error)

The UpdateObserver method is a gRPC protocol method which receives a message from a remote observer and repeats it to local observers.

Input

• ctx: A context to control lifecycle.
• request: Includes the message to send to Observers.

Output

• Empty response
• Error