event

Documentation

Index

• type ProcessChooseTeam
  • func (p ProcessChooseTeam) Process(ctx context.Context, msg *kafka.Message, uow uow.UowInterface) error
• type ProcessEventStrategy
• type ProcessMatchUpdateResult
  • func (p ProcessMatchUpdateResult) Process(ctx context.Context, msg *kafka.Message, uow uow.UowInterface) error
• type ProcessNewAction
  • func (p ProcessNewAction) Process(ctx context.Context, msg *kafka.Message, uow uow.UowInterface) error
• type ProcessNewMatch
  • func (p ProcessNewMatch) Process(ctx context.Context, msg *kafka.Message, uow uow.UowInterface) error
• type ProcessNewPlayer
  • func (p ProcessNewPlayer) Process(ctx context.Context, msg *kafka.Message, uow uow.UowInterface) error

Types

type ProcessChooseTeam

type ProcessChooseTeam struct{}

func (ProcessChooseTeam) Process

func (p ProcessChooseTeam) Process(ctx context.Context, msg *kafka.Message, uow uow.UowInterface) error

type ProcessEventStrategy

type ProcessEventStrategy interface {
	Process(ctx context.Context, msg *kafka.Message, uow uow.UowInterface) error
}

type ProcessMatchUpdateResult

type ProcessMatchUpdateResult struct{}

func (ProcessMatchUpdateResult) Process

func (p ProcessMatchUpdateResult) Process(ctx context.Context, msg *kafka.Message, uow uow.UowInterface) error

type ProcessNewAction

type ProcessNewAction struct{}

func (ProcessNewAction) Process

func (p ProcessNewAction) Process(ctx context.Context, msg *kafka.Message, uow uow.UowInterface) error

type ProcessNewMatch

type ProcessNewMatch struct{}

func (ProcessNewMatch) Process

func (p ProcessNewMatch) Process(ctx context.Context, msg *kafka.Message, uow uow.UowInterface) error

type ProcessNewPlayer

type ProcessNewPlayer struct{}

func (ProcessNewPlayer) Process

func (p ProcessNewPlayer) Process(ctx context.Context, msg *kafka.Message, uow uow.UowInterface) error