micro

package

v1.1.9 Latest Latest Go to latest Published: Jul 1, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

func ParseMsg[T any](data []byte) (*T, error)

type AnyMessage = Message[any]

func NewAnyMessage(data any, err error) *AnyMessage

type BaseController interface {
	MessageSender
	network.BaseController
}

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

type Config struct {
	NatsUrl            string
	NatsServiceName    string
	NatsServiceVersion string
	Timeout            time.Duration
}

type Controller interface {
	BaseController
	MountNats(group NatsGroup)
}

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

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

type MessageSender interface {
	SendNats(req NatsRequest) SendMessage
}

func NewMessageSender() MessageSender

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

type NatsClient interface {
	GetInstance() *natsClient
	Disconnect()
}

func NewNatsClient(config *Config) NatsClient

type NatsGroup = micro.Group

type NatsHandlerFunc = micro.HandlerFunc

type NatsRequest = micro.Request

type Request[T any] interface {
	Nats() (*T, error)
}

type RequestBuilder[T any] interface {
	NatsClient() NatsClient
	Request(data any) Request[T]
}

func NewRequestBuilder[T any](natsClient NatsClient, subject string) RequestBuilder[T]

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

func NewRouter(mode string, natsClient NatsClient) Router

type SendMessage interface {
	Message(data any)
	Error(err error)
}