micro

Documentation

Index

• func Request[T any, V any](ctx *NatsContext, sub string, send *T, receive *V) (*V, error)
• func Respond[T any](req NatsRequest, data *T, err error)
• type BaseController
  • func NewBaseController(basePath string, authProvider network.AuthenticationProvider, ...) BaseController
• type Config
• type Controller
• type Message
  • func NewMessage[T any](data *T, err error) *Message[T]
• type NatsClient
  • func NewNatsClient(config Config) *NatsClient
• type NatsContext
  • func NewNatsContext(client *NatsClient, baseSub string) *NatsContext
• type NatsGroup
• type NatsHandlerFunc
• type NatsRequest
• type Router
  • func NewRouter(mode string, config Config) Router

Functions

func Request

func Request[T any, V any](ctx *NatsContext, sub string, send *T, receive *V) (*V, error)

func Respond

func Respond[T any](req NatsRequest, data *T, err error)

Types

type BaseController

type BaseController interface {
	network.BaseController
	SetNatsContext(ctx *NatsContext)
	NatsContext() *NatsContext
}

func NewBaseController

func NewBaseController(basePath string, authProvider network.AuthenticationProvider, authorizeProvider network.AuthorizationProvider) BaseController

type Config

type Config struct {
	NatsUrl            string
	NatsServiceName    string
	NatsServiceVersion string
}

type Controller

type Controller interface {
	BaseController
	MountNats(group NatsGroup)
}

type Message

type Message[T any] struct {
	Data  *T      `json:"data,omitempty"`
	Error *string `json:"error,omitempty"`
}

func NewMessage

func NewMessage[T any](data *T, err error) *Message[T]

type NatsClient

type NatsClient struct {
	Conn    *nats.Conn
	Service micro.Service
	Timeout time.Duration
}

func NewNatsClient

func NewNatsClient(config Config) *NatsClient

type NatsContext

type NatsContext struct {
	context.Context
	Client  *NatsClient
	Subject string
}

func NewNatsContext

func NewNatsContext(client *NatsClient, baseSub string) *NatsContext

type NatsGroup

type NatsGroup = micro.Group

type NatsHandlerFunc

type NatsHandlerFunc = micro.HandlerFunc

type NatsRequest

type NatsRequest = micro.Request

type Router

type Router interface {
	network.BaseRouter
	NatsClient() *NatsClient
	Disconnect()
	LoadControllers(controllers []Controller)
}

func NewRouter

func NewRouter(mode string, config Config) Router