xfeed_proto

package
v0.0.0-...-fb4dc09 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 4, 2018 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package xfeed_proto contains all proto files while sdk in alpha in future all proto files will be moved to separate repository nolint:golint

Index

Constants

This section is empty.

Variables

View Source 
var DiffType_name = map[int32]string{
	0: "unknown",
	1: "INSERT",
	2: "DELETE",
	3: "UPDATE",
}
View Source 
var DiffType_value = map[string]int32{
	"unknown": 0,
	"INSERT":  1,
	"DELETE":  2,
	"UPDATE":  3,
}
View Source 
var EventTimer_TimerState_name = map[int32]string{
	0: "unknown",
	1: "FORWARD",
	2: "BACKWARD",
	3: "PAUSE",
}
View Source 
var EventTimer_TimerState_value = map[string]int32{
	"unknown":  0,
	"FORWARD":  1,
	"BACKWARD": 2,
	"PAUSE":    3,
}
View Source 
var FeedEvent_EventStatus_name = map[int32]string{
	0: "unknown",
	1: "PREMATCH",
	2: "LIVE",
}
View Source 
var FeedEvent_EventStatus_value = map[string]int32{
	"unknown":  0,
	"PREMATCH": 1,
	"LIVE":     2,
}
View Source 
var FeedMarketParam_MarketParamType_name = map[int32]string{
	0: "unknown",
	1: "PERIOD",
	2: "TOTAL",
	3: "HANDICAP",
	4: "TEAM",
}
View Source 
var FeedMarketParam_MarketParamType_value = map[string]int32{
	"unknown":  0,
	"PERIOD":   1,
	"TOTAL":    2,
	"HANDICAP": 3,
	"TEAM":     4,
}
View Source 
var OutcomeSettlement_SettlementType_name = map[int32]string{
	0: "unknown",
	1: "UNSETTLED",
	2: "WIN",
	3: "LOSE",
	4: "RETURN",
}
View Source 
var OutcomeSettlement_SettlementType_value = map[string]int32{
	"unknown":   0,
	"UNSETTLED": 1,
	"WIN":       2,
	"LOSE":      3,
	"RETURN":    4,
}
View Source 
var PointsGroup_PointType_name = map[int32]string{
	0: "unknown",
	1: "SCORE",
	2: "RED_CARDS",
	3: "YELLOW_CARDS",
	4: "PENALTIES",
	5: "CORNERS",
}
View Source 
var PointsGroup_PointType_value = map[string]int32{
	"unknown":      0,
	"SCORE":        1,
	"RED_CARDS":    2,
	"YELLOW_CARDS": 3,
	"PENALTIES":    4,
	"CORNERS":      5,
}

Functions

func RegisterFeedServer 

func RegisterFeedServer(s *grpc.Server, srv FeedServer)

Types

type DiffType 

type DiffType int32
const (
	DiffType_unknown DiffType = 0
	DiffType_INSERT  DiffType = 1
	DiffType_DELETE  DiffType = 2
	DiffType_UPDATE  DiffType = 3
)

func (DiffType) EnumDescriptor 

func (DiffType) EnumDescriptor() ([]byte, []int)

func (DiffType) String 

func (x DiffType) String() string

type DiffsMessage 

type DiffsMessage struct {
	EventDiffs           []*EventDiff   `protobuf:"bytes,1,rep,name=event_diffs,json=eventDiffs,proto3" json:"event_diffs,omitempty"`
	MarketDiffs          []*MarketsDiff `protobuf:"bytes,2,rep,name=market_diffs,json=marketDiffs,proto3" json:"market_diffs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*DiffsMessage) Descriptor 

func (*DiffsMessage) Descriptor() ([]byte, []int)

func (*DiffsMessage) GetEventDiffs 

func (m *DiffsMessage) GetEventDiffs() []*EventDiff

func (*DiffsMessage) GetMarketDiffs 

func (m *DiffsMessage) GetMarketDiffs() []*MarketsDiff

func (*DiffsMessage) ProtoMessage 

func (*DiffsMessage) ProtoMessage()

func (*DiffsMessage) Reset 

func (m *DiffsMessage) Reset()

func (*DiffsMessage) String 

func (m *DiffsMessage) String() string

func (*DiffsMessage) XXX_DiscardUnknown 

func (m *DiffsMessage) XXX_DiscardUnknown()

func (*DiffsMessage) XXX_Marshal 

func (m *DiffsMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiffsMessage) XXX_Merge 

func (dst *DiffsMessage) XXX_Merge(src proto.Message)

func (*DiffsMessage) XXX_Size 

func (m *DiffsMessage) XXX_Size() int

func (*DiffsMessage) XXX_Unmarshal 

func (m *DiffsMessage) XXX_Unmarshal(b []byte) error

type EventDiff 

type EventDiff struct {
	DiffType             DiffType   `protobuf:"varint,1,opt,name=diff_type,json=diffType,proto3,enum=xfeed_proto.DiffType" json:"diff_type,omitempty"`
	Event                *FeedEvent `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*EventDiff) Descriptor 

func (*EventDiff) Descriptor() ([]byte, []int)

func (*EventDiff) GetDiffType 

func (m *EventDiff) GetDiffType() DiffType

func (*EventDiff) GetEvent 

func (m *EventDiff) GetEvent() *FeedEvent

func (*EventDiff) ProtoMessage 

func (*EventDiff) ProtoMessage()

func (*EventDiff) Reset 

func (m *EventDiff) Reset()

func (*EventDiff) String 

func (m *EventDiff) String() string

func (*EventDiff) XXX_DiscardUnknown 

func (m *EventDiff) XXX_DiscardUnknown()

func (*EventDiff) XXX_Marshal 

func (m *EventDiff) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventDiff) XXX_Merge 

func (dst *EventDiff) XXX_Merge(src proto.Message)

func (*EventDiff) XXX_Size 

func (m *EventDiff) XXX_Size() int

func (*EventDiff) XXX_Unmarshal 

func (m *EventDiff) XXX_Unmarshal(b []byte) error

type EventPoints 

type EventPoints struct {
	PointGroups          []*PointsGroup `protobuf:"bytes,1,rep,name=point_groups,json=pointGroups,proto3" json:"point_groups,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*EventPoints) Descriptor 

func (*EventPoints) Descriptor() ([]byte, []int)

func (*EventPoints) GetPointGroups 

func (m *EventPoints) GetPointGroups() []*PointsGroup

func (*EventPoints) ProtoMessage 

func (*EventPoints) ProtoMessage()

func (*EventPoints) Reset 

func (m *EventPoints) Reset()

func (*EventPoints) String 

func (m *EventPoints) String() string

func (*EventPoints) XXX_DiscardUnknown 

func (m *EventPoints) XXX_DiscardUnknown()

func (*EventPoints) XXX_Marshal 

func (m *EventPoints) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventPoints) XXX_Merge 

func (dst *EventPoints) XXX_Merge(src proto.Message)

func (*EventPoints) XXX_Size 

func (m *EventPoints) XXX_Size() int

func (*EventPoints) XXX_Unmarshal 

func (m *EventPoints) XXX_Unmarshal(b []byte) error

type EventSettlement 

type EventSettlement struct {
	EventId              string                        `protobuf:"bytes,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	Resulting            *EventPoints                  `protobuf:"bytes,2,opt,name=resulting,proto3" json:"resulting,omitempty"`
	Outcomes             map[string]*OutcomeSettlement `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*EventSettlement) Descriptor 

func (*EventSettlement) Descriptor() ([]byte, []int)

func (*EventSettlement) GetEventId 

func (m *EventSettlement) GetEventId() string

func (*EventSettlement) GetOutcomes 

func (m *EventSettlement) GetOutcomes() map[string]*OutcomeSettlement

func (*EventSettlement) GetResulting 

func (m *EventSettlement) GetResulting() *EventPoints

func (*EventSettlement) ProtoMessage 

func (*EventSettlement) ProtoMessage()

func (*EventSettlement) Reset 

func (m *EventSettlement) Reset()

func (*EventSettlement) String 

func (m *EventSettlement) String() string

func (*EventSettlement) XXX_DiscardUnknown 

func (m *EventSettlement) XXX_DiscardUnknown()

func (*EventSettlement) XXX_Marshal 

func (m *EventSettlement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventSettlement) XXX_Merge 

func (dst *EventSettlement) XXX_Merge(src proto.Message)

func (*EventSettlement) XXX_Size 

func (m *EventSettlement) XXX_Size() int

func (*EventSettlement) XXX_Unmarshal 

func (m *EventSettlement) XXX_Unmarshal(b []byte) error

type EventTimer 

type EventTimer struct {
	ChangedTs            *timestamp.Timestamp  `protobuf:"bytes,1,opt,name=changed_ts,json=changedTs,proto3" json:"changed_ts,omitempty"`
	Time                 *duration.Duration    `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	State                EventTimer_TimerState `protobuf:"varint,3,opt,name=state,proto3,enum=xfeed_proto.EventTimer_TimerState" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*EventTimer) Descriptor 

func (*EventTimer) Descriptor() ([]byte, []int)

func (*EventTimer) GetChangedTs 

func (m *EventTimer) GetChangedTs() *timestamp.Timestamp

func (*EventTimer) GetState 

func (m *EventTimer) GetState() EventTimer_TimerState

func (*EventTimer) GetTime 

func (m *EventTimer) GetTime() *duration.Duration

func (*EventTimer) ProtoMessage 

func (*EventTimer) ProtoMessage()

func (*EventTimer) Reset 

func (m *EventTimer) Reset()

func (*EventTimer) String 

func (m *EventTimer) String() string

func (*EventTimer) XXX_DiscardUnknown 

func (m *EventTimer) XXX_DiscardUnknown()

func (*EventTimer) XXX_Marshal 

func (m *EventTimer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventTimer) XXX_Merge 

func (dst *EventTimer) XXX_Merge(src proto.Message)

func (*EventTimer) XXX_Size 

func (m *EventTimer) XXX_Size() int

func (*EventTimer) XXX_Unmarshal 

func (m *EventTimer) XXX_Unmarshal(b []byte) error

type EventTimer_TimerState 

type EventTimer_TimerState int32
const (
	EventTimer_unknown  EventTimer_TimerState = 0
	EventTimer_FORWARD  EventTimer_TimerState = 1
	EventTimer_BACKWARD EventTimer_TimerState = 2
	EventTimer_PAUSE    EventTimer_TimerState = 3
)

func (EventTimer_TimerState) EnumDescriptor 

func (EventTimer_TimerState) EnumDescriptor() ([]byte, []int)

func (EventTimer_TimerState) String 

func (x EventTimer_TimerState) String() string

type EventsRecoveryComplete 

type EventsRecoveryComplete struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EventsRecoveryComplete) Descriptor 

func (*EventsRecoveryComplete) Descriptor() ([]byte, []int)

func (*EventsRecoveryComplete) ProtoMessage 

func (*EventsRecoveryComplete) ProtoMessage()

func (*EventsRecoveryComplete) Reset 

func (m *EventsRecoveryComplete) Reset()

func (*EventsRecoveryComplete) String 

func (m *EventsRecoveryComplete) String() string

func (*EventsRecoveryComplete) XXX_DiscardUnknown 

func (m *EventsRecoveryComplete) XXX_DiscardUnknown()

func (*EventsRecoveryComplete) XXX_Marshal 

func (m *EventsRecoveryComplete) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventsRecoveryComplete) XXX_Merge 

func (dst *EventsRecoveryComplete) XXX_Merge(src proto.Message)

func (*EventsRecoveryComplete) XXX_Size 

func (m *EventsRecoveryComplete) XXX_Size() int

func (*EventsRecoveryComplete) XXX_Unmarshal 

func (m *EventsRecoveryComplete) XXX_Unmarshal(b []byte) error

type FeedClient 

type FeedClient interface {
	StreamEvents(ctx context.Context, in *StreamEventsRequest, opts ...grpc.CallOption) (Feed_StreamEventsClient, error)
	StreamSettlements(ctx context.Context, in *StreamSettlementsRequest, opts ...grpc.CallOption) (Feed_StreamSettlementsClient, error)
	GetSportDescriptions(ctx context.Context, in *SportDescriptionsRequest, opts ...grpc.CallOption) (*SportDescriptionsResponse, error)
}

FeedClient is the client API for Feed service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewFeedClient 

func NewFeedClient(cc *grpc.ClientConn) FeedClient

type FeedEvent 

type FeedEvent struct {
	EventId      string                `protobuf:"bytes,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	SportId      int32                 `protobuf:"varint,2,opt,name=sport_id,json=sportId,proto3" json:"sport_id,omitempty"`
	Category     string                `protobuf:"bytes,3,opt,name=category,proto3" json:"category,omitempty"`
	League       string                `protobuf:"bytes,4,opt,name=league,proto3" json:"league,omitempty"`
	Status       FeedEvent_EventStatus `protobuf:"varint,5,opt,name=status,proto3,enum=xfeed_proto.FeedEvent_EventStatus" json:"status,omitempty"`
	StartTs      *timestamp.Timestamp  `protobuf:"bytes,6,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	Participants []string              `protobuf:"bytes,7,rep,name=participants,proto3" json:"participants,omitempty"`
	// only live
	Timer                *EventTimer  `protobuf:"bytes,8,opt,name=timer,proto3" json:"timer,omitempty"`
	Statistics           *EventPoints `protobuf:"bytes,9,opt,name=statistics,proto3" json:"statistics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*FeedEvent) Descriptor 

func (*FeedEvent) Descriptor() ([]byte, []int)

func (*FeedEvent) GetCategory 

func (m *FeedEvent) GetCategory() string

func (*FeedEvent) GetEventId 

func (m *FeedEvent) GetEventId() string

func (*FeedEvent) GetLeague 

func (m *FeedEvent) GetLeague() string

func (*FeedEvent) GetParticipants 

func (m *FeedEvent) GetParticipants() []string

func (*FeedEvent) GetSportId 

func (m *FeedEvent) GetSportId() int32

func (*FeedEvent) GetStartTs 

func (m *FeedEvent) GetStartTs() *timestamp.Timestamp

func (*FeedEvent) GetStatistics 

func (m *FeedEvent) GetStatistics() *EventPoints

func (*FeedEvent) GetStatus 

func (m *FeedEvent) GetStatus() FeedEvent_EventStatus

func (*FeedEvent) GetTimer 

func (m *FeedEvent) GetTimer() *EventTimer

func (*FeedEvent) ProtoMessage 

func (*FeedEvent) ProtoMessage()

func (*FeedEvent) Reset 

func (m *FeedEvent) Reset()

func (*FeedEvent) String 

func (m *FeedEvent) String() string

func (*FeedEvent) XXX_DiscardUnknown 

func (m *FeedEvent) XXX_DiscardUnknown()

func (*FeedEvent) XXX_Marshal 

func (m *FeedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FeedEvent) XXX_Merge 

func (dst *FeedEvent) XXX_Merge(src proto.Message)

func (*FeedEvent) XXX_Size 

func (m *FeedEvent) XXX_Size() int

func (*FeedEvent) XXX_Unmarshal 

func (m *FeedEvent) XXX_Unmarshal(b []byte) error

type FeedEvent_EventStatus 

type FeedEvent_EventStatus int32
const (
	FeedEvent_unknown  FeedEvent_EventStatus = 0
	FeedEvent_PREMATCH FeedEvent_EventStatus = 1
	FeedEvent_LIVE     FeedEvent_EventStatus = 2
)

func (FeedEvent_EventStatus) EnumDescriptor 

func (FeedEvent_EventStatus) EnumDescriptor() ([]byte, []int)

func (FeedEvent_EventStatus) String 

func (x FeedEvent_EventStatus) String() string

type FeedMarket 

type FeedMarket struct {
	MarketId             string             `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	MarketType           int32              `protobuf:"varint,2,opt,name=market_type,json=marketType,proto3" json:"market_type,omitempty"`
	MarketParams         []*FeedMarketParam `protobuf:"bytes,3,rep,name=market_params,json=marketParams,proto3" json:"market_params,omitempty"`
	Outcomes             []*FeedOutcome     `protobuf:"bytes,4,rep,name=outcomes,proto3" json:"outcomes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*FeedMarket) Descriptor 

func (*FeedMarket) Descriptor() ([]byte, []int)

func (*FeedMarket) GetMarketId 

func (m *FeedMarket) GetMarketId() string

func (*FeedMarket) GetMarketParams 

func (m *FeedMarket) GetMarketParams() []*FeedMarketParam

func (*FeedMarket) GetMarketType 

func (m *FeedMarket) GetMarketType() int32

func (*FeedMarket) GetOutcomes 

func (m *FeedMarket) GetOutcomes() []*FeedOutcome

func (*FeedMarket) ProtoMessage 

func (*FeedMarket) ProtoMessage()

func (*FeedMarket) Reset 

func (m *FeedMarket) Reset()

func (*FeedMarket) String 

func (m *FeedMarket) String() string

func (*FeedMarket) XXX_DiscardUnknown 

func (m *FeedMarket) XXX_DiscardUnknown()

func (*FeedMarket) XXX_Marshal 

func (m *FeedMarket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FeedMarket) XXX_Merge 

func (dst *FeedMarket) XXX_Merge(src proto.Message)

func (*FeedMarket) XXX_Size 

func (m *FeedMarket) XXX_Size() int

func (*FeedMarket) XXX_Unmarshal 

func (m *FeedMarket) XXX_Unmarshal(b []byte) error

type FeedMarketParam 

type FeedMarketParam struct {
	Type                 FeedMarketParam_MarketParamType `protobuf:"varint,1,opt,name=type,proto3,enum=xfeed_proto.FeedMarketParam_MarketParamType" json:"type,omitempty"`
	Value                string                          `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*FeedMarketParam) Descriptor 

func (*FeedMarketParam) Descriptor() ([]byte, []int)

func (*FeedMarketParam) GetType 

func (m *FeedMarketParam) GetType() FeedMarketParam_MarketParamType

func (*FeedMarketParam) GetValue 

func (m *FeedMarketParam) GetValue() string

func (*FeedMarketParam) ProtoMessage 

func (*FeedMarketParam) ProtoMessage()

func (*FeedMarketParam) Reset 

func (m *FeedMarketParam) Reset()

func (*FeedMarketParam) String 

func (m *FeedMarketParam) String() string

func (*FeedMarketParam) XXX_DiscardUnknown 

func (m *FeedMarketParam) XXX_DiscardUnknown()

func (*FeedMarketParam) XXX_Marshal 

func (m *FeedMarketParam) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FeedMarketParam) XXX_Merge 

func (dst *FeedMarketParam) XXX_Merge(src proto.Message)

func (*FeedMarketParam) XXX_Size 

func (m *FeedMarketParam) XXX_Size() int

func (*FeedMarketParam) XXX_Unmarshal 

func (m *FeedMarketParam) XXX_Unmarshal(b []byte) error

type FeedMarketParam_MarketParamType 

type FeedMarketParam_MarketParamType int32
const (
	FeedMarketParam_unknown  FeedMarketParam_MarketParamType = 0
	FeedMarketParam_PERIOD   FeedMarketParam_MarketParamType = 1
	FeedMarketParam_TOTAL    FeedMarketParam_MarketParamType = 2
	FeedMarketParam_HANDICAP FeedMarketParam_MarketParamType = 3
	FeedMarketParam_TEAM     FeedMarketParam_MarketParamType = 4
)

func (FeedMarketParam_MarketParamType) EnumDescriptor 

func (FeedMarketParam_MarketParamType) EnumDescriptor() ([]byte, []int)

func (FeedMarketParam_MarketParamType) String 

func (x FeedMarketParam_MarketParamType) String() string

type FeedOutcome 

type FeedOutcome struct {
	OutcomeId            string   `protobuf:"bytes,1,opt,name=outcome_id,json=outcomeId,proto3" json:"outcome_id,omitempty"`
	OutcomeType          int32    `protobuf:"varint,4,opt,name=outcome_type,json=outcomeType,proto3" json:"outcome_type,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Suspended            bool     `protobuf:"varint,3,opt,name=suspended,proto3" json:"suspended,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FeedOutcome) Descriptor 

func (*FeedOutcome) Descriptor() ([]byte, []int)

func (*FeedOutcome) GetOutcomeId 

func (m *FeedOutcome) GetOutcomeId() string

func (*FeedOutcome) GetOutcomeType 

func (m *FeedOutcome) GetOutcomeType() int32

func (*FeedOutcome) GetSuspended 

func (m *FeedOutcome) GetSuspended() bool

func (*FeedOutcome) GetValue 

func (m *FeedOutcome) GetValue() string

func (*FeedOutcome) ProtoMessage 

func (*FeedOutcome) ProtoMessage()

func (*FeedOutcome) Reset 

func (m *FeedOutcome) Reset()

func (*FeedOutcome) String 

func (m *FeedOutcome) String() string

func (*FeedOutcome) XXX_DiscardUnknown 

func (m *FeedOutcome) XXX_DiscardUnknown()

func (*FeedOutcome) XXX_Marshal 

func (m *FeedOutcome) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FeedOutcome) XXX_Merge 

func (dst *FeedOutcome) XXX_Merge(src proto.Message)

func (*FeedOutcome) XXX_Size 

func (m *FeedOutcome) XXX_Size() int

func (*FeedOutcome) XXX_Unmarshal 

func (m *FeedOutcome) XXX_Unmarshal(b []byte) error

type FeedServer 

type FeedServer interface {
	StreamEvents(*StreamEventsRequest, Feed_StreamEventsServer) error
	StreamSettlements(*StreamSettlementsRequest, Feed_StreamSettlementsServer) error
	GetSportDescriptions(context.Context, *SportDescriptionsRequest) (*SportDescriptionsResponse, error)
}

FeedServer is the server API for Feed service.

type Feed_StreamEventsClient 

type Feed_StreamEventsClient interface {
	Recv() (*StreamEventsResponse, error)
	grpc.ClientStream
}

type Feed_StreamEventsServer 

type Feed_StreamEventsServer interface {
	Send(*StreamEventsResponse) error
	grpc.ServerStream
}

type Feed_StreamSettlementsClient 

type Feed_StreamSettlementsClient interface {
	Recv() (*StreamSettlementsResponse, error)
	grpc.ClientStream
}

type Feed_StreamSettlementsServer 

type Feed_StreamSettlementsServer interface {
	Send(*StreamSettlementsResponse) error
	grpc.ServerStream
}

type GroupParams 

type GroupParams struct {
	Period               int32    `protobuf:"varint,1,opt,name=period,proto3" json:"period,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GroupParams) Descriptor 

func (*GroupParams) Descriptor() ([]byte, []int)

func (*GroupParams) GetPeriod 

func (m *GroupParams) GetPeriod() int32

func (*GroupParams) ProtoMessage 

func (*GroupParams) ProtoMessage()

func (*GroupParams) Reset 

func (m *GroupParams) Reset()

func (*GroupParams) String 

func (m *GroupParams) String() string

func (*GroupParams) XXX_DiscardUnknown 

func (m *GroupParams) XXX_DiscardUnknown()

func (*GroupParams) XXX_Marshal 

func (m *GroupParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GroupParams) XXX_Merge 

func (dst *GroupParams) XXX_Merge(src proto.Message)

func (*GroupParams) XXX_Size 

func (m *GroupParams) XXX_Size() int

func (*GroupParams) XXX_Unmarshal 

func (m *GroupParams) XXX_Unmarshal(b []byte) error

type MarketType 

type MarketType struct {
	MarketTypeId int32 `protobuf:"varint,1,opt,name=market_type_id,json=marketTypeId,proto3" json:"market_type_id,omitempty"`
	// event.participants = ["Dinamo", "Shakhtar"]
	// market_params.team = 1
	// Ex.: "{%participant} Total" -> "Dinamo Total"
	MarketNameTemplate   string         `protobuf:"bytes,2,opt,name=market_name_template,json=marketNameTemplate,proto3" json:"market_name_template,omitempty"`
	OutcomeTypes         []*OutcomeType `protobuf:"bytes,3,rep,name=outcome_types,json=outcomeTypes,proto3" json:"outcome_types,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*MarketType) Descriptor 

func (*MarketType) Descriptor() ([]byte, []int)

func (*MarketType) GetMarketNameTemplate 

func (m *MarketType) GetMarketNameTemplate() string

func (*MarketType) GetMarketTypeId 

func (m *MarketType) GetMarketTypeId() int32

func (*MarketType) GetOutcomeTypes 

func (m *MarketType) GetOutcomeTypes() []*OutcomeType

func (*MarketType) ProtoMessage 

func (*MarketType) ProtoMessage()

func (*MarketType) Reset 

func (m *MarketType) Reset()

func (*MarketType) String 

func (m *MarketType) String() string

func (*MarketType) XXX_DiscardUnknown 

func (m *MarketType) XXX_DiscardUnknown()

func (*MarketType) XXX_Marshal 

func (m *MarketType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MarketType) XXX_Merge 

func (dst *MarketType) XXX_Merge(src proto.Message)

func (*MarketType) XXX_Size 

func (m *MarketType) XXX_Size() int

func (*MarketType) XXX_Unmarshal 

func (m *MarketType) XXX_Unmarshal(b []byte) error

type MarketsDiff 

type MarketsDiff struct {
	EventId              string              `protobuf:"bytes,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	EventMarketsDiffs    []*SingleMarketDiff `protobuf:"bytes,2,rep,name=event_markets_diffs,json=eventMarketsDiffs,proto3" json:"event_markets_diffs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*MarketsDiff) Descriptor 

func (*MarketsDiff) Descriptor() ([]byte, []int)

func (*MarketsDiff) GetEventId 

func (m *MarketsDiff) GetEventId() string

func (*MarketsDiff) GetEventMarketsDiffs 

func (m *MarketsDiff) GetEventMarketsDiffs() []*SingleMarketDiff

func (*MarketsDiff) ProtoMessage 

func (*MarketsDiff) ProtoMessage()

func (*MarketsDiff) Reset 

func (m *MarketsDiff) Reset()

func (*MarketsDiff) String 

func (m *MarketsDiff) String() string

func (*MarketsDiff) XXX_DiscardUnknown 

func (m *MarketsDiff) XXX_DiscardUnknown()

func (*MarketsDiff) XXX_Marshal 

func (m *MarketsDiff) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MarketsDiff) XXX_Merge 

func (dst *MarketsDiff) XXX_Merge(src proto.Message)

func (*MarketsDiff) XXX_Size 

func (m *MarketsDiff) XXX_Size() int

func (*MarketsDiff) XXX_Unmarshal 

func (m *MarketsDiff) XXX_Unmarshal(b []byte) error

type MultipleEventsSettlement 

type MultipleEventsSettlement struct {
	EventSettlement      []*EventSettlement `protobuf:"bytes,1,rep,name=event_settlement,json=eventSettlement,proto3" json:"event_settlement,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*MultipleEventsSettlement) Descriptor 

func (*MultipleEventsSettlement) Descriptor() ([]byte, []int)

func (*MultipleEventsSettlement) GetEventSettlement 

func (m *MultipleEventsSettlement) GetEventSettlement() []*EventSettlement

func (*MultipleEventsSettlement) ProtoMessage 

func (*MultipleEventsSettlement) ProtoMessage()

func (*MultipleEventsSettlement) Reset 

func (m *MultipleEventsSettlement) Reset()

func (*MultipleEventsSettlement) String 

func (m *MultipleEventsSettlement) String() string

func (*MultipleEventsSettlement) XXX_DiscardUnknown 

func (m *MultipleEventsSettlement) XXX_DiscardUnknown()

func (*MultipleEventsSettlement) XXX_Marshal 

func (m *MultipleEventsSettlement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MultipleEventsSettlement) XXX_Merge 

func (dst *MultipleEventsSettlement) XXX_Merge(src proto.Message)

func (*MultipleEventsSettlement) XXX_Size 

func (m *MultipleEventsSettlement) XXX_Size() int

func (*MultipleEventsSettlement) XXX_Unmarshal 

func (m *MultipleEventsSettlement) XXX_Unmarshal(b []byte) error

type OutcomeSettlement 

type OutcomeSettlement struct {
	Settlement           OutcomeSettlement_SettlementType `protobuf:"varint,1,opt,name=settlement,proto3,enum=xfeed_proto.OutcomeSettlement_SettlementType" json:"settlement,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*OutcomeSettlement) Descriptor 

func (*OutcomeSettlement) Descriptor() ([]byte, []int)

func (*OutcomeSettlement) GetSettlement 

func (m *OutcomeSettlement) GetSettlement() OutcomeSettlement_SettlementType

func (*OutcomeSettlement) ProtoMessage 

func (*OutcomeSettlement) ProtoMessage()

func (*OutcomeSettlement) Reset 

func (m *OutcomeSettlement) Reset()

func (*OutcomeSettlement) String 

func (m *OutcomeSettlement) String() string

func (*OutcomeSettlement) XXX_DiscardUnknown 

func (m *OutcomeSettlement) XXX_DiscardUnknown()

func (*OutcomeSettlement) XXX_Marshal 

func (m *OutcomeSettlement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OutcomeSettlement) XXX_Merge 

func (dst *OutcomeSettlement) XXX_Merge(src proto.Message)

func (*OutcomeSettlement) XXX_Size 

func (m *OutcomeSettlement) XXX_Size() int

func (*OutcomeSettlement) XXX_Unmarshal 

func (m *OutcomeSettlement) XXX_Unmarshal(b []byte) error

type OutcomeSettlement_SettlementType 

type OutcomeSettlement_SettlementType int32
const (
	OutcomeSettlement_unknown   OutcomeSettlement_SettlementType = 0
	OutcomeSettlement_UNSETTLED OutcomeSettlement_SettlementType = 1
	OutcomeSettlement_WIN       OutcomeSettlement_SettlementType = 2
	OutcomeSettlement_LOSE      OutcomeSettlement_SettlementType = 3
	OutcomeSettlement_RETURN    OutcomeSettlement_SettlementType = 4
)

func (OutcomeSettlement_SettlementType) EnumDescriptor 

func (OutcomeSettlement_SettlementType) EnumDescriptor() ([]byte, []int)

func (OutcomeSettlement_SettlementType) String 

func (x OutcomeSettlement_SettlementType) String() string

type OutcomeType 

type OutcomeType struct {
	OutcomeTypeId int32 `protobuf:"varint,1,opt,name=outcome_type_id,json=outcomeTypeId,proto3" json:"outcome_type_id,omitempty"`
	// event.participants = ["Dinamo", "Shakhtar"]
	// market_params.handicap = 1.5
	// Ex.: "{$participant2} ({-$handicap})" -> "Shakhtar (-1.5)"
	OutcomeNameTemplate  string   `protobuf:"bytes,2,opt,name=outcome_name_template,json=outcomeNameTemplate,proto3" json:"outcome_name_template,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OutcomeType) Descriptor 

func (*OutcomeType) Descriptor() ([]byte, []int)

func (*OutcomeType) GetOutcomeNameTemplate 

func (m *OutcomeType) GetOutcomeNameTemplate() string

func (*OutcomeType) GetOutcomeTypeId 

func (m *OutcomeType) GetOutcomeTypeId() int32

func (*OutcomeType) ProtoMessage 

func (*OutcomeType) ProtoMessage()

func (*OutcomeType) Reset 

func (m *OutcomeType) Reset()

func (*OutcomeType) String 

func (m *OutcomeType) String() string

func (*OutcomeType) XXX_DiscardUnknown 

func (m *OutcomeType) XXX_DiscardUnknown()

func (*OutcomeType) XXX_Marshal 

func (m *OutcomeType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OutcomeType) XXX_Merge 

func (dst *OutcomeType) XXX_Merge(src proto.Message)

func (*OutcomeType) XXX_Size 

func (m *OutcomeType) XXX_Size() int

func (*OutcomeType) XXX_Unmarshal 

func (m *OutcomeType) XXX_Unmarshal(b []byte) error

type Period 

type Period struct {
	PeriodId             int32    `protobuf:"varint,1,opt,name=period_id,json=periodId,proto3" json:"period_id,omitempty"`
	PeriodName           string   `protobuf:"bytes,2,opt,name=period_name,json=periodName,proto3" json:"period_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Period) Descriptor 

func (*Period) Descriptor() ([]byte, []int)

func (*Period) GetPeriodId 

func (m *Period) GetPeriodId() int32

func (*Period) GetPeriodName 

func (m *Period) GetPeriodName() string

func (*Period) ProtoMessage 

func (*Period) ProtoMessage()

func (*Period) Reset 

func (m *Period) Reset()

func (*Period) String 

func (m *Period) String() string

func (*Period) XXX_DiscardUnknown 

func (m *Period) XXX_DiscardUnknown()

func (*Period) XXX_Marshal 

func (m *Period) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Period) XXX_Merge 

func (dst *Period) XXX_Merge(src proto.Message)

func (*Period) XXX_Size 

func (m *Period) XXX_Size() int

func (*Period) XXX_Unmarshal 

func (m *Period) XXX_Unmarshal(b []byte) error

type PointsGroup 

type PointsGroup struct {
	PointType            PointsGroup_PointType `` /* 128-byte string literal not displayed */
	GroupParams          *GroupParams          `protobuf:"bytes,2,opt,name=group_params,json=groupParams,proto3" json:"group_params,omitempty"`
	State                []*State              `protobuf:"bytes,3,rep,name=state,proto3" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*PointsGroup) Descriptor 

func (*PointsGroup) Descriptor() ([]byte, []int)

func (*PointsGroup) GetGroupParams 

func (m *PointsGroup) GetGroupParams() *GroupParams

func (*PointsGroup) GetPointType 

func (m *PointsGroup) GetPointType() PointsGroup_PointType

func (*PointsGroup) GetState 

func (m *PointsGroup) GetState() []*State

func (*PointsGroup) ProtoMessage 

func (*PointsGroup) ProtoMessage()

func (*PointsGroup) Reset 

func (m *PointsGroup) Reset()

func (*PointsGroup) String 

func (m *PointsGroup) String() string

func (*PointsGroup) XXX_DiscardUnknown 

func (m *PointsGroup) XXX_DiscardUnknown()

func (*PointsGroup) XXX_Marshal 

func (m *PointsGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PointsGroup) XXX_Merge 

func (dst *PointsGroup) XXX_Merge(src proto.Message)

func (*PointsGroup) XXX_Size 

func (m *PointsGroup) XXX_Size() int

func (*PointsGroup) XXX_Unmarshal 

func (m *PointsGroup) XXX_Unmarshal(b []byte) error

type PointsGroup_PointType 

type PointsGroup_PointType int32
const (
	PointsGroup_unknown      PointsGroup_PointType = 0
	PointsGroup_SCORE        PointsGroup_PointType = 1
	PointsGroup_RED_CARDS    PointsGroup_PointType = 2
	PointsGroup_YELLOW_CARDS PointsGroup_PointType = 3
	PointsGroup_PENALTIES    PointsGroup_PointType = 4
	PointsGroup_CORNERS      PointsGroup_PointType = 5
)

func (PointsGroup_PointType) EnumDescriptor 

func (PointsGroup_PointType) EnumDescriptor() ([]byte, []int)

func (PointsGroup_PointType) String 

func (x PointsGroup_PointType) String() string

type SettlementRecoveryComplete 

type SettlementRecoveryComplete struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SettlementRecoveryComplete) Descriptor 

func (*SettlementRecoveryComplete) Descriptor() ([]byte, []int)

func (*SettlementRecoveryComplete) ProtoMessage 

func (*SettlementRecoveryComplete) ProtoMessage()

func (*SettlementRecoveryComplete) Reset 

func (m *SettlementRecoveryComplete) Reset()

func (*SettlementRecoveryComplete) String 

func (m *SettlementRecoveryComplete) String() string

func (*SettlementRecoveryComplete) XXX_DiscardUnknown 

func (m *SettlementRecoveryComplete) XXX_DiscardUnknown()

func (*SettlementRecoveryComplete) XXX_Marshal 

func (m *SettlementRecoveryComplete) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SettlementRecoveryComplete) XXX_Merge 

func (dst *SettlementRecoveryComplete) XXX_Merge(src proto.Message)

func (*SettlementRecoveryComplete) XXX_Size 

func (m *SettlementRecoveryComplete) XXX_Size() int

func (*SettlementRecoveryComplete) XXX_Unmarshal 

func (m *SettlementRecoveryComplete) XXX_Unmarshal(b []byte) error

type SingleMarketDiff 

type SingleMarketDiff struct {
	DiffType             DiffType    `protobuf:"varint,1,opt,name=diff_type,json=diffType,proto3,enum=xfeed_proto.DiffType" json:"diff_type,omitempty"`
	Market               *FeedMarket `protobuf:"bytes,2,opt,name=market,proto3" json:"market,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*SingleMarketDiff) Descriptor 

func (*SingleMarketDiff) Descriptor() ([]byte, []int)

func (*SingleMarketDiff) GetDiffType 

func (m *SingleMarketDiff) GetDiffType() DiffType

func (*SingleMarketDiff) GetMarket 

func (m *SingleMarketDiff) GetMarket() *FeedMarket

func (*SingleMarketDiff) ProtoMessage 

func (*SingleMarketDiff) ProtoMessage()

func (*SingleMarketDiff) Reset 

func (m *SingleMarketDiff) Reset()

func (*SingleMarketDiff) String 

func (m *SingleMarketDiff) String() string

func (*SingleMarketDiff) XXX_DiscardUnknown 

func (m *SingleMarketDiff) XXX_DiscardUnknown()

func (*SingleMarketDiff) XXX_Marshal 

func (m *SingleMarketDiff) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SingleMarketDiff) XXX_Merge 

func (dst *SingleMarketDiff) XXX_Merge(src proto.Message)

func (*SingleMarketDiff) XXX_Size 

func (m *SingleMarketDiff) XXX_Size() int

func (*SingleMarketDiff) XXX_Unmarshal 

func (m *SingleMarketDiff) XXX_Unmarshal(b []byte) error

type SportDescription 

type SportDescription struct {
	SportId              int32         `protobuf:"varint,1,opt,name=sport_id,json=sportId,proto3" json:"sport_id,omitempty"`
	SportName            string        `protobuf:"bytes,2,opt,name=sport_name,json=sportName,proto3" json:"sport_name,omitempty"`
	Periods              []*Period     `protobuf:"bytes,3,rep,name=periods,proto3" json:"periods,omitempty"`
	MarketTypes          []*MarketType `protobuf:"bytes,4,rep,name=market_types,json=marketTypes,proto3" json:"market_types,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*SportDescription) Descriptor 

func (*SportDescription) Descriptor() ([]byte, []int)

func (*SportDescription) GetMarketTypes 

func (m *SportDescription) GetMarketTypes() []*MarketType

func (*SportDescription) GetPeriods 

func (m *SportDescription) GetPeriods() []*Period

func (*SportDescription) GetSportId 

func (m *SportDescription) GetSportId() int32

func (*SportDescription) GetSportName 

func (m *SportDescription) GetSportName() string

func (*SportDescription) ProtoMessage 

func (*SportDescription) ProtoMessage()

func (*SportDescription) Reset 

func (m *SportDescription) Reset()

func (*SportDescription) String 

func (m *SportDescription) String() string

func (*SportDescription) XXX_DiscardUnknown 

func (m *SportDescription) XXX_DiscardUnknown()

func (*SportDescription) XXX_Marshal 

func (m *SportDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SportDescription) XXX_Merge 

func (dst *SportDescription) XXX_Merge(src proto.Message)

func (*SportDescription) XXX_Size 

func (m *SportDescription) XXX_Size() int

func (*SportDescription) XXX_Unmarshal 

func (m *SportDescription) XXX_Unmarshal(b []byte) error

type SportDescriptionsRequest 

type SportDescriptionsRequest struct {
	Lang                 string   `protobuf:"bytes,1,opt,name=lang,proto3" json:"lang,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SportDescriptionsRequest) Descriptor 

func (*SportDescriptionsRequest) Descriptor() ([]byte, []int)

func (*SportDescriptionsRequest) GetLang 

func (m *SportDescriptionsRequest) GetLang() string

func (*SportDescriptionsRequest) ProtoMessage 

func (*SportDescriptionsRequest) ProtoMessage()

func (*SportDescriptionsRequest) Reset 

func (m *SportDescriptionsRequest) Reset()

func (*SportDescriptionsRequest) String 

func (m *SportDescriptionsRequest) String() string

func (*SportDescriptionsRequest) XXX_DiscardUnknown 

func (m *SportDescriptionsRequest) XXX_DiscardUnknown()

func (*SportDescriptionsRequest) XXX_Marshal 

func (m *SportDescriptionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SportDescriptionsRequest) XXX_Merge 

func (dst *SportDescriptionsRequest) XXX_Merge(src proto.Message)

func (*SportDescriptionsRequest) XXX_Size 

func (m *SportDescriptionsRequest) XXX_Size() int

func (*SportDescriptionsRequest) XXX_Unmarshal 

func (m *SportDescriptionsRequest) XXX_Unmarshal(b []byte) error

type SportDescriptionsResponse 

type SportDescriptionsResponse struct {
	SportDescriptions    []*SportDescription `protobuf:"bytes,1,rep,name=sport_descriptions,json=sportDescriptions,proto3" json:"sport_descriptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*SportDescriptionsResponse) Descriptor 

func (*SportDescriptionsResponse) Descriptor() ([]byte, []int)

func (*SportDescriptionsResponse) GetSportDescriptions 

func (m *SportDescriptionsResponse) GetSportDescriptions() []*SportDescription

func (*SportDescriptionsResponse) ProtoMessage 

func (*SportDescriptionsResponse) ProtoMessage()

func (*SportDescriptionsResponse) Reset 

func (m *SportDescriptionsResponse) Reset()

func (*SportDescriptionsResponse) String 

func (m *SportDescriptionsResponse) String() string

func (*SportDescriptionsResponse) XXX_DiscardUnknown 

func (m *SportDescriptionsResponse) XXX_DiscardUnknown()

func (*SportDescriptionsResponse) XXX_Marshal 

func (m *SportDescriptionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SportDescriptionsResponse) XXX_Merge 

func (dst *SportDescriptionsResponse) XXX_Merge(src proto.Message)

func (*SportDescriptionsResponse) XXX_Size 

func (m *SportDescriptionsResponse) XXX_Size() int

func (*SportDescriptionsResponse) XXX_Unmarshal 

func (m *SportDescriptionsResponse) XXX_Unmarshal(b []byte) error

type State 

type State struct {
	StateParams          *StateParams `protobuf:"bytes,1,opt,name=state_params,json=stateParams,proto3" json:"state_params,omitempty"`
	Value                int32        `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*State) Descriptor 

func (*State) Descriptor() ([]byte, []int)

func (*State) GetStateParams 

func (m *State) GetStateParams() *StateParams

func (*State) GetValue 

func (m *State) GetValue() int32

func (*State) ProtoMessage 

func (*State) ProtoMessage()

func (*State) Reset 

func (m *State) Reset()

func (*State) String 

func (m *State) String() string

func (*State) XXX_DiscardUnknown 

func (m *State) XXX_DiscardUnknown()

func (*State) XXX_Marshal 

func (m *State) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*State) XXX_Merge 

func (dst *State) XXX_Merge(src proto.Message)

func (*State) XXX_Size 

func (m *State) XXX_Size() int

func (*State) XXX_Unmarshal 

func (m *State) XXX_Unmarshal(b []byte) error

type StateParams 

type StateParams struct {
	Participant          int32    `protobuf:"varint,1,opt,name=participant,proto3" json:"participant,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StateParams) Descriptor 

func (*StateParams) Descriptor() ([]byte, []int)

func (*StateParams) GetParticipant 

func (m *StateParams) GetParticipant() int32

func (*StateParams) ProtoMessage 

func (*StateParams) ProtoMessage()

func (*StateParams) Reset 

func (m *StateParams) Reset()

func (*StateParams) String 

func (m *StateParams) String() string

func (*StateParams) XXX_DiscardUnknown 

func (m *StateParams) XXX_DiscardUnknown()

func (*StateParams) XXX_Marshal 

func (m *StateParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StateParams) XXX_Merge 

func (dst *StateParams) XXX_Merge(src proto.Message)

func (*StateParams) XXX_Size 

func (m *StateParams) XXX_Size() int

func (*StateParams) XXX_Unmarshal 

func (m *StateParams) XXX_Unmarshal(b []byte) error

type StreamEventsRequest 

type StreamEventsRequest struct {
	ClientName           string   `protobuf:"bytes,1,opt,name=client_name,json=clientName,proto3" json:"client_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamEventsRequest) Descriptor 

func (*StreamEventsRequest) Descriptor() ([]byte, []int)

func (*StreamEventsRequest) GetClientName 

func (m *StreamEventsRequest) GetClientName() string

func (*StreamEventsRequest) ProtoMessage 

func (*StreamEventsRequest) ProtoMessage()

func (*StreamEventsRequest) Reset 

func (m *StreamEventsRequest) Reset()

func (*StreamEventsRequest) String 

func (m *StreamEventsRequest) String() string

func (*StreamEventsRequest) XXX_DiscardUnknown 

func (m *StreamEventsRequest) XXX_DiscardUnknown()

func (*StreamEventsRequest) XXX_Marshal 

func (m *StreamEventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamEventsRequest) XXX_Merge 

func (dst *StreamEventsRequest) XXX_Merge(src proto.Message)

func (*StreamEventsRequest) XXX_Size 

func (m *StreamEventsRequest) XXX_Size() int

func (*StreamEventsRequest) XXX_Unmarshal 

func (m *StreamEventsRequest) XXX_Unmarshal(b []byte) error

type StreamEventsResponse 

type StreamEventsResponse struct {
	// Types that are valid to be assigned to Data:
	//	*StreamEventsResponse_DiffsMessage
	//	*StreamEventsResponse_RecoveryComplete
	Data                 isStreamEventsResponse_Data `protobuf_oneof:"data"`
	GeneratedTs          *timestamp.Timestamp        `protobuf:"bytes,3,opt,name=generated_ts,json=generatedTs,proto3" json:"generated_ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*StreamEventsResponse) Descriptor 

func (*StreamEventsResponse) Descriptor() ([]byte, []int)

func (*StreamEventsResponse) GetData 

func (m *StreamEventsResponse) GetData() isStreamEventsResponse_Data

func (*StreamEventsResponse) GetDiffsMessage 

func (m *StreamEventsResponse) GetDiffsMessage() *DiffsMessage

func (*StreamEventsResponse) GetGeneratedTs 

func (m *StreamEventsResponse) GetGeneratedTs() *timestamp.Timestamp

func (*StreamEventsResponse) GetRecoveryComplete 

func (m *StreamEventsResponse) GetRecoveryComplete() *EventsRecoveryComplete

func (*StreamEventsResponse) ProtoMessage 

func (*StreamEventsResponse) ProtoMessage()

func (*StreamEventsResponse) Reset 

func (m *StreamEventsResponse) Reset()

func (*StreamEventsResponse) String 

func (m *StreamEventsResponse) String() string

func (*StreamEventsResponse) XXX_DiscardUnknown 

func (m *StreamEventsResponse) XXX_DiscardUnknown()

func (*StreamEventsResponse) XXX_Marshal 

func (m *StreamEventsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamEventsResponse) XXX_Merge 

func (dst *StreamEventsResponse) XXX_Merge(src proto.Message)

func (*StreamEventsResponse) XXX_OneofFuncs 

func (*StreamEventsResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*StreamEventsResponse) XXX_Size 

func (m *StreamEventsResponse) XXX_Size() int

func (*StreamEventsResponse) XXX_Unmarshal 

func (m *StreamEventsResponse) XXX_Unmarshal(b []byte) error

type StreamEventsResponse_DiffsMessage 

type StreamEventsResponse_DiffsMessage struct {
	DiffsMessage *DiffsMessage `protobuf:"bytes,1,opt,name=diffs_message,json=diffsMessage,proto3,oneof"`
}

type StreamEventsResponse_RecoveryComplete 

type StreamEventsResponse_RecoveryComplete struct {
	RecoveryComplete *EventsRecoveryComplete `protobuf:"bytes,2,opt,name=recovery_complete,json=recoveryComplete,proto3,oneof"`
}

type StreamSettlementsRequest 

type StreamSettlementsRequest struct {
	ClientName            string               `protobuf:"bytes,1,opt,name=client_name,json=clientName,proto3" json:"client_name,omitempty"`
	LastConsumedTimestamp *timestamp.Timestamp `` /* 126-byte string literal not displayed */
	XXX_NoUnkeyedLiteral  struct{}             `json:"-"`
	XXX_unrecognized      []byte               `json:"-"`
	XXX_sizecache         int32                `json:"-"`
}

func (*StreamSettlementsRequest) Descriptor 

func (*StreamSettlementsRequest) Descriptor() ([]byte, []int)

func (*StreamSettlementsRequest) GetClientName 

func (m *StreamSettlementsRequest) GetClientName() string

func (*StreamSettlementsRequest) GetLastConsumedTimestamp 

func (m *StreamSettlementsRequest) GetLastConsumedTimestamp() *timestamp.Timestamp

func (*StreamSettlementsRequest) ProtoMessage 

func (*StreamSettlementsRequest) ProtoMessage()

func (*StreamSettlementsRequest) Reset 

func (m *StreamSettlementsRequest) Reset()

func (*StreamSettlementsRequest) String 

func (m *StreamSettlementsRequest) String() string

func (*StreamSettlementsRequest) XXX_DiscardUnknown 

func (m *StreamSettlementsRequest) XXX_DiscardUnknown()

func (*StreamSettlementsRequest) XXX_Marshal 

func (m *StreamSettlementsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamSettlementsRequest) XXX_Merge 

func (dst *StreamSettlementsRequest) XXX_Merge(src proto.Message)

func (*StreamSettlementsRequest) XXX_Size 

func (m *StreamSettlementsRequest) XXX_Size() int

func (*StreamSettlementsRequest) XXX_Unmarshal 

func (m *StreamSettlementsRequest) XXX_Unmarshal(b []byte) error

type StreamSettlementsResponse 

type StreamSettlementsResponse struct {
	// Types that are valid to be assigned to Data:
	//	*StreamSettlementsResponse_MultipleEventsSettlement
	//	*StreamSettlementsResponse_RecoveryComplete
	Data                 isStreamSettlementsResponse_Data `protobuf_oneof:"data"`
	DiffTimestamp        *timestamp.Timestamp             `protobuf:"bytes,3,opt,name=diff_timestamp,json=diffTimestamp,proto3" json:"diff_timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*StreamSettlementsResponse) Descriptor 

func (*StreamSettlementsResponse) Descriptor() ([]byte, []int)

func (*StreamSettlementsResponse) GetData 

func (m *StreamSettlementsResponse) GetData() isStreamSettlementsResponse_Data

func (*StreamSettlementsResponse) GetDiffTimestamp 

func (m *StreamSettlementsResponse) GetDiffTimestamp() *timestamp.Timestamp

func (*StreamSettlementsResponse) GetMultipleEventsSettlement 

func (m *StreamSettlementsResponse) GetMultipleEventsSettlement() *MultipleEventsSettlement

func (*StreamSettlementsResponse) GetRecoveryComplete 

func (m *StreamSettlementsResponse) GetRecoveryComplete() *SettlementRecoveryComplete

func (*StreamSettlementsResponse) ProtoMessage 

func (*StreamSettlementsResponse) ProtoMessage()

func (*StreamSettlementsResponse) Reset 

func (m *StreamSettlementsResponse) Reset()

func (*StreamSettlementsResponse) String 

func (m *StreamSettlementsResponse) String() string

func (*StreamSettlementsResponse) XXX_DiscardUnknown 

func (m *StreamSettlementsResponse) XXX_DiscardUnknown()

func (*StreamSettlementsResponse) XXX_Marshal 

func (m *StreamSettlementsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamSettlementsResponse) XXX_Merge 

func (dst *StreamSettlementsResponse) XXX_Merge(src proto.Message)

func (*StreamSettlementsResponse) XXX_OneofFuncs 

func (*StreamSettlementsResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*StreamSettlementsResponse) XXX_Size 

func (m *StreamSettlementsResponse) XXX_Size() int

func (*StreamSettlementsResponse) XXX_Unmarshal 

func (m *StreamSettlementsResponse) XXX_Unmarshal(b []byte) error

type StreamSettlementsResponse_MultipleEventsSettlement 

type StreamSettlementsResponse_MultipleEventsSettlement struct {
	MultipleEventsSettlement *MultipleEventsSettlement `protobuf:"bytes,1,opt,name=multiple_events_settlement,json=multipleEventsSettlement,proto3,oneof"`
}

type StreamSettlementsResponse_RecoveryComplete 

type StreamSettlementsResponse_RecoveryComplete struct {
	RecoveryComplete *SettlementRecoveryComplete `protobuf:"bytes,2,opt,name=recovery_complete,json=recoveryComplete,proto3,oneof"`
}

Source Files

  • doc.go
  • endpoint.pb.go
  • event_points.pb.go
  • events_stream.pb.go
  • settlement_stream.pb.go
  • sport_descriptions.pb.go

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.