11import { CapiCredentials , RegionType } from './../interface' ;
2- import { TriggerInputs , ChafkaTriggerInputsParams , CreateTriggerReq } from './interface' ;
2+ import { TriggerInputs , CkafkaTriggerInputsParams , CreateTriggerReq } from './interface' ;
33import Scf from '../scf' ;
44import { TRIGGER_STATUS_MAP } from './base' ;
55
@@ -24,14 +24,14 @@ export default class CkafkaTrigger {
2424 inputs,
2525 } : {
2626 region : RegionType ;
27- inputs : TriggerInputs < ChafkaTriggerInputsParams > ;
27+ inputs : TriggerInputs < CkafkaTriggerInputsParams > ;
2828 } ) {
2929 const { parameters } = inputs ;
3030 const triggerInputs : CreateTriggerReq = {
3131 Action : 'CreateTrigger' ,
3232 FunctionName : inputs . functionName ,
3333 Namespace : inputs . namespace ,
34- Type : 'chafka ' ,
34+ Type : 'ckafka ' ,
3535 Qualifier : parameters ?. qualifier ?? '$DEFAULT' ,
3636 TriggerName : `${ parameters ?. name } -${ parameters ?. topic } ` ,
3737 TriggerDesc : JSON . stringify ( {
@@ -56,7 +56,7 @@ export default class CkafkaTrigger {
5656 } : {
5757 scf : Scf ;
5858 region : RegionType ;
59- inputs : TriggerInputs < ChafkaTriggerInputsParams > ;
59+ inputs : TriggerInputs < CkafkaTriggerInputsParams > ;
6060 } ) {
6161 const { triggerInputs } = this . formatInputs ( { region, inputs } ) ;
6262 console . log ( `Creating ${ triggerInputs . Type } trigger ${ triggerInputs . TriggerName } ` ) ;
0 commit comments