simulator

Documentation

Index

• Constants
• Variables
• func NewExternalRecordDownloader(region string) *externalRecordDownloader
• func RegisterRecorder(next http.Handler, authService GatewayAuthService, region, bareDomain string) http.Handler
• func ShutdownRecorder()
• type GatewayAuthService
• type LazyOutput
  • func NewLazyOutput(name string) *LazyOutput
  • func (l *LazyOutput) Close() error
  • func (l *LazyOutput) Write(d []byte) (int, error)
• type PlayBackMockConf
  • func (m *PlayBackMockConf) Authorize(req *auth.AuthorizationRequest) (*auth.AuthorizationResponse, error)
  • func (m *PlayBackMockConf) GetCredentials(accessKey string) (*model.Credential, error)
  • func (m *PlayBackMockConf) GetUserByID(userID int) (*model.User, error)
• type ResponseWriter
  • func (w *ResponseWriter) Header() http.Header
  • func (w *ResponseWriter) SaveHeaders(fName string)
  • func (w *ResponseWriter) Write(data []byte) (int, error)
  • func (w *ResponseWriter) WriteHeader(statusCode int)
• type StoredEvent

Constants

const (
	RequestExtension        = ".request"
	ResponseExtension       = ".response"
	ResponseHeaderExtension = ".response_headers"
	RequestBodyExtension    = ".request_body"
	SimulationConfig        = "simulation_config.json"
	RecordingRoot           = "gateway/testdata/recordings"
)

const EtagExtension = "etag"

Variables

var PlaybackParams struct {
	IsPlayback                bool
	CurrentUploadID           []byte // used at playback to set the upload id in
	RecordingDir, PlaybackDir string
}

Functions

func NewExternalRecordDownloader

func NewExternalRecordDownloader(region string) *externalRecordDownloader

func RegisterRecorder

func RegisterRecorder(next http.Handler, authService GatewayAuthService, region, bareDomain string) http.Handler

func ShutdownRecorder

func ShutdownRecorder()

Types

type GatewayAuthService

type GatewayAuthService interface {
	GetCredentials(accessKey string) (*model.Credential, error)
	GetUserByID(userID int) (*model.User, error)
	Authorize(req *auth.AuthorizationRequest) (*auth.AuthorizationResponse, error)
}

a limited service interface for the gateway, used by simulation playback

type LazyOutput

type LazyOutput struct {
	Name   string
	F      *os.File
	IsOpen bool
}

func NewLazyOutput

func NewLazyOutput(name string) *LazyOutput

func (*LazyOutput) Close

func (l *LazyOutput) Close() error

func (*LazyOutput) Write

func (l *LazyOutput) Write(d []byte) (int, error)

type PlayBackMockConf

type PlayBackMockConf struct {
	BareDomain      string `json:"bare_domain"`
	AccessKeyID     string `json:"access_key_id"`
	AccessSecretKey string `json:"access_secret_Key"`
	UserID          int    `json:"user_id"`
	Region          string `json:"region"`
}

func (*PlayBackMockConf) Authorize

func (m *PlayBackMockConf) Authorize(req *auth.AuthorizationRequest) (*auth.AuthorizationResponse, error)

func (*PlayBackMockConf) GetCredentials

func (m *PlayBackMockConf) GetCredentials(accessKey string) (*model.Credential, error)

func (*PlayBackMockConf) GetUserByID

func (m *PlayBackMockConf) GetUserByID(userID int) (*model.User, error)

type ResponseWriter

type ResponseWriter struct {
	OriginalWriter http.ResponseWriter
	ResponseLog    *LazyOutput
	StatusCode     int
	Headers        http.Header
	UploadIDRegexp *regexp.Regexp
	// contains filtered or unexported fields
}

func (*ResponseWriter) Header

func (w *ResponseWriter) Header() http.Header

func (*ResponseWriter) SaveHeaders

func (w *ResponseWriter) SaveHeaders(fName string)

func (*ResponseWriter) Write

func (w *ResponseWriter) Write(data []byte) (int, error)

func (*ResponseWriter) WriteHeader

func (w *ResponseWriter) WriteHeader(statusCode int)

type StoredEvent

type StoredEvent struct {
	Status   int    `json:"status"`
	UploadID string `json:"uploadId"`
	Request  string `json:"request"`
}