grpcworker

package
v2.8.1 Latest Latest
Warning

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

 Go to latest Published: Jun 4, 2026 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func TLSConfigForGRPC 

func TLSConfigForGRPC(cfg *tls.Config) *tls.Config

TLSConfigForGRPC is a helper that builds a *tls.Config from an existing TLS config. Callers can use this when the transport needs TLS but must remain gRPC-import-free.

Types

type Server 

type Server struct {
	workerapipb.UnimplementedWorkerServiceServer

	Pull          *pullapi.Server
	ResolveRoute  func(endpoint string) (route string, ok bool)
	Authorize     workerapi.Authorizer
	MaxLeaseBatch int
}

Server exposes the optional worker gRPC transport while reusing pull semantics.

func NewServer 

func NewServer(pullServer *pullapi.Server) *Server

func (*Server) Ack 

func (s *Server) Ack(ctx context.Context, req *workerapipb.AckRequest) (*workerapipb.AckResponse, error)

func (*Server) Dequeue 

func (s *Server) Dequeue(ctx context.Context, req *workerapipb.DequeueRequest) (*workerapipb.DequeueResponse, error)

func (*Server) Extend 

func (s *Server) Extend(ctx context.Context, req *workerapipb.ExtendRequest) (*emptypb.Empty, error)

func (*Server) Nack 

func (s *Server) Nack(ctx context.Context, req *workerapipb.NackRequest) (*workerapipb.NackResponse, error)

Source Files

View all Source files

Directories

Path Synopsis

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.