grpc

Documentation

Index

• type GrpcServerAdapter
  • func NewGrpcServerAdapter() *GrpcServerAdapter
  • func (gsa *GrpcServerAdapter) BidirectionalStreaming(stream pb.Grpc_BidirectionalStreamingServer) error
  • func (gsa *GrpcServerAdapter) ClientStreaming(stream pb.Grpc_ClientStreamingServer) error
  • func (gsa *GrpcServerAdapter) Register(handler *domain.PrimaryAdapterHandler) error
  • func (gsa *GrpcServerAdapter) Serve(ctx context.Context, shutdownWg, readyWg *sync.WaitGroup) error
  • func (gsa *GrpcServerAdapter) ServerStreaming(req *pb.StreamRequest, stream pb.Grpc_ServerStreamingServer) error
  • func (gsa *GrpcServerAdapter) SimpleRPC(ctx context.Context, req *pb.StreamRequest) (*pb.StreamResponse, error)
• type GrpcVariantConfigs

Types

type GrpcServerAdapter

type GrpcServerAdapter struct {
	pb.UnimplementedGrpcServer
	// contains filtered or unexported fields
}

must implement ports.PrimaryPort

func NewGrpcServerAdapter

func NewGrpcServerAdapter() *GrpcServerAdapter

func (*GrpcServerAdapter) BidirectionalStreaming

func (gsa *GrpcServerAdapter) BidirectionalStreaming(stream pb.Grpc_BidirectionalStreamingServer) error

Bidirectional streaming

func (*GrpcServerAdapter) ClientStreaming

func (gsa *GrpcServerAdapter) ClientStreaming(stream pb.Grpc_ClientStreamingServer) error

Client-side streaming

func (*GrpcServerAdapter) Register

func (gsa *GrpcServerAdapter) Register(handler *domain.PrimaryAdapterHandler) error

Register registers tasks to the server

func (*GrpcServerAdapter) Serve

func (gsa *GrpcServerAdapter) Serve(ctx context.Context, shutdownWg, readyWg *sync.WaitGroup) error

Serve starts the grpc server

func (*GrpcServerAdapter) ServerStreaming

func (gsa *GrpcServerAdapter) ServerStreaming(req *pb.StreamRequest, stream pb.Grpc_ServerStreamingServer) error

Server-side streaming

func (*GrpcServerAdapter) SimpleRPC

func (gsa *GrpcServerAdapter) SimpleRPC(ctx context.Context, req *pb.StreamRequest) (*pb.StreamResponse, error)

Regular RPC

type GrpcVariantConfigs

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

GrpcVariantConfigs holds the config for each grpc variant