service

Feb 18, 2024

Changes in this version

+ const StatusStarted

+ const StatusStarting

+ const StatusStopped

type Base

+ HnUpTime string

+ Meta *meta.Data

+ func (s *Base) Status() (string, time.Time)

+ type HealthStatus struct

+ Details map[string]string

+ Error error

+ ServiceStatus string

+ StartedAt string

+ Status string

+ type StatusType int

+ func (s StatusType) String() string

Feb 14, 2024

Changes in this version

+ var DefaultGrpcDialer = netConn

+ var DefaultGrpcListener = netConn

+ var DefaultHTTPClient = netConn

+ var DefaultHTTPListener = netConn

+ var ErrEmptyAddress = errors.New("address is empty")

+ var ErrEnvLoading = errors.New("env.Populate: error initializing otel stack")

+ var ErrOtelStack = errors.New("obs.New: error initializing otel stack")

+ func AttachProfilingHandlers(router *mux.Router)

+ type Base struct

+ Addr string

+ Ctx context.Context

+ OtelProvider *obs.OtelProvider

+ func New(opts ...Option) (*Base, error)

+ func (s *Base) Metadata() map[string]string

+ func (s *Base) Name() string

+ func (s *Base) SetStartedNow()

+ func (s *Base) Stop()

+ func (s *Base) Stopped()

+ func (s *Base) WhenStarted() time.Time

+ type BufConn struct

+ func NewBufConn() *BufConn

+ func NewBufConnWithTimeout(timeout time.Duration) *BufConn

+ func (t *BufConn) Close(addr string) error

+ func (t *BufConn) CloseAll()

+ func (t *BufConn) Dial(_ context.Context, addr string) (*rpc.ClientConn, error)

+ func (t *BufConn) Listen(addr string) (net.Listener, error)

+ func (t *BufConn) NewHTTPClient(addr string) (*http.Client, error)

+ func (t *BufConn) Tranport(addr string) (*http.Transport, error)

+ type ErrNotHealthy struct

+ Addr string

+ func (e ErrNotHealthy) Error() string

+ type GrpcConn struct

+ Dialer GrpcDialer

+ Listener GrpcListener

+ type GrpcDialer interface

+ Dial func(ctx context.Context, addr string) (*rpc.ClientConn, error)

+ type GrpcListener interface

+ Listen func(addr string) (net.Listener, error)

+ type HTTPClientBuilder interface

+ NewHTTPClient func(addr string) (*http.Client, error)

+ type HTTPConn struct

+ ClientBuilder HTTPClientBuilder

+ Listener HTTPListener

+ func (s HTTPConn) ClientBuilderOrDefault() HTTPClientBuilder

+ func (s HTTPConn) ListenerOrDefault() HTTPListener

+ type HTTPListener interface

+ Listen func(addr string) (net.Listener, error)

+ type HTTPTranporter interface

+ Tranport func(addr string) (*http.Transport, error)

+ type HealthChecker interface

+ CheckOk func(ctx context.Context) error

+ Close func() error

+ type Kind int

+ const GRPC

+ const HTTP

+ const Process

+ type ListenerFn func(ctx context.Context, addr string) (net.Listener, error)

+ type NetConn struct

+ func (NetConn) Dial(_ context.Context, addr string) (*rpc.ClientConn, error)

+ func (NetConn) Listen(addr string) (net.Listener, error)

+ func (NetConn) NewHTTPClient(_ string) (*http.Client, error)

+ type Option func(*Base)

+ func WithAddr(addr string) Option

+ func WithContext(ctx context.Context) Option

+ func WithKind(kind string) Option

+ func WithMetaInfo(meta *meta.Data) Option

+ func WithName(name string) Option

+ func WithOtelProvider(p *obs.OtelProvider) Option

Dec 4, 2023

Changes in this version

+ type GrpcHelthCheckClient struct

+ func (c *GrpcHelthCheckClient) Check(ctx context.Context, name string) (healthpb.HealthCheckResponse_ServingStatus, error)

+ func (c *GrpcHelthCheckClient) Close()

type GrpcServerInfo

+ func (g *GrpcServerInfo) Metadata(ctx context.Context, req *svcmeta.GrpcMetadataRequest) (*svcmeta.GrpcMetadataReply, error)

type GrpcService

+ func NewGrpcService(ctx context.Context, name string, desc *grpc.ServiceDesc, ...) (*GrpcService, error)

type Service

+ Ctx context.Context

Dec 2, 2023

Changes in this version

+ func Dial(addr string) (*grpc.ClientConn, error)

+ func EmptyhealthCheckHandler(context.Context) error

+ type Closeable interface

+ Close func() error

+ type GrpcServerHelthCheckClient struct

+ func NewGrpcServerHelthCheckClient(host string) (*GrpcServerHelthCheckClient, error)

+ func (c *GrpcServerHelthCheckClient) Check(ctx context.Context, name string) (healthpb.HealthCheckResponse_ServingStatus, error)

+ func (c *GrpcServerHelthCheckClient) Close()

+ type GrpcServerInfo struct

+ func NewGrpcServerInfo(svc *GrpcService) *GrpcServerInfo

+ func (g *GrpcServerInfo) Info(ctx context.Context, req *info.InfoRequest) (*info.InfoResponse, error)

+ type GrpcServerInfoClient struct

+ func NewGrpcServerInfoClient(host string) (*GrpcServerInfoClient, error)

+ func (c *GrpcServerInfoClient) Close()

+ func (c *GrpcServerInfoClient) Info(ctx context.Context, in *pb.InfoRequest) ([]*pb.Info, error)

+ type GrpcService struct

+ func NewGrpService(ctx context.Context, name string, desc *grpc.ServiceDesc, ...) (*GrpcService, error)

+ func (sh *GrpcService) Dispose()

+ func (sh *GrpcService) Info() map[string]string

+ func (sh *GrpcService) Serve() error

+ type HeadlessService struct

+ func NewHeadlessService(ctx context.Context, name string, serve func(ctx context.Context) error) *HeadlessService

+ func (s HeadlessService) Serve() error

+ type HttpService struct

+ func NewHttpService(ctx context.Context, name, resource string, ...) *HttpService

+ func (sh *HttpService) Serve() error

type Service

+ Addr string

+ Name string

+ StartTime time.Time

+ func NewService(ctx context.Context, name string) *Service

Nov 28, 2023

Changes in this version

+ func StartNamed(name string, service Service)

Nov 21, 2023

Changes in this version

+ func Start(service Service)

+ type Service func(context.Context) error