test

Documentation

Index

• type CloudWatchLogsMock
  • func NewCloudWatchLogsMock() *CloudWatchLogsMock
  • func (m *CloudWatchLogsMock) AddStream(group, stream string)
  • func (m *CloudWatchLogsMock) GetStream(group, stream string) *MockStream
  • func (m *CloudWatchLogsMock) GetStreams(group string) map[string]*MockStream
  • func (m *CloudWatchLogsMock) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type MockStream

Types

type CloudWatchLogsMock

type CloudWatchLogsMock struct {
	*httptest.Server

	Groups  map[string]map[string]*MockStream
	Streams []*cloudwatchlogs.LogStream
}

CloudWatchLogsMock mocks the CloudFront Logs API.

func NewCloudWatchLogsMock

func NewCloudWatchLogsMock() *CloudWatchLogsMock

NewCloudWatchLogsMock instantiates a mock CloudFront Logs server.

func (*CloudWatchLogsMock) AddStream

func (m *CloudWatchLogsMock) AddStream(group, stream string)

AddStream registers a new stream.

func (*CloudWatchLogsMock) GetStream

func (m *CloudWatchLogsMock) GetStream(group, stream string) *MockStream

GetStream returns a stream in a group.

func (*CloudWatchLogsMock) GetStreams

func (m *CloudWatchLogsMock) GetStreams(group string) map[string]*MockStream

GetStreams returns a list of streams in a group.

func (*CloudWatchLogsMock) ServeHTTP

func (m *CloudWatchLogsMock) ServeHTTP(w http.ResponseWriter, r *http.Request)

type MockStream

type MockStream struct {
	LogCount int
	Token    int
}

MockStream stores the state of a fake stream.