api

Documentation

Index

• Variables
• func Apply(w http.ResponseWriter, r *http.Request)
• func Cluster(w http.ResponseWriter, r *http.Request)
• func Create(w http.ResponseWriter, r *http.Request)
• func Delete(w http.ResponseWriter, r *http.Request)
• func Events(w http.ResponseWriter, r *http.Request)
• func Health(w http.ResponseWriter, r *http.Request)
• func ListSites(w http.ResponseWriter, r *http.Request)
• func Query(w http.ResponseWriter, r *http.Request)
• func Token(w http.ResponseWriter, r *http.Request)
• func Version(w http.ResponseWriter, r *http.Request)
• type API
  • func (a *API) ApplyCluster(context.Context, *apiv1.ApplyClusterRequest) (*apiv1.ApplyClusterResponse, error)
  • func (a *API) CreateSite(context.Context, *apiv1.CreateSiteRequest) (*apiv1.CreateSiteResponse, error)
  • func (*API) CreateToken(ctx context.Context, tr *apiv1.CreateTokenRequest) (*apiv1.CreateTokenResponse, error)
  • func (a *API) DeleteSite(context.Context, *apiv1.DeleteSiteRequest) (*apiv1.DeleteSiteResponse, error)
  • func (a *API) GetCluster(context.Context, *apiv1.GetClusterRequest) (*apiv1.GetClusterResponse, error)
  • func (a *API) GetSite(context.Context, *apiv1.GetSiteRequest) (*apiv1.GetSiteResponse, error)
  • func (a *API) ListSites(context.Context, *apiv1.ListSitesRequest) (*apiv1.ListSitesResponse, error)
  • func (a *API) Query(ctx context.Context, req *apiv1.QueryRequest) (*apiv1.QueryResponse, error)
  • func (a *API) SendEvent(ctx context.Context, req *apiv1.Event) (*emptypb.Empty, error)
  • func (a *API) Version(context.Context, *emptypb.Empty) (*v1.Build, error)

Variables

var AcceptedEvents = prometheus.NewCounter(prometheus.CounterOpts{
	Namespace: "vince",
	Name:      "events_accepted_total",
	Help:      "Total number of analytics events accepted",
})

var RejectedEvents = prometheus.NewCounter(prometheus.CounterOpts{
	Namespace: "vince",
	Name:      "events_rejected_total",
	Help:      "Total number of analytics events rejected",
})

Functions

func Apply

func Apply(w http.ResponseWriter, r *http.Request)

func Cluster

func Cluster(w http.ResponseWriter, r *http.Request)

func Create

func Create(w http.ResponseWriter, r *http.Request)

func Delete

func Delete(w http.ResponseWriter, r *http.Request)

func Events

func Events(w http.ResponseWriter, r *http.Request)

Events accepts events payloads from vince client script.

func Health

func Health(w http.ResponseWriter, r *http.Request)

func ListSites

func ListSites(w http.ResponseWriter, r *http.Request)

func Query

func Query(w http.ResponseWriter, r *http.Request)

func Token

func Token(w http.ResponseWriter, r *http.Request)

func Version

func Version(w http.ResponseWriter, r *http.Request)

Types

type API

type API struct {
	v1.UnsafeVinceServer
}

func (*API) ApplyCluster

func (a *API) ApplyCluster(context.Context, *apiv1.ApplyClusterRequest) (*apiv1.ApplyClusterResponse, error)

func (*API) CreateSite

func (a *API) CreateSite(context.Context, *apiv1.CreateSiteRequest) (*apiv1.CreateSiteResponse, error)

func (*API) CreateToken

func (*API) CreateToken(ctx context.Context, tr *apiv1.CreateTokenRequest) (*apiv1.CreateTokenResponse, error)

func (*API) DeleteSite

func (a *API) DeleteSite(context.Context, *apiv1.DeleteSiteRequest) (*apiv1.DeleteSiteResponse, error)

func (*API) GetCluster

func (a *API) GetCluster(context.Context, *apiv1.GetClusterRequest) (*apiv1.GetClusterResponse, error)

func (*API) GetSite

func (a *API) GetSite(context.Context, *apiv1.GetSiteRequest) (*apiv1.GetSiteResponse, error)

func (*API) ListSites

func (a *API) ListSites(context.Context, *apiv1.ListSitesRequest) (*apiv1.ListSitesResponse, error)

func (*API) Query

func (a *API) Query(ctx context.Context, req *apiv1.QueryRequest) (*apiv1.QueryResponse, error)

Query executes read only query. Assumes req has been validated.

func (*API) SendEvent

func (a *API) SendEvent(ctx context.Context, req *apiv1.Event) (*emptypb.Empty, error)

SendEvent accepts analytics event. Assumes req has already been validated

func (*API) Version

func (a *API) Version(context.Context, *emptypb.Empty) (*v1.Build, error)