serviceconfig

Documentation

Index

• Variables
• type RolloutIdChangeDetector
  • func NewRolloutIdChangeDetector(client *http.Client, serviceControlUrl, serviceName string, ...) *RolloutIdChangeDetector
  • func (c *RolloutIdChangeDetector) SetDetectRolloutIdChangeTimer(interval time.Duration, callback func())
• type ServiceConfigFetcher
  • func NewServiceConfigFetcher(client *http.Client, serviceManagementUrl, serviceName string, ...) *ServiceConfigFetcher
  • func (s *ServiceConfigFetcher) FetchConfig(configId string) (*confpb.Service, error)
  • func (s *ServiceConfigFetcher) LoadConfigIdFromRollouts() (string, error)

Variables

var SmRetryConfigs = map[int]util.RetryConfig{
	http.StatusTooManyRequests: util.RetryConfig{
		RetryNum:      30,
		RetryInterval: time.Second * 10,
	},
}

Types

type RolloutIdChangeDetector

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

func NewRolloutIdChangeDetector

func NewRolloutIdChangeDetector(client *http.Client, serviceControlUrl, serviceName string,
	accessToken util.GetAccessTokenFunc) *RolloutIdChangeDetector

func (*RolloutIdChangeDetector) SetDetectRolloutIdChangeTimer

func (c *RolloutIdChangeDetector) SetDetectRolloutIdChangeTimer(interval time.Duration, callback func())

type ServiceConfigFetcher

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

func NewServiceConfigFetcher

func NewServiceConfigFetcher(client *http.Client, serviceManagementUrl,
	serviceName string, accessToken util.GetAccessTokenFunc) *ServiceConfigFetcher

func (*ServiceConfigFetcher) FetchConfig

func (s *ServiceConfigFetcher) FetchConfig(configId string) (*confpb.Service, error)

Fetch the service config by given configId.

func (*ServiceConfigFetcher) LoadConfigIdFromRollouts

func (s *ServiceConfigFetcher) LoadConfigIdFromRollouts() (string, error)

Fetch all the rollouts and use the latest success rollout. Among its all service configs, pick up the one with highest traffic percentage.