actuator

Documentation

Index

• func NewGrpcServerWithActuator(srv mgrpc.RegisteredServer) (mgrpc.RegisteredServer, error)
• func SetAppInfoSingleton(a *AppInfo)
• type AppContributor
  • func GetAppContributor() AppContributor
• type AppInfo
  • func GetAppInfoSingleton() AppInfo
  • func NewAppInfo() *AppInfo
• type GrpcServerWithActuator
  • func (s *GrpcServerWithActuator) GracefulStop()
  • func (s *GrpcServerWithActuator) Serve(ln net.Listener) (err error)
  • func (s *GrpcServerWithActuator) Stop()
• type RuntimeIndicator
  • func GetRuntimeLivenessIndicator() RuntimeIndicator
  • func GetRuntimeReadinessIndicator() RuntimeIndicator

Functions

func NewGrpcServerWithActuator

func NewGrpcServerWithActuator(srv mgrpc.RegisteredServer) (mgrpc.RegisteredServer, error)

func SetAppInfoSingleton

func SetAppInfoSingleton(a *AppInfo)

Types

type AppContributor

type AppContributor info.Contributor

func GetAppContributor

func GetAppContributor() AppContributor

type AppInfo

type AppInfo struct {
	// The name of the program. Defaults to path.Base(os.Args[0])
	Name string `json:"name"`
	// Version of the program
	Version string `json:"version"`
	// Compilation date
	Compiled time.Time `json:"compiled,omitempty"`
}

func GetAppInfoSingleton

func GetAppInfoSingleton() AppInfo

func NewAppInfo

func NewAppInfo() *AppInfo

type GrpcServerWithActuator

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

func (*GrpcServerWithActuator) GracefulStop

func (s *GrpcServerWithActuator) GracefulStop()

func (*GrpcServerWithActuator) Serve

func (s *GrpcServerWithActuator) Serve(ln net.Listener) (err error)

func (*GrpcServerWithActuator) Stop

func (s *GrpcServerWithActuator) Stop()

type RuntimeIndicator

type RuntimeIndicator interface {
	Report() (status health.Status, details map[string]interface{})
	SetUnhealthy(reason string)
	SetHealthy(reason string)
	SetStarted()
}

func GetRuntimeLivenessIndicator

func GetRuntimeLivenessIndicator() RuntimeIndicator

func GetRuntimeReadinessIndicator

func GetRuntimeReadinessIndicator() RuntimeIndicator