micro

Documentation

Index

• func Request[T any, V any](ctx *Context, subject 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 Context
  • func EmptyContext() *Context
  • func NewContext(natsClient *NatsClient, baseSub string) *Context
• type Controller
• type Message
  • func NewMessage[T any](data *T, err error) *Message[T]
• type Module
• type NatsClient
  • func NewNatsClient(config *Config) *NatsClient
• 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 *Context, subject 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
	Context() *Context
}

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 Context

type Context struct {
	context.Context
	NatsClient  *NatsClient
	NatsSubject string
}

func EmptyContext

func EmptyContext() *Context

func NewContext

func NewContext(natsClient *NatsClient, baseSub string) *Context

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 Module

type Module[T any] interface {
	network.BaseModule[T]
	Controllers() []Controller
}

type NatsClient

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

func NewNatsClient

func NewNatsClient(config *Config) *NatsClient

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