endpoints

package

v0.2.5 Latest Latest Go to latest Published: Nov 8, 2023 License: BSD-3-Clause Imports: 10 Imported by: 0

Details

This section is empty.

View Source

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

This section is empty.

type Controller struct {
	EndpointsX *Service
}

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

func (x *Controller) SchedulePing(_ context.Context, c *app.RequestContext)

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

func (x *Controller) ScheduleState(_ context.Context, c *app.RequestContext)

type M = map[string]interface{}

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

type SchedulePingDto struct {
	Nodes []string `json:"nodes" vd:"gt=0"`
}

type ScheduleRevokeDto struct {
	Id  primitive.ObjectID `json:"id" vd:"required"`
	Key string             `json:"key" vd:"required"`
}

type ScheduleStatesDto struct {
	Node string `json:"node" vd:"required"`
	Key  string `json:"key" vd:"required"`
}

type Service struct {
	*common.Inject
}

func (x *Service) Schedule(node string) (client *schedule.Client, err error)

func (x *Service) ScheduleKeys(ctx context.Context, id primitive.ObjectID) (keys []string, err error)

func (x *Service) SchedulePing(node string) (r bool, err error)

func (x *Service) ScheduleRevoke(ctx context.Context, id primitive.ObjectID, key string) (err error)

func (x *Service) ScheduleSet(ctx context.Context, id primitive.ObjectID, key string, option sctyp.ScheduleOption) (err error)

func (x *Service) ScheduleState(node string, key string) (r sctyp.ScheduleOption, err error)