cloudwatchlogspublisher_mock

Documentation

Index

• type CloudWatchLogsClientMock
  • func NewClientMockDefault(log log.T) *CloudWatchLogsClientMock
  • func (m *CloudWatchLogsClientMock) CreateLogGroup(input *cloudwatchlogs.CreateLogGroupInput) (*cloudwatchlogs.CreateLogGroupOutput, error)
  • func (m *CloudWatchLogsClientMock) CreateLogStream(input *cloudwatchlogs.CreateLogStreamInput) (*cloudwatchlogs.CreateLogStreamOutput, error)
  • func (m *CloudWatchLogsClientMock) DescribeLogGroups(input *cloudwatchlogs.DescribeLogGroupsInput) (*cloudwatchlogs.DescribeLogGroupsOutput, error)
  • func (m *CloudWatchLogsClientMock) DescribeLogStreams(input *cloudwatchlogs.DescribeLogStreamsInput) (*cloudwatchlogs.DescribeLogStreamsOutput, error)
  • func (m *CloudWatchLogsClientMock) PutLogEvents(input *cloudwatchlogs.PutLogEventsInput) (*cloudwatchlogs.PutLogEventsOutput, error)
• type CloudWatchLogsServiceMock
  • func NewServiceMockDefault(log log.T) *CloudWatchLogsServiceMock
  • func (m *CloudWatchLogsServiceMock) CreateLogGroup(logGroup string) (err error)
  • func (m *CloudWatchLogsServiceMock) CreateLogStream(logGroup, logStream string) (err error)
  • func (m *CloudWatchLogsServiceMock) CreateNewServiceIfUnHealthy()
  • func (m *CloudWatchLogsServiceMock) DescribeLogGroups(logGroupPrefix, nextToken string) (response *cloudwatchlogs.DescribeLogGroupsOutput, err error)
  • func (m *CloudWatchLogsServiceMock) DescribeLogStreams(logGroup, logStreamPrefix, nextToken string) (response *cloudwatchlogs.DescribeLogStreamsOutput, err error)
  • func (m *CloudWatchLogsServiceMock) GetLogGroupDetails(logGroup string) (logGroupDetails *cloudwatchlogs.LogGroup, err error)
  • func (m *CloudWatchLogsServiceMock) GetSequenceTokenForStream(logGroupName, logStreamName string) (sequenceToken *string)
  • func (m *CloudWatchLogsServiceMock) IsLogGroupEncryptedWithKMS(logGroup *cloudwatchlogs.LogGroup) (bool, error)
  • func (m *CloudWatchLogsServiceMock) IsLogGroupPresent(logGroup string) (bool, *cloudwatchlogs.LogGroup)
  • func (m *CloudWatchLogsServiceMock) IsLogStreamPresent(logGroupName, logStreamName string) bool
  • func (m *CloudWatchLogsServiceMock) PutLogEvents(messages []*cloudwatchlogs.InputLogEvent, logGroup, logStream string, ...) (nextSequenceToken *string, err error)
  • func (m *CloudWatchLogsServiceMock) SetCloudWatchMessage(eventVersion string, awsRegion string, targetId string, runAsUser string, ...)
  • func (m *CloudWatchLogsServiceMock) StreamData(logGroupName string, logStreamName string, absoluteFilePath string, ...) (success bool)

Types

type CloudWatchLogsClientMock

type CloudWatchLogsClientMock struct {
	mock.Mock
}

CloudWatchLogsClientMock mocks CloudWatchLogsClient

func NewClientMockDefault

func NewClientMockDefault(log log.T) *CloudWatchLogsClientMock

NewClientMockDefault returns an instance of CloudWatchLogsClientMock with default expectations set.

func (*CloudWatchLogsClientMock) CreateLogGroup

func (m *CloudWatchLogsClientMock) CreateLogGroup(input *cloudwatchlogs.CreateLogGroupInput) (*cloudwatchlogs.CreateLogGroupOutput, error)

CreateLogGroup mocks CloudWatchLogsClient CreateLogGroup method

func (*CloudWatchLogsClientMock) CreateLogStream

func (m *CloudWatchLogsClientMock) CreateLogStream(input *cloudwatchlogs.CreateLogStreamInput) (*cloudwatchlogs.CreateLogStreamOutput, error)

CreateLogStream mocks CloudWatchLogsClient CreateLogStream method

func (*CloudWatchLogsClientMock) DescribeLogGroups

func (m *CloudWatchLogsClientMock) DescribeLogGroups(input *cloudwatchlogs.DescribeLogGroupsInput) (*cloudwatchlogs.DescribeLogGroupsOutput, error)

DescribeLogGroups mocks CloudWatchLogsClient DescribeLogGroups method

func (*CloudWatchLogsClientMock) DescribeLogStreams

func (m *CloudWatchLogsClientMock) DescribeLogStreams(input *cloudwatchlogs.DescribeLogStreamsInput) (*cloudwatchlogs.DescribeLogStreamsOutput, error)

DescribeLogStreams mocks CloudWatchLogsClient DescribeLogStreams method

func (*CloudWatchLogsClientMock) PutLogEvents

func (m *CloudWatchLogsClientMock) PutLogEvents(input *cloudwatchlogs.PutLogEventsInput) (*cloudwatchlogs.PutLogEventsOutput, error)

PutLogEvents mocks CloudWatchLogsClient PutLogEvents method

type CloudWatchLogsServiceMock

type CloudWatchLogsServiceMock struct {
	mock.Mock
	// contains filtered or unexported fields
}

CloudWatchLogsServiceMock mocks CloudWatchLogsService

func NewServiceMockDefault

func NewServiceMockDefault(log log.T) *CloudWatchLogsServiceMock

NewServiceMockDefault returns an instance of CloudWatchLogsServiceMock with default expectations set.

func (*CloudWatchLogsServiceMock) CreateLogGroup

func (m *CloudWatchLogsServiceMock) CreateLogGroup(logGroup string) (err error)

CreateLogGroup mocks CloudWatchLogsService CreateLogGroup method

func (*CloudWatchLogsServiceMock) CreateLogStream

func (m *CloudWatchLogsServiceMock) CreateLogStream(logGroup, logStream string) (err error)

CreateLogStream mocks CloudWatchLogsService CreateLogStream method

func (*CloudWatchLogsServiceMock) CreateNewServiceIfUnHealthy

func (m *CloudWatchLogsServiceMock) CreateNewServiceIfUnHealthy()

CreateNewServiceIfUnHealthy mocks CloudWatchLogsService CreateNewServiceIfUnHealthy method

func (*CloudWatchLogsServiceMock) DescribeLogGroups

func (m *CloudWatchLogsServiceMock) DescribeLogGroups(logGroupPrefix, nextToken string) (response *cloudwatchlogs.DescribeLogGroupsOutput, err error)

DescribeLogGroups mocks CloudWatchLogsService DescribeLogGroups method

func (*CloudWatchLogsServiceMock) DescribeLogStreams

func (m *CloudWatchLogsServiceMock) DescribeLogStreams(logGroup, logStreamPrefix, nextToken string) (response *cloudwatchlogs.DescribeLogStreamsOutput, err error)

DescribeLogStreams mocks CloudWatchLogsService DescribeLogStreams method

func (*CloudWatchLogsServiceMock) GetLogGroupDetails

func (m *CloudWatchLogsServiceMock) GetLogGroupDetails(logGroup string) (logGroupDetails *cloudwatchlogs.LogGroup, err error)

GetLogGroupDetails mocks CloudWatchLogsService getLogGroupDetails method

func (*CloudWatchLogsServiceMock) GetSequenceTokenForStream

func (m *CloudWatchLogsServiceMock) GetSequenceTokenForStream(logGroupName, logStreamName string) (sequenceToken *string)

GetSequenceTokenForStream mocks CloudWatchLogsService GetSequenceTokenForStream method

func (*CloudWatchLogsServiceMock) IsLogGroupEncryptedWithKMS

func (m *CloudWatchLogsServiceMock) IsLogGroupEncryptedWithKMS(logGroup *cloudwatchlogs.LogGroup) (bool, error)

IsLogGroupEncryptedWithKMS mocks CloudWatchLogsService IsLogGroupEncryptedWithKMS method

func (*CloudWatchLogsServiceMock) IsLogGroupPresent

func (m *CloudWatchLogsServiceMock) IsLogGroupPresent(logGroup string) (bool, *cloudwatchlogs.LogGroup)

IsLogGroupPresent mocks CloudWatchLogsService IsLogGroupPresent method

func (*CloudWatchLogsServiceMock) IsLogStreamPresent

func (m *CloudWatchLogsServiceMock) IsLogStreamPresent(logGroupName, logStreamName string) bool

IsLogStreamPresent mocks CloudWatchLogsService IsLogStreamPresent method

func (*CloudWatchLogsServiceMock) PutLogEvents

func (m *CloudWatchLogsServiceMock) PutLogEvents(messages []*cloudwatchlogs.InputLogEvent, logGroup, logStream string, sequenceToken *string) (nextSequenceToken *string, err error)

PutLogEvents mocks CloudWatchLogsService PutLogEvents method

func (*CloudWatchLogsServiceMock) SetCloudWatchMessage

func (m *CloudWatchLogsServiceMock) SetCloudWatchMessage(eventVersion string, awsRegion string, targetId string, runAsUser string, sessionId string, sessionOwner string)

SetCloudWatchMessage mocks CloudWatchLogsService SetCloudWatchMessage method

func (*CloudWatchLogsServiceMock) StreamData

func (m *CloudWatchLogsServiceMock) StreamData(logGroupName string, logStreamName string, absoluteFilePath string, isFileComplete bool, isLogStreamCreated bool, fileCompleteSignal chan bool, processControlSequences bool, structuredLogs bool) (success bool)

StreamData mocks CloudWatchLogsService StreamData method