process

Documentation

Index

• Constants
• type Container
  • func (c *Container) Addr() string
  • func (c *Container) AddrOrPanic() string
  • func (c *Container) NewHealthCheckClient() (service.HealthChecker, error)
• type Option
  • func WithAddr(addr string) Option
  • func WithContext(ctx context.Context) Option
  • func WithHealthCheckFN(s http.HealthCheckFn) Option
  • func WithName(n string) Option
  • func WithProfilingEnabled(p bool) Option
  • func WithSidecarListener(l service.HTTPListener) Option
  • func WithStarter(s func(ctx context.Context) error) Option
• type Options
• type Service
  • func New(opts ...Option) (*Service, error)
  • func (s Service) DoServe(listener net.Listener) error
  • func (s Service) DoServeWithDelay(listener net.Listener, delay time.Duration) error
  • func (s Service) NewHelthCheckClient(c service.HTTPClientBuilder) *http.HealthCheckClient
  • func (s Service) Serve() error
  • func (s Service) ServeWithDelay(delay time.Duration) error
• type StartFn

Constants

const Kind = service.Process

Types

type Container

type Container struct {
	service.HTTPConn
	Svc  *Service
	Name string
}

func (*Container) Addr

func (c *Container) Addr() string

func (*Container) AddrOrPanic

func (c *Container) AddrOrPanic() string

func (*Container) NewHealthCheckClient

func (c *Container) NewHealthCheckClient() (service.HealthChecker, error)

type Option

type Option interface {
	Apply(*Options)
}

func WithAddr

func WithAddr(addr string) Option

func WithContext

func WithContext(ctx context.Context) Option

func WithHealthCheckFN

func WithHealthCheckFN(s http.HealthCheckFn) Option

func WithName

func WithName(n string) Option

Setters

func WithProfilingEnabled

func WithProfilingEnabled(p bool) Option

func WithSidecarListener

func WithSidecarListener(l service.HTTPListener) Option

func WithStarter

func WithStarter(s func(ctx context.Context) error) Option

type Options

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

type Service

type Service struct {
	Base *service.Base
	// contains filtered or unexported fields
}

func New

func New(opts ...Option) (*Service, error)

func (Service) DoServe

func (s Service) DoServe(listener net.Listener) error

func (Service) DoServeWithDelay

func (s Service) DoServeWithDelay(listener net.Listener, delay time.Duration) error

func (Service) NewHelthCheckClient

func (s Service) NewHelthCheckClient(c service.HTTPClientBuilder) *http.HealthCheckClient

func (Service) Serve

func (s Service) Serve() error

func (Service) ServeWithDelay

func (s Service) ServeWithDelay(delay time.Duration) error

type StartFn

type StartFn func(ctx context.Context) error