resolver

Documentation

Overview

Package resolver provides a unified interface to query backend services.

Index

• Constants
• type Client
  • func NewClient(config ClientConfig) (*Client, error)
  • func (c *Client) CheckResults(ctx context.Context, user *schema.User, checkId string) (results []*schema.CheckResult, err error)
  • func (c *Client) DeleteChecks(ctx context.Context, user *schema.User, checksInput []interface{}) ([]string, error)
  • func (c *Client) GetCheckStateTransition(ctx context.Context, user *schema.User, checkId string, transitionId int) (*schema.CheckStateTransition, error)
  • func (c *Client) GetCheckStateTransitions(ctx context.Context, user *schema.User, checkId string, ...) ([]*schema.CheckStateTransition, error)
  • func (c *Client) GetCredentials(ctx context.Context, customerId string) (*opsee.GetCredentialsResponse, error)
  • func (c *Client) GetGroups(ctx context.Context, user *schema.User, region, vpc, groupType, groupId string) (interface{}, error)
  • func (c *Client) GetInstances(ctx context.Context, user *schema.User, ...) (interface{}, error)
  • func (c *Client) GetMetricStatistics(ctx context.Context, user *schema.User, region string, ...) (*schema.CloudWatchResponse, error)
  • func (c *Client) GetNotifications(ctx context.Context, user *schema.User, defaultOnly bool) ([]*schema.Notification, error)
  • func (c *Client) GetRoleStack(ctx context.Context, user *schema.User) (*schema.RoleStack, error)
  • func (c *Client) GetTaskDefinition(ctx context.Context, user *schema.User, region, id string) (*opsee_aws_ecs.TaskDefinition, error)
  • func (c *Client) GetTeam(ctx context.Context, user *schema.User) (*schema.Team, error)
  • func (c *Client) GetUser(ctx context.Context, req *opsee.GetUserRequest) (*opsee.GetUserResponse, error)
  • func (c *Client) HasRole(ctx context.Context, user *schema.User) (bool, error)
  • func (c *Client) InviteUser(ctx context.Context, req *opsee.InviteUserRequest) (*schema.User, error)
  • func (c *Client) LaunchBastionStack(ctx context.Context, user *schema.User, ...) (bool, error)
  • func (c *Client) LaunchRoleUrl(ctx context.Context, user *schema.User) (string, error)
  • func (c *Client) LaunchRoleUrlTemplate(ctx context.Context, user *schema.User) (string, error)
  • func (c *Client) ListChecks(ctx context.Context, user *schema.User, checkId string, transitionId int) ([]*schema.Check, error)
  • func (c *Client) ListCustomers(ctx context.Context, req *opsee.ListUsersRequest) (*opsee.ListCustomersResponse, error)
  • func (c *Client) PutDefaultNotifications(ctx context.Context, user *schema.User, notificationsInput []interface{}) ([]*schema.Notification, error)
  • func (c *Client) PutTeam(ctx context.Context, user *schema.User, teamInput map[string]interface{}) (*schema.Team, error)
  • func (c *Client) PutUser(ctx context.Context, req *opsee.UpdateUserRequest) (*schema.User, error)
  • func (c *Client) QueryCheckMetrics(ctx context.Context, user *schema.User, checkId, metricName string, ...) ([]*schema.Metric, error)
  • func (c *Client) RebootInstances(ctx context.Context, user *schema.User, region string, instanceIds []string) error
  • func (c *Client) ScanRegion(ctx context.Context, user *schema.User, region string) (*schema.Region, error)
  • func (c *Client) StartInstances(ctx context.Context, user *schema.User, region string, instanceIds []string) error
  • func (c *Client) StopInstances(ctx context.Context, user *schema.User, region string, instanceIds []string) error
  • func (c *Client) TestCheck(ctx context.Context, user *schema.User, checkInput map[string]interface{}) (*opsee.TestCheckResponse, error)
  • func (c *Client) UpsertChecks(ctx context.Context, user *schema.User, checksInput []interface{}) ([]*schema.Check, error)
• type ClientConfig

Constants

const (
	RoutePath           = "/opsee.co/routes"
	MagicExecutionGroup = "127a7354-290e-11e6-b178-2bc1f6aefc14"
)

Types

type Client

type Client struct {
	Bartnet    bartnet.Client
	Beavis     beavis.Client
	Spanx      opsee.SpanxClient
	Cats       opsee.CatsClient
	Keelhaul   opsee.KeelhaulClient
	Hugs       hugs.Client
	Bezos      opsee.BezosClient
	Marktricks opsee.MarktricksClient
	Dynamo     *dynamodb.DynamoDB
	EtcdKeys   etcd.KeysAPI
}

func NewClient

func NewClient(config ClientConfig) (*Client, error)

func (*Client) CheckResults

func (c *Client) CheckResults(ctx context.Context, user *schema.User, checkId string) (results []*schema.CheckResult, err error)

func (*Client) DeleteChecks

func (c *Client) DeleteChecks(ctx context.Context, user *schema.User, checksInput []interface{}) ([]string, error)

func (*Client) GetCheckStateTransition

func (c *Client) GetCheckStateTransition(ctx context.Context, user *schema.User, checkId string, transitionId int) (*schema.CheckStateTransition, error)

Get a single check state transition from cats

func (*Client) GetCheckStateTransitions

func (c *Client) GetCheckStateTransitions(ctx context.Context, user *schema.User, checkId string, startTime, endTime *opsee_types.Timestamp) ([]*schema.CheckStateTransition, error)

Get check state transitions from cats

func (*Client) GetCredentials

func (c *Client) GetCredentials(ctx context.Context, customerId string) (*opsee.GetCredentialsResponse, error)

func (*Client) GetGroups

func (c *Client) GetGroups(ctx context.Context, user *schema.User, region, vpc, groupType, groupId string) (interface{}, error)

func (*Client) GetInstances

func (c *Client) GetInstances(ctx context.Context, user *schema.User, region, vpc, instanceType, instanceId string) (interface{}, error)

func (*Client) GetMetricStatistics

func (c *Client) GetMetricStatistics(ctx context.Context, user *schema.User, region string, input *opsee_aws_cloudwatch.GetMetricStatisticsInput) (*schema.CloudWatchResponse, error)

func (*Client) GetNotifications

func (c *Client) GetNotifications(ctx context.Context, user *schema.User, defaultOnly bool) ([]*schema.Notification, error)

func (*Client) GetRoleStack

func (c *Client) GetRoleStack(ctx context.Context, user *schema.User) (*schema.RoleStack, error)

func (*Client) GetTaskDefinition

func (c *Client) GetTaskDefinition(ctx context.Context, user *schema.User, region, id string) (*opsee_aws_ecs.TaskDefinition, error)

Fetches a single task definition for ECS services

func (*Client) GetTeam

func (c *Client) GetTeam(ctx context.Context, user *schema.User) (*schema.Team, error)

func (*Client) GetUser

func (c *Client) GetUser(ctx context.Context, req *opsee.GetUserRequest) (*opsee.GetUserResponse, error)

func (*Client) HasRole

func (c *Client) HasRole(ctx context.Context, user *schema.User) (bool, error)

func (*Client) InviteUser

func (c *Client) InviteUser(ctx context.Context, req *opsee.InviteUserRequest) (*schema.User, error)

func (*Client) LaunchBastionStack

func (c *Client) LaunchBastionStack(ctx context.Context, user *schema.User, region, vpcId, subnetId, subnetRouting, instanceSize string) (bool, error)

func (*Client) LaunchRoleUrl

func (c *Client) LaunchRoleUrl(ctx context.Context, user *schema.User) (string, error)

func (*Client) LaunchRoleUrlTemplate

func (c *Client) LaunchRoleUrlTemplate(ctx context.Context, user *schema.User) (string, error)

func (*Client) ListChecks

func (c *Client) ListChecks(ctx context.Context, user *schema.User, checkId string, transitionId int) ([]*schema.Check, error)

ListChecks fetches Checks from Bartnet and CheckResults from Beavis concurrently, then zips them together. If the request to Beavis fails, then checks are returned without results.

func (*Client) ListCustomers

func (c *Client) ListCustomers(ctx context.Context, req *opsee.ListUsersRequest) (*opsee.ListCustomersResponse, error)

func (*Client) PutDefaultNotifications

func (c *Client) PutDefaultNotifications(ctx context.Context, user *schema.User, notificationsInput []interface{}) ([]*schema.Notification, error)

func (*Client) PutTeam

func (c *Client) PutTeam(ctx context.Context, user *schema.User, teamInput map[string]interface{}) (*schema.Team, error)

func (*Client) PutUser

func (c *Client) PutUser(ctx context.Context, req *opsee.UpdateUserRequest) (*schema.User, error)

func (*Client) QueryCheckMetrics

func (c *Client) QueryCheckMetrics(ctx context.Context, user *schema.User, checkId, metricName string, ts0, ts1 *opsee_types.Timestamp, aggregator *opsee.Aggregator) ([]*schema.Metric, error)

func (*Client) RebootInstances

func (c *Client) RebootInstances(ctx context.Context, user *schema.User, region string, instanceIds []string) error

func (*Client) ScanRegion

func (c *Client) ScanRegion(ctx context.Context, user *schema.User, region string) (*schema.Region, error)

func (*Client) StartInstances

func (c *Client) StartInstances(ctx context.Context, user *schema.User, region string, instanceIds []string) error

func (*Client) StopInstances

func (c *Client) StopInstances(ctx context.Context, user *schema.User, region string, instanceIds []string) error

func (*Client) TestCheck

func (c *Client) TestCheck(ctx context.Context, user *schema.User, checkInput map[string]interface{}) (*opsee.TestCheckResponse, error)

func (*Client) UpsertChecks

func (c *Client) UpsertChecks(ctx context.Context, user *schema.User, checksInput []interface{}) ([]*schema.Check, error)

type ClientConfig

type ClientConfig struct {
	SkipVerify bool
	Bartnet    string
	Beavis     string
	Spanx      string
	Cats       string
	Keelhaul   string
	Bezos      string
	Hugs       string
	Marktricks string
	Etcd       string
}