pipes

Documentation

Index

• type Pipe
• type PipesService
  • func New(accountID, region string) *PipesService
  • func NewWithLocator(accountID, region string, locator ServiceLocator) *PipesService
  • func (s *PipesService) Actions() []service.Action
  • func (s *PipesService) HandleRequest(ctx *service.RequestContext) (*service.Response, error)
  • func (s *PipesService) HealthCheck() error
  • func (s *PipesService) Name() string
  • func (s *PipesService) SetLocator(locator ServiceLocator)
• type ServiceLocator
• type Store
  • func NewStore(accountID, region string) *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)

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

type ServiceLocator interface {
	Lookup(name string) (service.Service, error)
}

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 NewStore

func NewStore(accountID, region string) *Store

NewStore returns a new Store for the given account and region.

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

func (s *Store) DeletePipe(name string) (*Pipe, bool)

DeletePipe removes a pipe.

func (*Store) DescribePipe

func (s *Store) DescribePipe(name string) (*Pipe, bool)

DescribePipe returns a pipe by name.

func (*Store) GetEventsForwarded

func (s *Store) GetEventsForwarded(name string) int

GetEventsForwarded returns the count of events forwarded by a pipe.

func (*Store) ListPipes

func (s *Store) ListPipes(namePrefix, currentState, desiredState, sourcePrefix string) []*Pipe

ListPipes returns all pipes, optionally filtered by prefix and state.

func (*Store) ListTagsForResource

func (s *Store) ListTagsForResource(arn string) (map[string]string, bool)

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) StartPipe

func (s *Store) StartPipe(name string) (*Pipe, bool)

StartPipe starts a stopped pipe.

func (*Store) StopPipe

func (s *Store) StopPipe(name string) (*Pipe, bool)

StopPipe stops a running pipe.

func (*Store) TagResource

func (s *Store) TagResource(arn string, tags map[string]string) bool

TagResource applies tags to a pipe by ARN.

func (*Store) UntagResource

func (s *Store) UntagResource(arn string, keys []string) bool

UntagResource removes tags from a pipe by ARN.

func (*Store) UpdatePipe

func (s *Store) UpdatePipe(name, description, target, roleArn, enrichment, desiredState string, targetParams map[string]any) (*Pipe, bool)

UpdatePipe updates a pipe.