streamer

Documentation

Index

• type Payload
• type Streamer
  • func New(missionServiceClient mission.MissionServiceClient, ...) *Streamer
  • func (s Streamer) GetBullseyes(ctx context.Context) ([]*objects.Object, error)
  • func (s *Streamer) GetCurrentTime(ctx context.Context) (string, error)
  • func (s *Streamer) GetGlobalObject(ctx context.Context) (*objects.Object, error)
  • func (s *Streamer) GetMissionName(ctx context.Context) (string, error)
  • func (s *Streamer) GetStartTime(ctx context.Context) (string, error)
  • func (s *Streamer) Stream(ctx context.Context, updates chan<- Payload, ...)

Types

type Payload

type Payload struct {
	Update      *objects.Update
	MissionTime time.Duration
}

type Streamer

type Streamer struct {
	// contains filtered or unexported fields
}

func New

func New(
	missionServiceClient mission.MissionServiceClient,
	coalitionServiceClient coalition.CoalitionServiceClient,
	hookServiceClient hook.HookServiceClient,
) *Streamer

func (Streamer) GetBullseyes

func (s Streamer) GetBullseyes(ctx context.Context) ([]*objects.Object, error)

func (*Streamer) GetCurrentTime

func (s *Streamer) GetCurrentTime(ctx context.Context) (string, error)

func (*Streamer) GetGlobalObject

func (s *Streamer) GetGlobalObject(ctx context.Context) (*objects.Object, error)

func (*Streamer) GetMissionName

func (s *Streamer) GetMissionName(ctx context.Context) (string, error)

func (*Streamer) GetStartTime

func (s *Streamer) GetStartTime(ctx context.Context) (string, error)

func (*Streamer) Stream

func (s *Streamer) Stream(ctx context.Context, updates chan<- Payload, airUpdateInterval, surfaceUpdateInterval, weaponUpdateInterval time.Duration)