handler

package
v0.0.0-...-0490640 Latest Latest
Warning

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

 Go to latest Published: May 16, 2019 License: Apache-2.0 Imports: 75 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var SERVICE_NAME = "automate-gateway"

Functions

func NewLegacyIngestServer 

func NewLegacyIngestServer(ingestStatusClient ingest.IngestStatusClient) *legacyIngestServer

func NewNotificationsServer 

func NewNotificationsServer(notificationsClient notifications.NotificationsClient) *notificationsServer

func ToUUID 

func ToUUID(id string) string

Types

type Applications 

type Applications struct {
	// contains filtered or unexported fields
}

Applications - the applications service data structure

func NewApplicationsHandler 

func NewApplicationsHandler(applicationsClient applications.ApplicationsServiceClient) *Applications

NewApplicationsHandler - create a new applications service handler

func (*Applications) GetServiceGroups 

func (a *Applications) GetServiceGroups(
	ctx context.Context,
	in *applications.ServiceGroupsReq) (*applications.ServiceGroups, error)

GetServiceGroups returns a list of service groups

func (*Applications) GetServiceGroupsHealthCounts 

func (a *Applications) GetServiceGroupsHealthCounts(
	ctx context.Context,
	in *applications.ServiceGroupsHealthCountsReq) (*applications.HealthCounts, error)

GetServiceGroupsHealthCounts returns the health counts from all service groups

func (*Applications) GetServices 

func (a *Applications) GetServices(
	ctx context.Context,
	in *applications.ServicesReq) (*applications.ServicesRes, error)

GetServices returns a list of services

func (*Applications) GetServicesBySG 

func (a *Applications) GetServicesBySG(
	ctx context.Context,
	in *applications.ServicesBySGReq) (*applications.ServicesBySGRes, error)

GetServicesBySG returns a list of services within a service-group

func (*Applications) GetVersion 

func (a *Applications) GetVersion(ctx context.Context,
	e *version.VersionInfoRequest) (*version.VersionInfo, error)

GetVersion fetches the version of team service

type AuthzServer 

type AuthzServer struct {
	// contains filtered or unexported fields
}

AuthzServer is the server interface

func NewAuthzServer 

func NewAuthzServer(
	client authz.AuthorizationClient,
	clientV2 authzV2.AuthorizationClient,
	filterHandler middleware.SwitchingFilterHandler,
) *AuthzServer

NewAuthzServer creates a server with its client

func (*AuthzServer) CreatePolicy 

func (a *AuthzServer) CreatePolicy(ctx context.Context,
	gwReq *gwAuthzReq.CreatePolicyReq) (*gwAuthzRes.CreatePolicyResp, error)

CreatePolicy creates a new policy in authz-service.

func (*AuthzServer) DeletePolicy 

func (a *AuthzServer) DeletePolicy(ctx context.Context,
	gwReq *gwAuthzReq.DeletePolicyReq) (*gwAuthzRes.DeletePolicyResp, error)

DeletePolicy removes a policy from authz-service by id.

func (*AuthzServer) GetVersion 

func (a *AuthzServer) GetVersion(ctx context.Context, _ *version.VersionInfoRequest) (*version.VersionInfo, error)

GetVersion returns service version

func (*AuthzServer) Introspect 

func (a *AuthzServer) Introspect(
	ctx context.Context, gwReq *gwAuthzReq.IntrospectReq) (*gwAuthzRes.IntrospectResp, error)

Introspect returns a list of the supported HTTP methods with a Boolean status indicating allowed or denied, for the given, single endpoint. This method must be used for parameterized endpoints but may also be used for non-parameterized endpoints.

func (*AuthzServer) IntrospectAll 

func (a *AuthzServer) IntrospectAll(
	ctx context.Context, gwReq *gwAuthzReq.IntrospectAllReq) (*gwAuthzRes.IntrospectResp, error)

IntrospectAll returns a list of all HTTP endpoints the requestor has access to and, for each endpoint, a map of the supported HTTP methods with a Boolean status indicating allowed or denied.

func (*AuthzServer) IntrospectAllProjects 

func (a *AuthzServer) IntrospectAllProjects(
	ctx context.Context, gwReq *gwAuthzReq.IntrospectAllProjectsReq) (*gwAuthzRes.IntrospectProjectsResp, error)

IntrospectAllProjects returns a list of all projects the requestor has access to.

func (*AuthzServer) IntrospectSome 

func (a *AuthzServer) IntrospectSome(
	ctx context.Context, gwReq *gwAuthzReq.IntrospectSomeReq) (*gwAuthzRes.IntrospectResp, error)

IntrospectSome returns a list of the supported HTTP methods with a Boolean status indicating allowed or denied, for each endpoint in the request list. All supplied endpoints must be non-parameterized.

func (*AuthzServer) ListPolicies 

func (a *AuthzServer) ListPolicies(ctx context.Context,
	gwReq *gwAuthzReq.ListPoliciesReq) (*gwAuthzRes.ListPoliciesResp, error)

ListPolicies returns an array of all policy objects that currently exist in authz-service.

type CfgMgmtServer 

type CfgMgmtServer struct {
	// contains filtered or unexported fields
}

CfgMgmtServer stores client

func NewCfgMgmtServer 

func NewCfgMgmtServer(cfgMgmtClient cmsService.CfgMgmtClient) *CfgMgmtServer

NewCfgMgmtServer initializes CfgMgmtServer with client

func (*CfgMgmtServer) GetAttributes 

func (s *CfgMgmtServer) GetAttributes(ctx context.Context, request *cfgReq.Node) (*cfgRes.NodeAttribute, error)

func (*CfgMgmtServer) GetNodeRun 

func (s *CfgMgmtServer) GetNodeRun(ctx context.Context, request *cfgReq.NodeRun) (*cfgRes.Run, error)

GetNodeRun returns the requested run

func (*CfgMgmtServer) GetNodes 

func (s *CfgMgmtServer) GetNodes(ctx context.Context, request *cfgReq.Nodes) (*gpStruct.ListValue, error)

GetNodes returns an array of Nodes returned from the Cfgmgmt (a.k.a. config-mgmt) Service

func (*CfgMgmtServer) GetNodesCounts 

func (s *CfgMgmtServer) GetNodesCounts(ctx context.Context, request *cfgReq.NodesCounts) (*cfgRes.NodesCounts, error)

GetNodesCounts returns the nodes counts

func (*CfgMgmtServer) GetOrganizations 

func (s *CfgMgmtServer) GetOrganizations(ctx context.Context, e *cfgReq.Organizations) (*gpStruct.ListValue, error)

GetOrganizations returns the names of every organization for the configuration management service

func (*CfgMgmtServer) GetPolicyCookbooks 

func (s *CfgMgmtServer) GetPolicyCookbooks(ctx context.Context, request *cfgReq.PolicyRevision) (*cfgRes.PolicyCookbooks, error)

GetPolicyCookbooks returns PolicyCookbooks with their policy identifiers based on a policy revision ID.

func (*CfgMgmtServer) GetRuns 

func (s *CfgMgmtServer) GetRuns(ctx context.Context, request *cfgReq.Runs) (*gpStruct.ListValue, error)

GetRuns returns an array of Runs returned from the Cfgmgmt (a.k.a. config-mgmt) Service

func (*CfgMgmtServer) GetRunsCounts 

func (s *CfgMgmtServer) GetRunsCounts(ctx context.Context, request *cfgReq.RunsCounts) (*cfgRes.RunsCounts, error)

GetRunsCounts returns the runs counts

func (*CfgMgmtServer) GetSourceFqdns 

func (s *CfgMgmtServer) GetSourceFqdns(ctx context.Context, e *cfgReq.SourceFqdns) (*gpStruct.ListValue, error)

GetSourceFqdns returns the names of every organization for the configuration management service

func (*CfgMgmtServer) GetSuggestions 

func (s *CfgMgmtServer) GetSuggestions(ctx context.Context, request *sharedReq.Suggestion) (*gpStruct.ListValue, error)

Get suggestions returns an array of suggestions from config management

func (*CfgMgmtServer) GetVersion 

func (s *CfgMgmtServer) GetVersion(ctx context.Context, e *version.VersionInfoRequest) (*version.VersionInfo, error)

GetVersion returns the version info for the configuration management service

type ChefIngestJobSchedulerServer 

type ChefIngestJobSchedulerServer struct {
	// contains filtered or unexported fields
}

func NewChefIngestJobSchedulerServer 

func NewChefIngestJobSchedulerServer(jobSchedulerClient ingest.JobSchedulerClient) *ChefIngestJobSchedulerServer

func (*ChefIngestJobSchedulerServer) ConfigureDeleteNodesScheduler 

func (server *ChefIngestJobSchedulerServer) ConfigureDeleteNodesScheduler(ctx context.Context,
	config *req.SchedulerConfig) (*res.ConfigureDeleteNodesScheduler, error)

ConfigureDeleteNodesScheduler changed the configurations for the delete node scheduler

func (*ChefIngestJobSchedulerServer) ConfigureMissingNodesForDeletionScheduler 

func (server *ChefIngestJobSchedulerServer) ConfigureMissingNodesForDeletionScheduler(ctx context.Context,
	config *req.SchedulerConfig) (*res.ConfigureMissingNodesForDeletionScheduler, error)

ConfigureMissingNodesForDeletionScheduler changed the configurations for mark missing nodes for deletion scheduler

func (*ChefIngestJobSchedulerServer) ConfigureNodesMissingScheduler 

func (server *ChefIngestJobSchedulerServer) ConfigureNodesMissingScheduler(ctx context.Context, parameters *req.SchedulerConfig) (*res.ConfigureNodesMissingScheduler, error)

ConfigureNodesMissingScheduler rpc call to configure the NodesMissing Job

func (*ChefIngestJobSchedulerServer) DeleteMarkedNodes 

func (server *ChefIngestJobSchedulerServer) DeleteMarkedNodes(ctx context.Context, empty *req.DeleteMarkedNodes) (*res.DeleteMarkedNodes, error)

DeleteMarkedNodes - run the delete node task now

func (*ChefIngestJobSchedulerServer) GetStatusJobScheduler 

func (server *ChefIngestJobSchedulerServer) GetStatusJobScheduler(ctx context.Context, empty *req.GetStatusJobScheduler) (*res.JobSchedulerStatus, error)

GetStatusJobScheduler - collect and return the status of all the jobs in the Job Scheduler

func (*ChefIngestJobSchedulerServer) MarkMissingNodesForDeletion 

func (server *ChefIngestJobSchedulerServer) MarkMissingNodesForDeletion(ctx context.Context, empty *req.MarkMissingNodesForDeletion) (*res.MarkMissingNodesForDeletion, error)

MarkMissingNodesForDeletion - run the mark missing nodes for deletion task now

func (*ChefIngestJobSchedulerServer) MarkNodesMissing 

func (server *ChefIngestJobSchedulerServer) MarkNodesMissing(ctx context.Context, empty *req.MarkNodesMissing) (*res.MarkNodesMissing, error)

MarkNodesMissing - run the mark nodes missing task now

func (*ChefIngestJobSchedulerServer) StartDeleteNodesScheduler 

func (server *ChefIngestJobSchedulerServer) StartDeleteNodesScheduler(ctx context.Context, empty *req.StartDeleteNodesScheduler) (*res.StartDeleteNodesScheduler, error)

StartDeleteNodesScheduler - start the scheduled task of deleting nodes

func (*ChefIngestJobSchedulerServer) StartJobScheduler 

func (server *ChefIngestJobSchedulerServer) StartJobScheduler(ctx context.Context, empty *req.StartJobScheduler) (*res.StartJobScheduler, error)

StartJobScheduler - Start the Job Scheduler

func (*ChefIngestJobSchedulerServer) StartMissingNodesForDeletionScheduler 

func (server *ChefIngestJobSchedulerServer) StartMissingNodesForDeletionScheduler(ctx context.Context, empty *req.StartMissingNodesForDeletionScheduler) (*res.StartMissingNodesForDeletionScheduler, error)

StartMissingNodesForDeletionScheduler - start the scheduled task mark missing nodes for deletion

func (*ChefIngestJobSchedulerServer) StartNodesMissingScheduler 

func (server *ChefIngestJobSchedulerServer) StartNodesMissingScheduler(ctx context.Context, empty *req.StartNodesMissingScheduler) (*res.StartNodesMissingScheduler, error)

StartNodesMissingScheduler - start the scheduled task of deleting nodes

func (*ChefIngestJobSchedulerServer) StopDeleteNodesScheduler 

func (server *ChefIngestJobSchedulerServer) StopDeleteNodesScheduler(ctx context.Context, empty *req.StopDeleteNodesScheduler) (*res.StopDeleteNodesScheduler, error)

StopDeleteNodesScheduler - stop the scheduled delete node task from running

func (*ChefIngestJobSchedulerServer) StopJobScheduler 

func (server *ChefIngestJobSchedulerServer) StopJobScheduler(ctx context.Context, empty *req.StopJobScheduler) (*res.StopJobScheduler, error)

StopJobScheduler - Stop the Job Scheduler

func (*ChefIngestJobSchedulerServer) StopMissingNodesForDeletionScheduler 

func (server *ChefIngestJobSchedulerServer) StopMissingNodesForDeletionScheduler(ctx context.Context, empty *req.StopMissingNodesForDeletionScheduler) (*res.StopMissingNodesForDeletionScheduler, error)

StopMissingNodesForDeletionScheduler - stop the scheduled mark missing nodes for deletion task from running

func (*ChefIngestJobSchedulerServer) StopNodesMissingScheduler 

func (server *ChefIngestJobSchedulerServer) StopNodesMissingScheduler(ctx context.Context, empty *req.StopNodesMissingScheduler) (*res.StopNodesMissingScheduler, error)

StopNodesMissingScheduler - stop the scheduled delete node task from running

type ChefIngestServer 

type ChefIngestServer struct {
	// contains filtered or unexported fields
}

func NewChefIngestServer 

func NewChefIngestServer(automateUrl *url.URL, ingesterClient ingest.ChefIngesterClient, notifierClient notifier.Notifier) *ChefIngestServer

func (*ChefIngestServer) GetVersion 

func (s *ChefIngestServer) GetVersion(ctx context.Context, empty *version.VersionInfoRequest) (*version.VersionInfo, error)

func (*ChefIngestServer) ProcessChefAction 

func (s *ChefIngestServer) ProcessChefAction(ctx context.Context, request *ingestReq.Action) (*ingestResp.ProcessChefActionResponse, error)

func (*ChefIngestServer) ProcessChefRun 

func (s *ChefIngestServer) ProcessChefRun(ctx context.Context, request *ingestReq.Run) (*ingestResp.ProcessChefRunResponse, error)

func (*ChefIngestServer) ProcessLivenessPing 

func (s *ChefIngestServer) ProcessLivenessPing(ctx context.Context, request *ingestReq.Liveness) (*ingestResp.ProcessLivenessResponse, error)

func (*ChefIngestServer) ProcessMultipleNodeDeletes 

func (s *ChefIngestServer) ProcessMultipleNodeDeletes(ctx context.Context, request *ingestReq.MultipleNodeDeleteRequest) (*ingestResp.ProcessMultipleNodeDeleteResponse, error)

func (*ChefIngestServer) ProcessNodeDelete 

func (s *ChefIngestServer) ProcessNodeDelete(ctx context.Context, request *ingestReq.Delete) (*ingestResp.ProcessNodeDeleteResponse, error)

type DeploymentServer 

type DeploymentServer struct {
	// contains filtered or unexported fields
}

func NewDeploymentServer 

func NewDeploymentServer(dc api.DeploymentClient) *DeploymentServer

func (*DeploymentServer) GetVersion 

func (s *DeploymentServer) GetVersion(ctx context.Context, _ *gp.Empty) (*deployment.Version, error)

func (*DeploymentServer) ServiceVersions 

func (s *DeploymentServer) ServiceVersions(ctx context.Context, _ *deployment.ServiceVersionsRequest) (*deployment.ServiceVersionsResponse, error)

type EventFeedServer 

type EventFeedServer struct {
	// contains filtered or unexported fields
}

EventFeedServer stores client

func NewEventFeedServer 

func NewEventFeedServer(cfgMgmtClient cmsService.CfgMgmtClient, feedClient ccFeed.FeedServiceClient) *EventFeedServer

NewEventFeedServer creates a new server instance

func (*EventFeedServer) GetEventFeed 

func (s *EventFeedServer) GetEventFeed(ctx context.Context,
	request *agReq.EventFilter) (*agRes.Events, error)

GetEventFeed returns a list of all Events

func (*EventFeedServer) GetEventStringBuckets 

func (s *EventFeedServer) GetEventStringBuckets(ctx context.Context,
	request *agReq.EventStrings) (*agRes.EventStrings, error)

GetEventStringBuckets - gets the buckets for the guitar strings

func (*EventFeedServer) GetEventTaskCounts 

func (s *EventFeedServer) GetEventTaskCounts(ctx context.Context,
	request *agReq.EventCountsFilter) (*agRes.EventCounts, error)

GetEventTaskCounts - gets event type counts

func (*EventFeedServer) GetEventTypeCounts 

func (s *EventFeedServer) GetEventTypeCounts(ctx context.Context,
	request *agReq.EventCountsFilter) (*agRes.EventCounts, error)

GetEventTypeCounts - gets event type counts

type Gateway 

type Gateway struct{}

func NewGatewayServer 

func NewGatewayServer() *Gateway

func (*Gateway) GetHealth 

func (m *Gateway) GetHealth(ctx context.Context, empty *gp.Empty) (*pb.Health, error)

GetHealth returns the health of the service

func (*Gateway) GetVersion 

func (m *Gateway) GetVersion(ctx context.Context, empty *gp.Empty) (*pb.Version, error)

GetVersion returns the service version

type LicenseServer 

type LicenseServer struct {
	// contains filtered or unexported fields
}

func NewLicenseServer 

func NewLicenseServer(
	client license_control.LicenseControlClient,
	deployClient deployment_service.DeploymentClient,
	trialLicenseURL *url.URL) *LicenseServer

NewLicenseServer returns the initialized state of the license handlers: a client to license-control-service and the URL of trial-license-service

func (*LicenseServer) ApplyLicense 

func (t *LicenseServer) ApplyLicense(ctx context.Context,
	req *license.ApplyLicenseReq) (*license.ApplyLicenseResp, error)

ApplyLicense applies the provided license token (provided as string JWT) to the system.

func (*LicenseServer) GetStatus 

func (t *LicenseServer) GetStatus(ctx context.Context,
	req *license.GetStatusReq) (*license.GetStatusResp, error)

GetStatus queries l-c-s for the status of the license currently in use

func (*LicenseServer) RequestLicense 

func (t *LicenseServer) RequestLicense(ctx context.Context,
	req *license.RequestLicenseReq) (*license.RequestLicenseResp, error)

type NodeManager 

type NodeManager struct {
	// contains filtered or unexported fields
}

func NewNodeManagerHandler 

func NewNodeManagerHandler(nodeManagerClient nodeManagerService.NodeManagerServiceClient, jobsClient jobsService.JobsServiceClient) *NodeManager

func (*NodeManager) Connect 

func (a *NodeManager) Connect(ctx context.Context, in *manager.Id) (*manager.ConnectResponse, error)

func (*NodeManager) Create 

func (a *NodeManager) Create(ctx context.Context, in *manager.NodeManager) (*manager.Ids, error)

func (*NodeManager) Delete 

func (a *NodeManager) Delete(ctx context.Context, in *manager.Id) (*gp.Empty, error)

func (*NodeManager) DeleteWithNodeStateStopped 

func (a *NodeManager) DeleteWithNodeStateStopped(ctx context.Context, in *manager.Id) (*gp.Empty, error)

func (*NodeManager) DeleteWithNodeStateTerminated 

func (a *NodeManager) DeleteWithNodeStateTerminated(ctx context.Context, in *manager.Id) (*gp.Empty, error)

func (*NodeManager) DeleteWithNodes 

func (a *NodeManager) DeleteWithNodes(ctx context.Context, in *manager.Id) (*manager.Ids, error)

func (*NodeManager) List 

func (a *NodeManager) List(ctx context.Context, in *manager.Query) (*manager.NodeManagers, error)

func (*NodeManager) Read 

func (a *NodeManager) Read(ctx context.Context, in *manager.Id) (*manager.NodeManager, error)

func (*NodeManager) SearchNodeFields 

func (a *NodeManager) SearchNodeFields(ctx context.Context, in *manager.FieldQuery) (*manager.Fields, error)

func (*NodeManager) SearchNodes 

func (a *NodeManager) SearchNodes(ctx context.Context, in *manager.NodeQuery) (*manager.Nodes, error)

func (*NodeManager) Update 

func (a *NodeManager) Update(ctx context.Context, in *manager.NodeManager) (*gp.Empty, error)

type Nodes 

type Nodes struct {
	// contains filtered or unexported fields
}

func NewNodesHandler 

func NewNodesHandler(nodesClient nodesService.NodesServiceClient, jobsClient jobsService.JobsServiceClient) *Nodes

func (*Nodes) BulkCreate 

func (a *Nodes) BulkCreate(ctx context.Context, in *nodes.Nodes) (*nodes.Ids, error)

func (*Nodes) BulkDelete 

func (a *Nodes) BulkDelete(ctx context.Context, in *nodes.Query) (*nodes.BulkDeleteResponse, error)

func (*Nodes) BulkDeleteById 

func (a *Nodes) BulkDeleteById(ctx context.Context, in *nodes.Ids) (*nodes.BulkDeleteResponse, error)

func (*Nodes) Create 

func (a *Nodes) Create(ctx context.Context, in *nodes.Node) (*nodes.Id, error)

func (*Nodes) Delete 

func (a *Nodes) Delete(ctx context.Context, in *nodes.Id) (*gp.Empty, error)

func (*Nodes) List 

func (a *Nodes) List(ctx context.Context, in *nodes.Query) (*nodes.Nodes, error)

func (*Nodes) Read 

func (a *Nodes) Read(ctx context.Context, in *nodes.Id) (*nodes.Node, error)

func (*Nodes) Rerun 

func (a *Nodes) Rerun(ctx context.Context, in *nodes.Id) (*nodes.RerunResponse, error)

func (*Nodes) Update 

func (a *Nodes) Update(ctx context.Context, in *nodes.Node) (*gp.Empty, error)

type Secrets 

type Secrets struct {
	// contains filtered or unexported fields
}

Secrets - the secrets service data structure

func NewSecretsHandler 

func NewSecretsHandler(secretClient secrets.SecretsServiceClient) *Secrets

NewSecretsHandler - create a new secrets service handler

func (*Secrets) Create 

func (a *Secrets) Create(ctx context.Context, in *secrets.Secret) (*secrets.Id, error)

Create - create a new secret

func (*Secrets) Delete 

func (a *Secrets) Delete(ctx context.Context, in *secrets.Id) (*secrets.DeleteResponse, error)

Delete - delete an existing secret

func (*Secrets) List 

func (a *Secrets) List(ctx context.Context, in *secrets.Query) (*secrets.Secrets, error)

List - List the stored secret based off the provided query

func (*Secrets) Read 

func (a *Secrets) Read(ctx context.Context, in *secrets.Id) (*secrets.Secret, error)

Read - read the stored information for one secret.

func (*Secrets) Update 

func (a *Secrets) Update(ctx context.Context, in *secrets.Secret) (*secrets.UpdateResponse, error)

Update - update an existing secret

type TeamsServer 

type TeamsServer struct {
	// contains filtered or unexported fields
}

func NewTeamsServer 

func NewTeamsServer(client teams.TeamsV1Client) *TeamsServer

func (*TeamsServer) AddUsers 

func (a *TeamsServer) AddUsers(ctx context.Context, r *gwreq.AddUsersReq) (*gwres.AddUsersResp, error)

AddUsers puts an array of userIDs to a team upstream

func (*TeamsServer) CreateTeam 

func (a *TeamsServer) CreateTeam(ctx context.Context, r *gwreq.CreateTeamReq) (*gwres.CreateTeamResp, error)

CreateTeam posts a team upstream

func (*TeamsServer) DeleteTeam 

func (a *TeamsServer) DeleteTeam(ctx context.Context, r *gwreq.DeleteTeamReq) (*gwres.DeleteTeamResp, error)

DeleteTeam deletes a team upstream

func (*TeamsServer) GetTeam 

func (a *TeamsServer) GetTeam(ctx context.Context, r *gwreq.GetTeamReq) (*gwres.GetTeamResp, error)

GetTeam fetches a single team by ID

func (*TeamsServer) GetTeams 

func (a *TeamsServer) GetTeams(ctx context.Context, _ *gwreq.GetTeamsReq) (*gwres.Teams, error)

GetTeams fetches an array of existing teams

func (*TeamsServer) GetTeamsForUser 

func (a *TeamsServer) GetTeamsForUser(ctx context.Context,
	r *gwreq.GetTeamsForUserReq) (*gwres.GetTeamsForUserResp, error)

GetTeamsForUser returns all the teams for a specific user

func (*TeamsServer) GetUsers 

func (a *TeamsServer) GetUsers(ctx context.Context, r *gwreq.GetUsersReq) (*gwres.GetUsersResp, error)

GetUsers returns an array of userIDs for a team downstream

func (*TeamsServer) GetVersion 

func (a *TeamsServer) GetVersion(ctx context.Context, e *version.VersionInfoRequest) (*version.VersionInfo, error)

GetVersion fetches the version of team service

func (*TeamsServer) RemoveUsers 

func (a *TeamsServer) RemoveUsers(ctx context.Context, r *gwreq.RemoveUsersReq) (*gwres.RemoveUsersResp, error)

RemoveUsers deletes an array of userIDs from a team upstream

func (*TeamsServer) UpdateTeam 

func (a *TeamsServer) UpdateTeam(ctx context.Context, r *gwreq.UpdateTeamReq) (*gwres.UpdateTeamResp, error)

UpdateTeam updates a team upstream

type TelemetryServer 

type TelemetryServer struct {
	// contains filtered or unexported fields
}

func NewTelemetryServer 

func NewTelemetryServer(client license_control.LicenseControlClient, dclient deployment_service.DeploymentClient) *TelemetryServer

func (*TelemetryServer) GetTelemetryConfiguration 

func (t *TelemetryServer) GetTelemetryConfiguration(ctx context.Context, request *telemetry.TelemetryRequest) (*telemetry.TelemetryResponse, error)

GetTelemetryConfiguration returns the license and telemetry information

type TokensServer 

type TokensServer struct {
	// contains filtered or unexported fields
}

TokensServer stores token

func NewTokensMgmtServer 

func NewTokensMgmtServer(tokensMgmtClient authn.TokensMgmtClient) *TokensServer

NewTokensMgmtServer initializes Server with client

func (*TokensServer) CreateToken 

func (a *TokensServer) CreateToken(ctx context.Context, r *authReq.CreateToken) (*authRes.Token, error)

func (*TokensServer) DeleteToken 

func (a *TokensServer) DeleteToken(ctx context.Context, r *authReq.Uuid) (*authRes.DeleteTokenResp, error)

func (*TokensServer) GetToken 

func (a *TokensServer) GetToken(ctx context.Context, r *authReq.Uuid) (*authRes.Token, error)

func (*TokensServer) GetTokens 

func (a *TokensServer) GetTokens(ctx context.Context, _ *authReq.GetTokensReq) (*authRes.Tokens, error)

func (*TokensServer) UpdateToken 

func (a *TokensServer) UpdateToken(ctx context.Context, r *authReq.UpdateToken) (*authRes.Token, error)

type UsersServer 

type UsersServer struct {
	// contains filtered or unexported fields
}

UsersServer stores client to an upstream auth service

func NewUsersMgmtServer 

func NewUsersMgmtServer(client local_user.UsersMgmtClient) *UsersServer

NewUsersMgmtServer initializes Server with client

func (*UsersServer) CreateUser 

func (a *UsersServer) CreateUser(ctx context.Context, r *localUserReq.CreateUser) (*localUserRes.User, error)

CreateUser posts a user upstream

func (*UsersServer) DeleteUser 

func (a *UsersServer) DeleteUser(ctx context.Context, r *localUserReq.Email) (*localUserRes.DeleteUserResp, error)

DeleteUser deletes an existing user from upstream Deprecated: 20180424200344 -----------------------------------------------

func (*UsersServer) DeleteUserByUsername 

func (a *UsersServer) DeleteUserByUsername(ctx context.Context,
	r *localUserReq.Username) (*localUserRes.DeleteUserResp, error)

DeleteUserByUsername deletes an existing user upstream

func (*UsersServer) GetUser 

func (a *UsersServer) GetUser(ctx context.Context, r *localUserReq.Email) (*localUserRes.User, error)

GetUser fetches an existing user from upstream Deprecated: 20180424200344

func (*UsersServer) GetUserByUsername 

func (a *UsersServer) GetUserByUsername(ctx context.Context,
	r *localUserReq.Username) (*localUserRes.User, error)

GetUserByUsername fetches an existing user from upstream

func (*UsersServer) GetUsers 

func (a *UsersServer) GetUsers(ctx context.Context, _ *localUserReq.GetUsersReq) (*localUserRes.Users, error)

GetUsers fetches a map of existing users and extracts each user into an array

func (*UsersServer) UpdateSelf 

func (a *UsersServer) UpdateSelf(ctx context.Context, r *localUserReq.UpdateSelf) (*localUserRes.User, error)

UpdateSelf allows a user to update their own info, requiring the previous password if they want to change password.

func (*UsersServer) UpdateUser 

func (a *UsersServer) UpdateUser(ctx context.Context, r *localUserReq.UpdateUser) (*localUserRes.User, error)

UpdateUser updates an existing user.

Source Files

View all Source files

Directories

Path Synopsis
iam
v2beta/policy
v2beta/teams
v2beta/tokens
v2beta/users

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.