imessages

package
v0.1.18 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 16, 2023 License: BSD-3-Clause Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Provides = wire.NewSet(
	wire.Struct(new(Controller), "*"),
	wire.Struct(new(Service), "*"),
)

Functions

This section is empty.

Types

type Controller

type Controller struct {
	ImessagesServices *Service
}

func (*Controller) CreateMetrics

func (x *Controller) CreateMetrics(ctx context.Context, c *app.RequestContext)

func (*Controller) DeleteMetrics

func (x *Controller) DeleteMetrics(ctx context.Context, c *app.RequestContext)

func (*Controller) GetMetrics

func (x *Controller) GetMetrics(ctx context.Context, c *app.RequestContext)

func (*Controller) GetNodes

func (x *Controller) GetNodes(ctx context.Context, c *app.RequestContext)

func (*Controller) Publish

func (x *Controller) Publish(ctx context.Context, c *app.RequestContext)

type CreateMetricsDto

type CreateMetricsDto struct {
	Id string `path:"id" vd:"mongodb"`
}

type DeleteMetricsDto

type DeleteMetricsDto struct {
	Id string `path:"id" vd:"mongodb"`
}

type GetMetricsDto

type GetMetricsDto struct {
	Id string `path:"id" vd:"mongodb"`
}

type M

type M = map[string]interface{}

type PublishDto

type PublishDto struct {
	Topic   string `json:"topic" vd:"required"`
	Payload M      `json:"payload" vd:"required"`
}

type Service

type Service struct {
	*common.Inject
}

func (*Service) CreateMetrics

func (x *Service) CreateMetrics(ctx context.Context, id primitive.ObjectID) (rs []interface{}, err error)

func (*Service) DeleteMetrics

func (x *Service) DeleteMetrics(ctx context.Context, id primitive.ObjectID) (rs []interface{}, err error)

func (*Service) Event

func (x *Service) Event() (err error)

func (*Service) GetMetrics

func (x *Service) GetMetrics(ctx context.Context, id primitive.ObjectID) (rs []interface{}, err error)

func (*Service) GetNodes

func (x *Service) GetNodes(ctx context.Context) (r interface{}, err error)

func (*Service) Publish

func (x *Service) Publish(ctx context.Context, dto PublishDto) (r interface{}, err error)

func (*Service) R

func (x *Service) R(ctx context.Context) *req.Request

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL