micro

May 17, 2024

Changes in this version

type Request

+ Reply func() string

Sep 20, 2023

Changes in this version

+ const DefaultQueueGroup

type Config

+ QueueGroup string

type EndpointConfig

+ QueueGroup string

type EndpointInfo

+ QueueGroup string

type EndpointOpt

+ func WithEndpointQueueGroup(queueGroup string) EndpointOpt

type EndpointStats

+ QueueGroup string

+ type GroupOpt func(*groupOpts) error

+ func WithGroupQueueGroup(queueGroup string) GroupOpt

Jun 12, 2023

Changes in this version

type Endpoint

+ Name string

+ type EndpointInfo struct

+ Metadata map[string]string

+ Name string

+ Subject string

type Info

+ Endpoints []EndpointInfo

Mar 24, 2023

Changes in this version

type Config

+ Metadata map[string]string

type EndpointConfig

+ Metadata map[string]string

type EndpointOpt

+ func WithEndpointMetadata(metadata map[string]string) EndpointOpt

type EndpointSchema

+ Metadata map[string]string

type EndpointStats

+ Metadata map[string]string

type ServiceIdentity

+ Metadata map[string]string

Feb 24, 2023

Changes in this version

type Handler

+ func ContextHandler(ctx context.Context, handler func(context.Context, Request)) Handler

Jan 18, 2023

Changes in this version

+ const InfoResponseType

+ const PingResponseType

+ const SchemaResponseType

+ const StatsResponseType

type Config

+ APIURL string

+ type EndpointConfig struct

+ Handler Handler

+ Schema *Schema

+ Subject string

+ type EndpointOpt func(*endpointOpts) error

+ func WithEndpointSchema(schema *Schema) EndpointOpt

+ func WithEndpointSubject(subject string) EndpointOpt

+ type EndpointSchema struct

+ Name string

+ Schema Schema

+ Subject string

+ type EndpointStats struct

+ AverageProcessingTime time.Duration

+ Data json.RawMessage

+ LastError string

+ Name string

+ NumErrors int

+ NumRequests int

+ ProcessingTime time.Duration

+ Subject string

+ type Group interface

+ AddEndpoint func(string, Handler, ...EndpointOpt) error

+ AddGroup func(string) Group

+ type Handler interface

+ Handle func(Request)

+ type HandlerFunc func(Request)

+ func (fn HandlerFunc) Handle(req Request)

type Info

+ Subjects []string

+ Type string

type Ping

+ Type string

type Request

+ Subject func() string

type SchemaResp

+ APIURL string

+ Endpoints []EndpointSchema

+ Type string

type Service

+ AddEndpoint func(string, Handler, ...EndpointOpt) error

+ AddGroup func(string) Group

type Stats

+ Endpoints []*EndpointStats

+ Type string

Dec 22, 2022

Changes in this version

+ type Headers nats.Header

+ func (h Headers) Get(key string) string

+ func (h Headers) Values(key string) []string

type Request

+ func (r *Request) Data() []byte

+ func (r *Request) Headers() Headers

+ type RespondOpt func(*nats.Msg)

+ func WithHeaders(headers Headers) RespondOpt

Dec 20, 2022

Changes in this version

+ const APIPrefix

+ const ErrorCodeHeader

+ const ErrorHeader

+ const QG

+ var ErrArgRequired = errors.New("argument required")

+ var ErrConfigValidation = errors.New("validation")

+ var ErrMarshalResponse = errors.New("marshaling response")

+ var ErrRespond = errors.New("NATS error when sending response")

+ var ErrServiceNameRequired = errors.New("service name is required to generate ID control subject")

+ var ErrVerbNotSupported = errors.New("unsupported verb")

+ func ControlSubject(verb Verb, name, id string) (string, error)

+ type Config struct

+ Description string

+ DoneHandler DoneHandler

+ Endpoint Endpoint

+ ErrorHandler ErrHandler

+ Name string

+ Schema Schema

+ StatsHandler StatsHandler

+ Version string

+ type DoneHandler func(Service)

+ type Endpoint struct

+ Handler RequestHandler

+ Subject string

+ type ErrHandler func(Service, *NATSError)

+ type Info struct

+ Description string

+ Subject string

+ type NATSError struct

+ Description string

+ Subject string

+ func (e *NATSError) Error() string

+ type Ping ServiceIdentity

+ type Request struct

+ func (r *Request) Error(code, description string, data []byte) error

+ func (r *Request) Respond(response []byte) error

+ func (r *Request) RespondJSON(response interface{}) error

+ type RequestHandler func(*Request) error

+ type Schema struct

+ Request string

+ Response string

+ type SchemaResp struct

+ Schema Schema

+ type Service interface

+ Info func() Info

+ Reset func()

+ Stats func() Stats

+ Stop func() error

+ Stopped func() bool

+ func AddService(nc *nats.Conn, config Config) (Service, error)

+ type ServiceIdentity struct

+ ID string

+ Name string

+ Version string

+ type Stats struct

+ AverageProcessingTime time.Duration

+ Data json.RawMessage

+ LastError string

+ NumErrors int

+ NumRequests int

+ ProcessingTime time.Duration

+ Started string

+ type StatsHandler func(Endpoint) interface

+ type Verb int64

+ const InfoVerb

+ const PingVerb

+ const SchemaVerb

+ const StatsVerb

+ func (s Verb) String() string