Documentation
¶
Index ¶
- type Pipe
- type PipesService
- type ServiceLocator
- type Store
- func (s *Store) CreatePipe(name, description, source, target, roleArn, enrichment, desiredState string, ...) (*Pipe, bool)
- func (s *Store) DeletePipe(name string) (*Pipe, bool)
- func (s *Store) DescribePipe(name string) (*Pipe, bool)
- func (s *Store) GetEventsForwarded(name string) int
- func (s *Store) ListPipes(namePrefix, currentState, desiredState, sourcePrefix string) []*Pipe
- func (s *Store) ListTagsForResource(arn string) (map[string]string, bool)
- func (s *Store) SetLocator(locator ServiceLocator)
- func (s *Store) StartPipe(name string) (*Pipe, bool)
- func (s *Store) StopPipe(name string) (*Pipe, bool)
- func (s *Store) TagResource(arn string, tags map[string]string) bool
- func (s *Store) UntagResource(arn string, keys []string) bool
- func (s *Store) UpdatePipe(name, description, target, roleArn, enrichment, desiredState string, ...) (*Pipe, bool)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Pipe ¶
type Pipe struct {
ARN string
Name string
Description string
DesiredState string
CurrentState string
Source string
SourceParameters map[string]any
Target string
TargetParameters map[string]any
RoleArn string
Enrichment string
CreationTime time.Time
LastModifiedTime time.Time
Lifecycle *lifecycle.Machine
Tags map[string]string
// Behavioral fields
EventsForwarded int
// contains filtered or unexported fields
}
Pipe represents an EventBridge Pipe.
type PipesService ¶
type PipesService struct {
// contains filtered or unexported fields
}
PipesService is the cloudmock implementation of the AWS EventBridge Pipes API.
func New ¶
func New(accountID, region string) *PipesService
New returns a new PipesService for the given AWS account ID and region.
func NewWithLocator ¶
func NewWithLocator(accountID, region string, locator ServiceLocator) *PipesService
NewWithLocator returns a new PipesService with a ServiceLocator for cross-service integration.
func (*PipesService) Actions ¶
func (s *PipesService) Actions() []service.Action
Actions returns the list of Pipes API actions supported by this service.
func (*PipesService) HandleRequest ¶
func (s *PipesService) HandleRequest(ctx *service.RequestContext) (*service.Response, error)
HandleRequest routes an incoming Pipes request to the appropriate handler.
func (*PipesService) HealthCheck ¶
func (s *PipesService) HealthCheck() error
HealthCheck always returns nil (no external dependencies).
func (*PipesService) Name ¶
func (s *PipesService) Name() string
Name returns the AWS service name used for routing.
func (*PipesService) SetLocator ¶
func (s *PipesService) SetLocator(locator ServiceLocator)
SetLocator sets the service locator for cross-service calls.
type ServiceLocator ¶
ServiceLocator resolves other services for cross-service integration.
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
Store manages all Pipes state in memory.
func (*Store) CreatePipe ¶
func (s *Store) CreatePipe(name, description, source, target, roleArn, enrichment, desiredState string, sourceParams, targetParams map[string]any, tags map[string]string) (*Pipe, bool)
CreatePipe creates a new pipe.
func (*Store) DeletePipe ¶
DeletePipe removes a pipe.
func (*Store) DescribePipe ¶
DescribePipe returns a pipe by name.
func (*Store) GetEventsForwarded ¶
GetEventsForwarded returns the count of events forwarded by a pipe.
func (*Store) ListTagsForResource ¶
ListTagsForResource returns tags for a pipe by ARN.
func (*Store) SetLocator ¶
func (s *Store) SetLocator(locator ServiceLocator)
SetLocator sets the service locator for cross-service integration.
func (*Store) TagResource ¶
TagResource applies tags to a pipe by ARN.
func (*Store) UntagResource ¶
UntagResource removes tags from a pipe by ARN.
Source Files