grpc

Documentation

Index

• Variables
• type Server
  • func NewServer(_ context.Context, pipeline queue.Queue, repo discovery.ServiceRepo, ...) *Server
  • func (ps Server) Apply(ctx context.Context, req *propertyv1.ApplyRequest) (*propertyv1.ApplyResponse, error)
  • func (s *Server) FlagSet() *run.FlagSet
  • func (s *Server) GracefulStop()
  • func (s *Server) Name() string
  • func (s *Server) PreRun() error
  • func (s *Server) Serve() run.StopNotify
  • func (s *Server) Validate() error

Variables

var (
	ErrServerCert = errors.New("invalid server cert file")
	ErrServerKey  = errors.New("invalid server key file")
	ErrNoAddr     = errors.New("no address")
	ErrQueryMsg   = errors.New("invalid query message")
)

var ErrNotExist = errors.New("the object doesn't exist")

Types

type Server

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

func NewServer

func NewServer(_ context.Context, pipeline queue.Queue, repo discovery.ServiceRepo, schemaRegistry metadata.Service) *Server

func (Server) Apply

func (ps Server) Apply(ctx context.Context, req *propertyv1.ApplyRequest) (*propertyv1.ApplyResponse, error)

func (*Server) FlagSet

func (s *Server) FlagSet() *run.FlagSet

func (*Server) GracefulStop

func (s *Server) GracefulStop()

func (*Server) Name

func (s *Server) Name() string

func (*Server) PreRun

func (s *Server) PreRun() error

func (*Server) Serve

func (s *Server) Serve() run.StopNotify

func (*Server) Validate

func (s *Server) Validate() error