// OnStarted builds a composed decider that fires on swf.EventTypeWorkflowExecutionStarted.
438855
func OnStarted(deciders ...Decider) Decider {
	return func(ctx *FSMContext, h *swf.HistoryEvent, data interface{}) Outcome {
		switch *h.EventType {
		case swf.EventTypeWorkflowExecutionStarted:
			logf(ctx, "at=on-started")
			return NewComposedDecider(deciders...)(ctx, h, data)
		}
		return ctx.Pass()
	}
}
591499
func (s *RunTaskInput) SetStartedBy(v string) *RunTaskInput {
	s.StartedBy = &v
	return s
}
72281
func (c *ReportingClient) JobStarted(ctx context.Context, args JobStartedArgs) error {
	return c.postJSON("jobstarted", args)
}
198751
func (bcR *BlockchainReactor) OnStart() error {
	if bcR.fastSync {
		err := bcR.pool.Start()
		if err != nil {
			return err
		}
		go bcR.poolRoutine()
	}
	return nil
}
1034493
func (s *Server) OnStart() error {
	go s.loop(state{
		subscriptions: make(map[string]map[string]*Subscription),
		queries:       make(map[string]*queryPlusRefCount),
	})
	return nil
}
1292163
func (s *Server) OnStartupComplete() {
	if !caddy.Quiet {
		firstSite := s.sites[0]
		scheme := "HTTP"
		if firstSite.TLS.Enabled {
			scheme = "HTTPS"
		}

		fmt.Println("")
		fmt.Printf("Serving %s on port "+firstSite.Port()+" \n", scheme)
		s.outputSiteInfo(false)
		fmt.Println("")
	}

	// Print out process log without header comment
	s.outputSiteInfo(true)
}
1109429
func (s *ServerHTTPS) OnStartupComplete() {
	if Quiet {
		return
	}

	out := startUpZones(transport.HTTPS+"://", s.Addr, s.zones)
	if out != "" {
		fmt.Print(out)
	}
	return
}
34661
func (s *LambdaFunctionCompletedEventAttributes) SetStartedEventId(v int64) *LambdaFunctionCompletedEventAttributes {
	s.StartedEventId = &v
	return s
}
734557
func OnTimerFired(timerId string, deciders ...Decider) Decider {
	return func(ctx *FSMContext, h *swf.HistoryEvent, data interface{}) Outcome {
		switch *h.EventType {
		case swf.EventTypeTimerFired:
			if *h.TimerFiredEventAttributes.TimerId == timerId {
				logf(ctx, "at=on-timer-fired")
				return NewComposedDecider(deciders...)(ctx, h, data)
			}
		}
		return ctx.Pass()
	}
}
51139
func OnActivityCompleted(activityName string, deciders ...Decider) Decider {
	return OnActivityEvents(activityName, []string{
		swf.EventTypeActivityTaskCompleted,
	}, deciders...)
}
192830
func (p *peer) OnStart() error {
	if err := p.BaseService.OnStart(); err != nil {
		return err
	}

	if err := p.mconn.Start(); err != nil {
		return err
	}

	go p.metricsReporter()
	return nil
}
9532
func (s *StartSelector) SetStartSelectorType(v string) *StartSelector {
	s.StartSelectorType = &v
	return s
}
231309
func (s *ServergRPC) OnStartupComplete() {
	if Quiet {
		return
	}

	for zone, config := range s.zones {
		fmt.Println(TransportGRPC + "://" + zone + ":" + config.Port)
	}
}
1268001
func (s *Job) SetStarted(v time.Time) *Job {
	s.Started = &v
	return s
}
535501
func (c *ReportingClient) RunStepStarted(ctx context.Context, args RunStepStartedArgs) error {
	return c.postJSON("runstepstarted", args)
}
1024590
func (s *ChildWorkflowExecutionCanceledEventAttributes) SetStartedEventId(v int64) *ChildWorkflowExecutionCanceledEventAttributes {
	s.StartedEventId = &v
	return s
}
1338758
func (s *HybridSlowStart) OnPacketAcked(ackedPacketNumber protocol.PacketNumber) {
	if s.IsEndOfRound(ackedPacketNumber) {
		s.started = false
	}
}