FilesExpand file tree

 update-python-path

/

plugins.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

95 lines (92 loc) · 4.32 KB

 update-python-path

/

plugins.py

Copy path

Top

File metadata and controls

• Code
• Blame

95 lines (92 loc) · 4.32 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

90

91

92

93

94

95

import os

import sys

from localstack.utils.bootstrap import ENV_SCRIPT_STARTING_DOCKER

def register_localstack_plugins():

# register default plugins

try:

from localstack.services.s3 import s3_listener, s3_starter

from localstack.services.kms import kms_starter

from localstack.services.sns import sns_listener

from localstack.services.sqs import sqs_listener, sqs_starter

from localstack.services.iam import iam_listener, iam_starter

from localstack.services.logs import logs_listener, logs_starter

from localstack.services.infra import (register_plugin, Plugin,

start_sns, start_ses, start_apigateway, start_elasticsearch_service, start_events, start_lambda,

start_redshift, start_firehose, start_cloudwatch, start_dynamodbstreams, start_route53,

start_ssm, start_sts, start_secretsmanager, start_ec2)

from localstack.services.kinesis import kinesis_listener, kinesis_starter

from localstack.services.dynamodb import dynamodb_listener, dynamodb_starter

from localstack.services.apigateway import apigateway_listener

from localstack.services.stepfunctions import stepfunctions_starter, stepfunctions_listener

from localstack.services.cloudformation import cloudformation_listener, cloudformation_starter

from localstack.services.events import events_listener

register_plugin(Plugin('apigateway',

start=start_apigateway,

listener=apigateway_listener.UPDATE_APIGATEWAY))

register_plugin(Plugin('cloudformation',

start=cloudformation_starter.start_cloudformation,

listener=cloudformation_listener.UPDATE_CLOUDFORMATION))

register_plugin(Plugin('cloudwatch',

start=start_cloudwatch))

register_plugin(Plugin('dynamodb',

start=dynamodb_starter.start_dynamodb,

check=dynamodb_starter.check_dynamodb,

listener=dynamodb_listener.UPDATE_DYNAMODB))

register_plugin(Plugin('dynamodbstreams',

start=start_dynamodbstreams))

register_plugin(Plugin('ec2',

start=start_ec2))

register_plugin(Plugin('es',

start=start_elasticsearch_service))

register_plugin(Plugin('events',

start=start_events))

register_plugin(Plugin('firehose',

start=start_firehose))

register_plugin(Plugin('iam',

start=iam_starter.start_iam,

listener=iam_listener.UPDATE_IAM))

register_plugin(Plugin('kinesis',

start=kinesis_starter.start_kinesis,

check=kinesis_starter.check_kinesis,

listener=kinesis_listener.UPDATE_KINESIS))

register_plugin(Plugin('kms',

start=kms_starter.start_kms,

priority=10))

register_plugin(Plugin('lambda',

start=start_lambda))

register_plugin(Plugin('logs',

start=logs_starter.start_cloudwatch_logs,

listener=logs_listener.UPDATE_LOGS))

register_plugin(Plugin('redshift',

start=start_redshift))

register_plugin(Plugin('route53',

start=start_route53))

register_plugin(Plugin('s3',

start=s3_starter.start_s3,

check=s3_starter.check_s3,

listener=s3_listener.UPDATE_S3))

register_plugin(Plugin('secretsmanager',

start=start_secretsmanager))

register_plugin(Plugin('ses',

start=start_ses))

register_plugin(Plugin('sns',

start=start_sns,

listener=sns_listener.UPDATE_SNS))

register_plugin(Plugin('sqs',

start=sqs_starter.start_sqs,

listener=sqs_listener.UPDATE_SQS,

check=sqs_starter.check_sqs))

register_plugin(Plugin('ssm',

start=start_ssm))

register_plugin(Plugin('sts',

start=start_sts))

register_plugin(Plugin('events',

start=start_events, listener=events_listener.UPDATE_EVENTS))

register_plugin(Plugin('stepfunctions',

start=stepfunctions_starter.start_stepfunctions,

listener=stepfunctions_listener.UPDATE_STEPFUNCTIONS))

except Exception as e:

if not os.environ.get(ENV_SCRIPT_STARTING_DOCKER):

print('Unable to register plugins: %s' % e)

sys.stdout.flush()

raise e