// SetPipe set the various encoders, tees and the writer.
335877
func (wo *WriteOperations) SetPipe(p *pipe.Pipe, id string) error {
	for _, s := range wo.Steps {
		switch s.(type) {
		case encoders.Encoder:
			p.Push(s.(encoders.Encoder).Encode)
		case *WriteOperations:
			tp := p.Tee()
			teeWo := s.(*WriteOperations)
			if err := teeWo.SetPipe(tp, id); err != nil {
				return err
			}
		}
	}
	w, err := wo.Output.NewWriter(id)
	if err != nil {
		return err
	}
	p.ToCloser(w)
	return nil
}
631063
func (p *Pipeline) SetSource(s Source) {
	p.mutex.Lock()
	defer p.mutex.Unlock()

	p.src = s
}
568391
func (s *DescribePipelineInput) SetPipelineName(v string) *DescribePipelineInput {
	s.PipelineName = &v
	return s
}
1062051
func (s *ChannelSummary) SetPipelinesRunningCount(v int64) *ChannelSummary {
	s.PipelinesRunningCount = &v
	return s
}
537937
func (s *EnableStageTransitionInput) SetPipelineName(v string) *EnableStageTransitionInput {
	s.PipelineName = &v
	return s
}
1284813
func (s *ListPipelinesOutput) SetPipelines(v []*Pipeline) *ListPipelinesOutput {
	s.Pipelines = v
	return s
}
417158
func (s *CreatePipelineInput) SetPipelineActivities(v []*PipelineActivity) *CreatePipelineInput {
	s.PipelineActivities = v
	return s
}
906953
func (s *SetStatusInput) SetPipelineId(v string) *SetStatusInput {
	s.PipelineId = &v
	return s
}
1327034
func (s *DeleteChannelOutput) SetPipelinesRunningCount(v int64) *DeleteChannelOutput {
	s.PipelinesRunningCount = &v
	return s
}
641385
func (s *RetryStageExecutionInput) SetPipelineName(v string) *RetryStageExecutionInput {
	s.PipelineName = &v
	return s
}
713987
func (s *CreatePipelineInput) SetPipelineName(v string) *CreatePipelineInput {
	s.PipelineName = &v
	return s
}
679732
func (s *PipelineDescription) SetPipelineId(v string) *PipelineDescription {
	s.PipelineId = &v
	return s
}
901422
func (s *SegmentDemographics) SetChannel(v *SetDimension) *SegmentDemographics {
	s.Channel = v
	return s
}
780998
func (s *GetPipelineDefinitionInput) SetPipelineId(v string) *GetPipelineDefinitionInput {
	s.PipelineId = &v
	return s
}
1180768
func (s *Resolver) SetPipelineConfig(v *PipelineConfig) *Resolver {
	s.PipelineConfig = v
	return s
}
1040462
func (h *Header) SetText(k, v string) {
	h.Set(k, encodeHeader(v))
}
206035
func (s *GetPipelineOutput) SetPipeline(v *PipelineDeclaration) *GetPipelineOutput {
	s.Pipeline = v
	return s
}