service

Documentation

Index

• Constants
• func New(name, image, broker string, role Role, params map[string]string) triggermesh.Component
• type Role
• type Service
  • func (s *Service) AsDigitalOceanObject(additionalEnvs map[string]string) (interface{}, error)
  • func (s *Service) AsDockerComposeObject(additionalEnvs map[string]string) (interface{}, error)
  • func (s *Service) AsK8sObject() (kubernetes.Object, error)
  • func (s *Service) AsKubernetesDeployment(additionalEnvs map[string]string) (interface{}, error)
  • func (s *Service) ConsumedEventTypes() ([]string, error)
  • func (s *Service) GetAPIVersion() string
  • func (s *Service) GetEventSource() (string, error)
  • func (s *Service) GetEventTypes() ([]string, error)
  • func (s *Service) GetKind() string
  • func (s *Service) GetName() string
  • func (s *Service) GetPort(ctx context.Context) (string, error)
  • func (s *Service) GetSpec() map[string]interface{}
  • func (s *Service) Info(ctx context.Context) (*docker.Container, error)
  • func (s *Service) IsSource() bool
  • func (s *Service) IsTarget() bool
  • func (s *Service) Logs(ctx context.Context, since time.Time, follow bool) (io.ReadCloser, error)
  • func (s *Service) SetEventAttributes(attributes map[string]string) error
  • func (s *Service) SetSpec(spec map[string]interface{})
  • func (s *Service) Start(ctx context.Context, additionalEnvs map[string]string, restart bool) (*docker.Container, error)
  • func (s *Service) Stop(ctx context.Context) error

Constants

const (
	APIVersion = "serving.knative.dev/v1"
	Kind       = "Service"

	RoleLabel = "triggermesh.io/role"
)

Functions

func New

func New(name, image, broker string, role Role, params map[string]string) triggermesh.Component

Types

type Role

type Role string

var (
	Producer Role = "source"
	Consumer Role = "target"
)

type Service

type Service struct {
	Name   string
	Broker string
	Image  string
	// contains filtered or unexported fields
}

func (*Service) AsDigitalOceanObject

func (s *Service) AsDigitalOceanObject(additionalEnvs map[string]string) (interface{}, error)

func (*Service) AsDockerComposeObject

func (s *Service) AsDockerComposeObject(additionalEnvs map[string]string) (interface{}, error)

func (*Service) AsK8sObject

func (s *Service) AsK8sObject() (kubernetes.Object, error)

func (*Service) AsKubernetesDeployment

func (s *Service) AsKubernetesDeployment(additionalEnvs map[string]string) (interface{}, error)

func (*Service) ConsumedEventTypes

func (s *Service) ConsumedEventTypes() ([]string, error)

func (*Service) GetAPIVersion

func (s *Service) GetAPIVersion() string

func (*Service) GetEventSource

func (s *Service) GetEventSource() (string, error)

func (*Service) GetEventTypes

func (s *Service) GetEventTypes() ([]string, error)

func (*Service) GetKind

func (s *Service) GetKind() string

func (*Service) GetName

func (s *Service) GetName() string

func (*Service) GetPort

func (s *Service) GetPort(ctx context.Context) (string, error)

func (*Service) GetSpec

func (s *Service) GetSpec() map[string]interface{}

func (*Service) Info

func (s *Service) Info(ctx context.Context) (*docker.Container, error)

func (*Service) IsSource

func (s *Service) IsSource() bool

func (*Service) IsTarget

func (s *Service) IsTarget() bool

func (*Service) Logs

func (s *Service) Logs(ctx context.Context, since time.Time, follow bool) (io.ReadCloser, error)

func (*Service) SetEventAttributes

func (s *Service) SetEventAttributes(attributes map[string]string) error

func (*Service) SetSpec

func (s *Service) SetSpec(spec map[string]interface{})

func (*Service) Start

func (s *Service) Start(ctx context.Context, additionalEnvs map[string]string, restart bool) (*docker.Container, error)

func (*Service) Stop

func (s *Service) Stop(ctx context.Context) error