service

Documentation

Index

• type ControlPlaneService
  • func NewControlPlaneService(repo apis.Repo, servicebound apis.Servicebound, edgebound apis.Edgebound) *ControlPlaneService
  • func (cps *ControlPlaneService) GetEdge(ctx context.Context, req *v1.GetEdgeRequest) (*v1.Edge, error)
  • func (cps *ControlPlaneService) GetService(ctx context.Context, req *v1.GetServiceRequest) (*v1.Service, error)
  • func (cps *ControlPlaneService) KickEdge(ctx context.Context, req *v1.KickEdgeRequest) (*v1.KickEdgeResponse, error)
  • func (cps *ControlPlaneService) KickService(ctx context.Context, req *v1.KickServiceRequest) (*v1.KickServiceResponse, error)
  • func (cps *ControlPlaneService) ListEdgeRPCs(ctx context.Context, req *v1.ListEdgeRPCsRequest) (*v1.ListEdgeRPCsResponse, error)
  • func (cps *ControlPlaneService) ListEdges(ctx context.Context, req *v1.ListEdgesRequest) (*v1.ListEdgesResponse, error)
  • func (cps *ControlPlaneService) ListServiceRPCs(ctx context.Context, req *v1.ListServiceRPCsRequest) (*v1.ListServiceRPCsResponse, error)
  • func (cps *ControlPlaneService) ListServiceTopics(ctx context.Context, req *v1.ListServiceTopicsRequest) (*v1.ListServiceTopicsResponse, error)
  • func (cps *ControlPlaneService) ListServices(ctx context.Context, req *v1.ListServicesRequest) (*v1.ListServicesResponse, error)

Types

type ControlPlaneService

type ControlPlaneService struct {
	v1.UnimplementedControlPlaneServer
	// contains filtered or unexported fields
}

func NewControlPlaneService

func NewControlPlaneService(repo apis.Repo, servicebound apis.Servicebound, edgebound apis.Edgebound) *ControlPlaneService

func (*ControlPlaneService) GetEdge

func (cps *ControlPlaneService) GetEdge(ctx context.Context, req *v1.GetEdgeRequest) (*v1.Edge, error)

@Summary Get Edge @Tags 1.0 @Param params query v1.GetEdgeRequest true "queries" @Success 200 {object} v1.Edge "result" @Router /v1/edges/{edge_id} [get]

func (*ControlPlaneService) GetService

func (cps *ControlPlaneService) GetService(ctx context.Context, req *v1.GetServiceRequest) (*v1.Service, error)

@Summary Get Service @Tags 1.0 @Param params query v1.GetServiceRequest true "queries" @Success 200 {object} v1.Service "result" @Router /v1/services/{service_id} [get]

func (*ControlPlaneService) KickEdge

func (cps *ControlPlaneService) KickEdge(ctx context.Context, req *v1.KickEdgeRequest) (*v1.KickEdgeResponse, error)

@Summary Kick Edge @Tags 1.0 @Param params query v1.KickEdgeRequest true "queries" @Success 200 {object} v1.KickEdgeResponse "result" @Router /v1/edges/{edge_id} [delete]

func (*ControlPlaneService) KickService

func (cps *ControlPlaneService) KickService(ctx context.Context, req *v1.KickServiceRequest) (*v1.KickServiceResponse, error)

@Summary Kick Service @Tags 1.0 @Param params query v1.KickServiceRequest true "queries" @Success 200 {object} v1.KickServiceResponse "result" @Router /v1/services/{service_id} [delete]

func (*ControlPlaneService) ListEdgeRPCs

func (cps *ControlPlaneService) ListEdgeRPCs(ctx context.Context, req *v1.ListEdgeRPCsRequest) (*v1.ListEdgeRPCsResponse, error)

@Summary List Edges RPCs @Tags 1.0 @Param params query v1.ListEdgeRPCsRequest true "queries" @Success 200 {object} v1.ListEdgeRPCsResponse "result" @Router /v1/edges/rpcs [get]

func (*ControlPlaneService) ListEdges

func (cps *ControlPlaneService) ListEdges(ctx context.Context, req *v1.ListEdgesRequest) (*v1.ListEdgesResponse, error)

@Summary ListEdges @Tags 1.0 @Param params query v1.ListEdgesRequest true "queries" @Success 200 {object} v1.ListEdgesResponse "result" @Router /v1/edges [get]

func (*ControlPlaneService) ListServiceRPCs

func (cps *ControlPlaneService) ListServiceRPCs(ctx context.Context, req *v1.ListServiceRPCsRequest) (*v1.ListServiceRPCsResponse, error)

@Summary List Services RPCs @Tags 1.0 @Param params query v1.ListServiceRPCsRequest true "queries" @Success 200 {object} v1.ListServiceRPCsResponse "result" @Router /v1/services/rpcs [get]

func (*ControlPlaneService) ListServiceTopics

func (cps *ControlPlaneService) ListServiceTopics(ctx context.Context, req *v1.ListServiceTopicsRequest) (*v1.ListServiceTopicsResponse, error)

@Summary List Services Topics @Tags 1.0 @Param params query v1.ListServiceTopicsRequest true "queries" @Success 200 {object} v1.ListServiceTopicsResponse "result" @Router /v1/services/topics [get]

func (*ControlPlaneService) ListServices

func (cps *ControlPlaneService) ListServices(ctx context.Context, req *v1.ListServicesRequest) (*v1.ListServicesResponse, error)

@Summary List Services @Tags 1.0 @Param params query v1.ListServicesRequest true "queries" @Success 200 {object} v1.ListServicesResponse "result" @Router /v1/services [get]