client

Documentation

Index

• type GrpcClient
  • func NewGrpcClient(address string) *GrpcClient
  • func (gc *GrpcClient) Close() error
  • func (gc *GrpcClient) GetConn() interface{}
  • func (gc *GrpcClient) GetGameEvents() ([]entity.Event, error)
  • func (gc *GrpcClient) GetReplayChunk(timestamp int64) (entity.Chunk, error)
  • func (gc *GrpcClient) ReceiveLiveStream(proxy *application.ConnectionProxy) error

Types

type GrpcClient

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

func NewGrpcClient

func NewGrpcClient(address string) *GrpcClient

func (*GrpcClient) Close

func (gc *GrpcClient) Close() error

func (*GrpcClient) GetConn

func (gc *GrpcClient) GetConn() interface{}

func (*GrpcClient) GetGameEvents

func (gc *GrpcClient) GetGameEvents() ([]entity.Event, error)

func (*GrpcClient) GetReplayChunk

func (gc *GrpcClient) GetReplayChunk(timestamp int64) (entity.Chunk, error)

func (*GrpcClient) ReceiveLiveStream

func (gc *GrpcClient) ReceiveLiveStream(proxy *application.ConnectionProxy) error