schedules

package

v0.1.2 Latest Latest Go to latest Published: Sep 13, 2023 License: BSD-3-Clause Imports: 21 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 {
	SchedulesService *Service
}

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

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

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

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

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

type DeployDto struct {
	Id primitive.ObjectID `json:"id,required"`
}

type KeysDto struct {
	Id string `path:"id,required"`
}

type M = map[string]interface{}

type PingDto struct {
	Ids []string `json:"ids,required"`
}

type RevokeDto struct {
	Id  string `json:"id,required"`
	Key string `json:"key,required"`
}

type Service struct {
	*common.Inject
	Clusters *clusters.Service
}

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

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

func (x *Service) Get(id string, key string) (r typ.ScheduleOption, err error)

func (x *Service) Keys(id string) (keys []string, err error)

func (x *Service) Ping(id string) (r bool, err error)

func (x *Service) Revoke(id string, key string) (err error)

func (x *Service) Set(id string, key string, option typ.ScheduleOption) (err error)

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

type UnDeployDto struct {
	Id primitive.ObjectID `json:"id,required"`
}