statestoreservice

package
v0.16.1 Latest Latest
Warning

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

 Go to latest Published: Sep 22, 2022 License: Apache-2.0 Imports: 9 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GoUnusedProtection__ int
View Source 
var THeartbeatRequest_RegistrationID_DEFAULT *types.TUniqueId
View Source 
var THeavyMemoryQuery_QueryId_DEFAULT *types.TUniqueId
View Source 
var TRegisterSubscriberRequest_SubscriberLocation_DEFAULT *types.TNetworkAddress
View Source 
var TRegisterSubscriberResponse_RegistrationID_DEFAULT *types.TUniqueId
View Source 
var TRegisterSubscriberResponse_Status_DEFAULT *status.TStatus
View Source 
var TTopicDelta_ClearTopicEntries_DEFAULT bool
View Source 
var TTopicDelta_FromVersion_DEFAULT int64
View Source 
var TTopicDelta_MinSubscriberTopicVersion_DEFAULT int64
View Source 
var TTopicDelta_ToVersion_DEFAULT int64
View Source 
var TTopicRegistration_FilterPrefix_DEFAULT string
View Source 
var TUpdateStateRequest_RegistrationID_DEFAULT *types.TUniqueId
View Source 
var TUpdateStateResponse_Skipped_DEFAULT bool
View Source 
var TUpdateStateResponse_Status_DEFAULT *status.TStatus

Functions

This section is empty.

Types

type StatestoreService 

type StatestoreService interface {
	// Parameters:
	//  - Params
	RegisterSubscriber(ctx context.Context, params *TRegisterSubscriberRequest) (_r *TRegisterSubscriberResponse, _err error)
}

type StatestoreServiceClient 

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

func NewStatestoreServiceClient 

func NewStatestoreServiceClient(c thrift.TClient) *StatestoreServiceClient

func NewStatestoreServiceClientFactory 

func NewStatestoreServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *StatestoreServiceClient

func NewStatestoreServiceClientProtocol 

func NewStatestoreServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *StatestoreServiceClient

func (*StatestoreServiceClient) Client_ 

func (p *StatestoreServiceClient) Client_() thrift.TClient

func (*StatestoreServiceClient) LastResponseMeta_ 

func (p *StatestoreServiceClient) LastResponseMeta_() thrift.ResponseMeta

func (*StatestoreServiceClient) RegisterSubscriber 

func (p *StatestoreServiceClient) RegisterSubscriber(ctx context.Context, params *TRegisterSubscriberRequest) (_r *TRegisterSubscriberResponse, _err error)

Parameters:

  • Params

func (*StatestoreServiceClient) SetLastResponseMeta_ 

func (p *StatestoreServiceClient) SetLastResponseMeta_(meta thrift.ResponseMeta)

type StatestoreServiceProcessor 

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

func NewStatestoreServiceProcessor 

func NewStatestoreServiceProcessor(handler StatestoreService) *StatestoreServiceProcessor

func (*StatestoreServiceProcessor) AddToProcessorMap 

func (p *StatestoreServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*StatestoreServiceProcessor) GetProcessorFunction 

func (p *StatestoreServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*StatestoreServiceProcessor) Process 

func (p *StatestoreServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*StatestoreServiceProcessor) ProcessorMap 

func (p *StatestoreServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

type StatestoreServiceRegisterSubscriberArgs 

type StatestoreServiceRegisterSubscriberArgs struct {
	Params *TRegisterSubscriberRequest `thrift:"params,1" db:"params" json:"params"`
}

Attributes:

  • Params

func NewStatestoreServiceRegisterSubscriberArgs 

func NewStatestoreServiceRegisterSubscriberArgs() *StatestoreServiceRegisterSubscriberArgs

func (*StatestoreServiceRegisterSubscriberArgs) GetParams 

func (p *StatestoreServiceRegisterSubscriberArgs) GetParams() *TRegisterSubscriberRequest

func (*StatestoreServiceRegisterSubscriberArgs) IsSetParams 

func (p *StatestoreServiceRegisterSubscriberArgs) IsSetParams() bool

func (*StatestoreServiceRegisterSubscriberArgs) Read 

func (p *StatestoreServiceRegisterSubscriberArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*StatestoreServiceRegisterSubscriberArgs) ReadField1 

func (p *StatestoreServiceRegisterSubscriberArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*StatestoreServiceRegisterSubscriberArgs) String 

func (p *StatestoreServiceRegisterSubscriberArgs) String() string

func (*StatestoreServiceRegisterSubscriberArgs) Write 

func (p *StatestoreServiceRegisterSubscriberArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type StatestoreServiceRegisterSubscriberResult 

type StatestoreServiceRegisterSubscriberResult struct {
	Success *TRegisterSubscriberResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStatestoreServiceRegisterSubscriberResult 

func NewStatestoreServiceRegisterSubscriberResult() *StatestoreServiceRegisterSubscriberResult

func (*StatestoreServiceRegisterSubscriberResult) GetSuccess 

func (p *StatestoreServiceRegisterSubscriberResult) GetSuccess() *TRegisterSubscriberResponse

func (*StatestoreServiceRegisterSubscriberResult) IsSetSuccess 

func (p *StatestoreServiceRegisterSubscriberResult) IsSetSuccess() bool

func (*StatestoreServiceRegisterSubscriberResult) Read 

func (p *StatestoreServiceRegisterSubscriberResult) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*StatestoreServiceRegisterSubscriberResult) ReadField0 

func (p *StatestoreServiceRegisterSubscriberResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*StatestoreServiceRegisterSubscriberResult) String 

func (p *StatestoreServiceRegisterSubscriberResult) String() string

func (*StatestoreServiceRegisterSubscriberResult) Write 

func (p *StatestoreServiceRegisterSubscriberResult) Write(ctx context.Context, oprot thrift.TProtocol) error

type StatestoreServiceVersion 

type StatestoreServiceVersion int64
const (
	StatestoreServiceVersion_V1 StatestoreServiceVersion = 0
)

func StatestoreServiceVersionFromString 

func StatestoreServiceVersionFromString(s string) (StatestoreServiceVersion, error)

func StatestoreServiceVersionPtr 

func StatestoreServiceVersionPtr(v StatestoreServiceVersion) *StatestoreServiceVersion

func (StatestoreServiceVersion) MarshalText 

func (p StatestoreServiceVersion) MarshalText() ([]byte, error)

func (*StatestoreServiceVersion) Scan 

func (p *StatestoreServiceVersion) Scan(value interface{}) error

func (StatestoreServiceVersion) String 

func (p StatestoreServiceVersion) String() string

func (*StatestoreServiceVersion) UnmarshalText 

func (p *StatestoreServiceVersion) UnmarshalText(text []byte) error

func (*StatestoreServiceVersion) Value 

func (p *StatestoreServiceVersion) Value() (driver.Value, error)

type StatestoreSubscriber 

type StatestoreSubscriber interface {
	// Parameters:
	//  - Params
	UpdateState(ctx context.Context, params *TUpdateStateRequest) (_r *TUpdateStateResponse, _err error)
	// Parameters:
	//  - Params
	Heartbeat(ctx context.Context, params *THeartbeatRequest) (_r *THeartbeatResponse, _err error)
}

type StatestoreSubscriberClient 

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

func NewStatestoreSubscriberClient 

func NewStatestoreSubscriberClient(c thrift.TClient) *StatestoreSubscriberClient

func NewStatestoreSubscriberClientFactory 

func NewStatestoreSubscriberClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *StatestoreSubscriberClient

func NewStatestoreSubscriberClientProtocol 

func NewStatestoreSubscriberClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *StatestoreSubscriberClient

func (*StatestoreSubscriberClient) Client_ 

func (p *StatestoreSubscriberClient) Client_() thrift.TClient

func (*StatestoreSubscriberClient) Heartbeat 

func (p *StatestoreSubscriberClient) Heartbeat(ctx context.Context, params *THeartbeatRequest) (_r *THeartbeatResponse, _err error)

Parameters:

  • Params

func (*StatestoreSubscriberClient) LastResponseMeta_ 

func (p *StatestoreSubscriberClient) LastResponseMeta_() thrift.ResponseMeta

func (*StatestoreSubscriberClient) SetLastResponseMeta_ 

func (p *StatestoreSubscriberClient) SetLastResponseMeta_(meta thrift.ResponseMeta)

func (*StatestoreSubscriberClient) UpdateState 

func (p *StatestoreSubscriberClient) UpdateState(ctx context.Context, params *TUpdateStateRequest) (_r *TUpdateStateResponse, _err error)

Parameters:

  • Params

type StatestoreSubscriberHeartbeatArgs 

type StatestoreSubscriberHeartbeatArgs struct {
	Params *THeartbeatRequest `thrift:"params,1" db:"params" json:"params"`
}

Attributes:

  • Params

func NewStatestoreSubscriberHeartbeatArgs 

func NewStatestoreSubscriberHeartbeatArgs() *StatestoreSubscriberHeartbeatArgs

func (*StatestoreSubscriberHeartbeatArgs) GetParams 

func (p *StatestoreSubscriberHeartbeatArgs) GetParams() *THeartbeatRequest

func (*StatestoreSubscriberHeartbeatArgs) IsSetParams 

func (p *StatestoreSubscriberHeartbeatArgs) IsSetParams() bool

func (*StatestoreSubscriberHeartbeatArgs) Read 

func (p *StatestoreSubscriberHeartbeatArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*StatestoreSubscriberHeartbeatArgs) ReadField1 

func (p *StatestoreSubscriberHeartbeatArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*StatestoreSubscriberHeartbeatArgs) String 

func (p *StatestoreSubscriberHeartbeatArgs) String() string

func (*StatestoreSubscriberHeartbeatArgs) Write 

func (p *StatestoreSubscriberHeartbeatArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type StatestoreSubscriberHeartbeatResult 

type StatestoreSubscriberHeartbeatResult struct {
	Success *THeartbeatResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStatestoreSubscriberHeartbeatResult 

func NewStatestoreSubscriberHeartbeatResult() *StatestoreSubscriberHeartbeatResult

func (*StatestoreSubscriberHeartbeatResult) GetSuccess 

func (p *StatestoreSubscriberHeartbeatResult) GetSuccess() *THeartbeatResponse

func (*StatestoreSubscriberHeartbeatResult) IsSetSuccess 

func (p *StatestoreSubscriberHeartbeatResult) IsSetSuccess() bool

func (*StatestoreSubscriberHeartbeatResult) Read 

func (p *StatestoreSubscriberHeartbeatResult) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*StatestoreSubscriberHeartbeatResult) ReadField0 

func (p *StatestoreSubscriberHeartbeatResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*StatestoreSubscriberHeartbeatResult) String 

func (p *StatestoreSubscriberHeartbeatResult) String() string

func (*StatestoreSubscriberHeartbeatResult) Write 

func (p *StatestoreSubscriberHeartbeatResult) Write(ctx context.Context, oprot thrift.TProtocol) error

type StatestoreSubscriberProcessor 

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

func NewStatestoreSubscriberProcessor 

func NewStatestoreSubscriberProcessor(handler StatestoreSubscriber) *StatestoreSubscriberProcessor

func (*StatestoreSubscriberProcessor) AddToProcessorMap 

func (p *StatestoreSubscriberProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*StatestoreSubscriberProcessor) GetProcessorFunction 

func (p *StatestoreSubscriberProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*StatestoreSubscriberProcessor) Process 

func (p *StatestoreSubscriberProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*StatestoreSubscriberProcessor) ProcessorMap 

func (p *StatestoreSubscriberProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

type StatestoreSubscriberUpdateStateArgs 

type StatestoreSubscriberUpdateStateArgs struct {
	Params *TUpdateStateRequest `thrift:"params,1" db:"params" json:"params"`
}

Attributes:

  • Params

func NewStatestoreSubscriberUpdateStateArgs 

func NewStatestoreSubscriberUpdateStateArgs() *StatestoreSubscriberUpdateStateArgs

func (*StatestoreSubscriberUpdateStateArgs) GetParams 

func (p *StatestoreSubscriberUpdateStateArgs) GetParams() *TUpdateStateRequest

func (*StatestoreSubscriberUpdateStateArgs) IsSetParams 

func (p *StatestoreSubscriberUpdateStateArgs) IsSetParams() bool

func (*StatestoreSubscriberUpdateStateArgs) Read 

func (p *StatestoreSubscriberUpdateStateArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*StatestoreSubscriberUpdateStateArgs) ReadField1 

func (p *StatestoreSubscriberUpdateStateArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*StatestoreSubscriberUpdateStateArgs) String 

func (p *StatestoreSubscriberUpdateStateArgs) String() string

func (*StatestoreSubscriberUpdateStateArgs) Write 

func (p *StatestoreSubscriberUpdateStateArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type StatestoreSubscriberUpdateStateResult 

type StatestoreSubscriberUpdateStateResult struct {
	Success *TUpdateStateResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStatestoreSubscriberUpdateStateResult 

func NewStatestoreSubscriberUpdateStateResult() *StatestoreSubscriberUpdateStateResult

func (*StatestoreSubscriberUpdateStateResult) GetSuccess 

func (p *StatestoreSubscriberUpdateStateResult) GetSuccess() *TUpdateStateResponse

func (*StatestoreSubscriberUpdateStateResult) IsSetSuccess 

func (p *StatestoreSubscriberUpdateStateResult) IsSetSuccess() bool

func (*StatestoreSubscriberUpdateStateResult) Read 

func (p *StatestoreSubscriberUpdateStateResult) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*StatestoreSubscriberUpdateStateResult) ReadField0 

func (p *StatestoreSubscriberUpdateStateResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*StatestoreSubscriberUpdateStateResult) String 

func (p *StatestoreSubscriberUpdateStateResult) String() string

func (*StatestoreSubscriberUpdateStateResult) Write 

func (p *StatestoreSubscriberUpdateStateResult) Write(ctx context.Context, oprot thrift.TProtocol) error

type THeartbeatRequest 

type THeartbeatRequest struct {
	RegistrationID *types.TUniqueId `thrift:"registration_id,1" db:"registration_id" json:"registration_id,omitempty"`
}

Attributes:

  • RegistrationID
var StatestoreSubscriberHeartbeatArgs_Params_DEFAULT *THeartbeatRequest

func NewTHeartbeatRequest 

func NewTHeartbeatRequest() *THeartbeatRequest

func (*THeartbeatRequest) Equals 

func (p *THeartbeatRequest) Equals(other *THeartbeatRequest) bool

func (*THeartbeatRequest) GetRegistrationID 

func (p *THeartbeatRequest) GetRegistrationID() *types.TUniqueId

func (*THeartbeatRequest) IsSetRegistrationID 

func (p *THeartbeatRequest) IsSetRegistrationID() bool

func (*THeartbeatRequest) Read 

func (p *THeartbeatRequest) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THeartbeatRequest) ReadField1 

func (p *THeartbeatRequest) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*THeartbeatRequest) String 

func (p *THeartbeatRequest) String() string

func (*THeartbeatRequest) Write 

func (p *THeartbeatRequest) Write(ctx context.Context, oprot thrift.TProtocol) error

type THeartbeatResponse 

type THeartbeatResponse struct {
}
var StatestoreSubscriberHeartbeatResult_Success_DEFAULT *THeartbeatResponse

func NewTHeartbeatResponse 

func NewTHeartbeatResponse() *THeartbeatResponse

func (*THeartbeatResponse) Equals 

func (p *THeartbeatResponse) Equals(other *THeartbeatResponse) bool

func (*THeartbeatResponse) Read 

func (p *THeartbeatResponse) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THeartbeatResponse) String 

func (p *THeartbeatResponse) String() string

func (*THeartbeatResponse) Write 

func (p *THeartbeatResponse) Write(ctx context.Context, oprot thrift.TProtocol) error

type THeavyMemoryQuery 

type THeavyMemoryQuery struct {
	MemoryConsumed int64            `thrift:"memory_consumed,1,required" db:"memory_consumed" json:"memory_consumed"`
	QueryId        *types.TUniqueId `thrift:"queryId,2,required" db:"queryId" json:"queryId"`
}

Attributes:

  • MemoryConsumed
  • QueryId

func NewTHeavyMemoryQuery 

func NewTHeavyMemoryQuery() *THeavyMemoryQuery

func (*THeavyMemoryQuery) Equals 

func (p *THeavyMemoryQuery) Equals(other *THeavyMemoryQuery) bool

func (*THeavyMemoryQuery) GetMemoryConsumed 

func (p *THeavyMemoryQuery) GetMemoryConsumed() int64

func (*THeavyMemoryQuery) GetQueryId 

func (p *THeavyMemoryQuery) GetQueryId() *types.TUniqueId

func (*THeavyMemoryQuery) IsSetQueryId 

func (p *THeavyMemoryQuery) IsSetQueryId() bool

func (*THeavyMemoryQuery) Read 

func (p *THeavyMemoryQuery) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THeavyMemoryQuery) ReadField1 

func (p *THeavyMemoryQuery) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*THeavyMemoryQuery) ReadField2 

func (p *THeavyMemoryQuery) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*THeavyMemoryQuery) String 

func (p *THeavyMemoryQuery) String() string

func (*THeavyMemoryQuery) Write 

func (p *THeavyMemoryQuery) Write(ctx context.Context, oprot thrift.TProtocol) error

type THostStats 

type THostStats struct {
	MemReserved int64 `thrift:"mem_reserved,1,required" db:"mem_reserved" json:"mem_reserved"`
	MemAdmitted int64 `thrift:"mem_admitted,2,required" db:"mem_admitted" json:"mem_admitted"`
	NumAdmitted int64 `thrift:"num_admitted,3,required" db:"num_admitted" json:"num_admitted"`
	SlotsInUse  int64 `thrift:"slots_in_use,4,required" db:"slots_in_use" json:"slots_in_use"`
}

Attributes:

  • MemReserved
  • MemAdmitted
  • NumAdmitted
  • SlotsInUse
var TPerHostStatsUpdateElement_Stats_DEFAULT *THostStats

func NewTHostStats 

func NewTHostStats() *THostStats

func (*THostStats) Equals 

func (p *THostStats) Equals(other *THostStats) bool

func (*THostStats) GetMemAdmitted 

func (p *THostStats) GetMemAdmitted() int64

func (*THostStats) GetMemReserved 

func (p *THostStats) GetMemReserved() int64

func (*THostStats) GetNumAdmitted 

func (p *THostStats) GetNumAdmitted() int64

func (*THostStats) GetSlotsInUse 

func (p *THostStats) GetSlotsInUse() int64

func (*THostStats) Read 

func (p *THostStats) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THostStats) ReadField1 

func (p *THostStats) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*THostStats) ReadField2 

func (p *THostStats) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*THostStats) ReadField3 

func (p *THostStats) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*THostStats) ReadField4 

func (p *THostStats) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*THostStats) String 

func (p *THostStats) String() string

func (*THostStats) Write 

func (p *THostStats) Write(ctx context.Context, oprot thrift.TProtocol) error

type TPerHostStatsUpdate 

type TPerHostStatsUpdate struct {
	PerHostStats []*TPerHostStatsUpdateElement `thrift:"per_host_stats,1,required" db:"per_host_stats" json:"per_host_stats"`
}

Attributes:

  • PerHostStats

func NewTPerHostStatsUpdate 

func NewTPerHostStatsUpdate() *TPerHostStatsUpdate

func (*TPerHostStatsUpdate) Equals 

func (p *TPerHostStatsUpdate) Equals(other *TPerHostStatsUpdate) bool

func (*TPerHostStatsUpdate) GetPerHostStats 

func (p *TPerHostStatsUpdate) GetPerHostStats() []*TPerHostStatsUpdateElement

func (*TPerHostStatsUpdate) Read 

func (p *TPerHostStatsUpdate) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TPerHostStatsUpdate) ReadField1 

func (p *TPerHostStatsUpdate) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TPerHostStatsUpdate) String 

func (p *TPerHostStatsUpdate) String() string

func (*TPerHostStatsUpdate) Write 

func (p *TPerHostStatsUpdate) Write(ctx context.Context, oprot thrift.TProtocol) error

type TPerHostStatsUpdateElement 

type TPerHostStatsUpdateElement struct {
	HostAddr string      `thrift:"host_addr,1,required" db:"host_addr" json:"host_addr"`
	Stats    *THostStats `thrift:"stats,2,required" db:"stats" json:"stats"`
}

Attributes:

  • HostAddr
  • Stats

func NewTPerHostStatsUpdateElement 

func NewTPerHostStatsUpdateElement() *TPerHostStatsUpdateElement

func (*TPerHostStatsUpdateElement) Equals 

func (p *TPerHostStatsUpdateElement) Equals(other *TPerHostStatsUpdateElement) bool

func (*TPerHostStatsUpdateElement) GetHostAddr 

func (p *TPerHostStatsUpdateElement) GetHostAddr() string

func (*TPerHostStatsUpdateElement) GetStats 

func (p *TPerHostStatsUpdateElement) GetStats() *THostStats

func (*TPerHostStatsUpdateElement) IsSetStats 

func (p *TPerHostStatsUpdateElement) IsSetStats() bool

func (*TPerHostStatsUpdateElement) Read 

func (p *TPerHostStatsUpdateElement) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TPerHostStatsUpdateElement) ReadField1 

func (p *TPerHostStatsUpdateElement) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TPerHostStatsUpdateElement) ReadField2 

func (p *TPerHostStatsUpdateElement) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TPerHostStatsUpdateElement) String 

func (p *TPerHostStatsUpdateElement) String() string

func (*TPerHostStatsUpdateElement) Write 

func (p *TPerHostStatsUpdateElement) Write(ctx context.Context, oprot thrift.TProtocol) error

type TPoolStats 

type TPoolStats struct {
	NumAdmittedRunning  int64                `thrift:"num_admitted_running,1,required" db:"num_admitted_running" json:"num_admitted_running"`
	NumQueued           int64                `thrift:"num_queued,2,required" db:"num_queued" json:"num_queued"`
	BackendMemReserved  int64                `thrift:"backend_mem_reserved,3,required" db:"backend_mem_reserved" json:"backend_mem_reserved"`
	HeavyMemoryQueries  []*THeavyMemoryQuery `thrift:"heavy_memory_queries,4,required" db:"heavy_memory_queries" json:"heavy_memory_queries"`
	MinMemoryConsumed   int64                `thrift:"min_memory_consumed,5,required" db:"min_memory_consumed" json:"min_memory_consumed"`
	MaxMemoryConsumed   int64                `thrift:"max_memory_consumed,6,required" db:"max_memory_consumed" json:"max_memory_consumed"`
	TotalMemoryConsumed int64                `thrift:"total_memory_consumed,7,required" db:"total_memory_consumed" json:"total_memory_consumed"`
	NumRunning          int64                `thrift:"num_running,8,required" db:"num_running" json:"num_running"`
}

Attributes:

  • NumAdmittedRunning
  • NumQueued
  • BackendMemReserved
  • HeavyMemoryQueries
  • MinMemoryConsumed
  • MaxMemoryConsumed
  • TotalMemoryConsumed
  • NumRunning

func NewTPoolStats 

func NewTPoolStats() *TPoolStats

func (*TPoolStats) Equals 

func (p *TPoolStats) Equals(other *TPoolStats) bool

func (*TPoolStats) GetBackendMemReserved 

func (p *TPoolStats) GetBackendMemReserved() int64

func (*TPoolStats) GetHeavyMemoryQueries 

func (p *TPoolStats) GetHeavyMemoryQueries() []*THeavyMemoryQuery

func (*TPoolStats) GetMaxMemoryConsumed 

func (p *TPoolStats) GetMaxMemoryConsumed() int64

func (*TPoolStats) GetMinMemoryConsumed 

func (p *TPoolStats) GetMinMemoryConsumed() int64

func (*TPoolStats) GetNumAdmittedRunning 

func (p *TPoolStats) GetNumAdmittedRunning() int64

func (*TPoolStats) GetNumQueued 

func (p *TPoolStats) GetNumQueued() int64

func (*TPoolStats) GetNumRunning 

func (p *TPoolStats) GetNumRunning() int64

func (*TPoolStats) GetTotalMemoryConsumed 

func (p *TPoolStats) GetTotalMemoryConsumed() int64

func (*TPoolStats) Read 

func (p *TPoolStats) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TPoolStats) ReadField1 

func (p *TPoolStats) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TPoolStats) ReadField2 

func (p *TPoolStats) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TPoolStats) ReadField3 

func (p *TPoolStats) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TPoolStats) ReadField4 

func (p *TPoolStats) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TPoolStats) ReadField5 

func (p *TPoolStats) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TPoolStats) ReadField6 

func (p *TPoolStats) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TPoolStats) ReadField7 

func (p *TPoolStats) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TPoolStats) ReadField8 

func (p *TPoolStats) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*TPoolStats) String 

func (p *TPoolStats) String() string

func (*TPoolStats) Write 

func (p *TPoolStats) Write(ctx context.Context, oprot thrift.TProtocol) error

type TRegisterSubscriberRequest 

type TRegisterSubscriberRequest struct {
	ProtocolVersion    StatestoreServiceVersion `thrift:"protocol_version,1,required" db:"protocol_version" json:"protocol_version"`
	SubscriberID       string                   `thrift:"subscriber_id,2,required" db:"subscriber_id" json:"subscriber_id"`
	SubscriberLocation *types.TNetworkAddress   `thrift:"subscriber_location,3,required" db:"subscriber_location" json:"subscriber_location"`
	TopicRegistrations []*TTopicRegistration    `thrift:"topic_registrations,4,required" db:"topic_registrations" json:"topic_registrations"`
}

Attributes:

  • ProtocolVersion
  • SubscriberID
  • SubscriberLocation
  • TopicRegistrations
var StatestoreServiceRegisterSubscriberArgs_Params_DEFAULT *TRegisterSubscriberRequest

func NewTRegisterSubscriberRequest 

func NewTRegisterSubscriberRequest() *TRegisterSubscriberRequest

func (*TRegisterSubscriberRequest) Equals 

func (p *TRegisterSubscriberRequest) Equals(other *TRegisterSubscriberRequest) bool

func (*TRegisterSubscriberRequest) GetProtocolVersion 

func (p *TRegisterSubscriberRequest) GetProtocolVersion() StatestoreServiceVersion

func (*TRegisterSubscriberRequest) GetSubscriberID 

func (p *TRegisterSubscriberRequest) GetSubscriberID() string

func (*TRegisterSubscriberRequest) GetSubscriberLocation 

func (p *TRegisterSubscriberRequest) GetSubscriberLocation() *types.TNetworkAddress

func (*TRegisterSubscriberRequest) GetTopicRegistrations 

func (p *TRegisterSubscriberRequest) GetTopicRegistrations() []*TTopicRegistration

func (*TRegisterSubscriberRequest) IsSetSubscriberLocation 

func (p *TRegisterSubscriberRequest) IsSetSubscriberLocation() bool

func (*TRegisterSubscriberRequest) Read 

func (p *TRegisterSubscriberRequest) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TRegisterSubscriberRequest) ReadField1 

func (p *TRegisterSubscriberRequest) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TRegisterSubscriberRequest) ReadField2 

func (p *TRegisterSubscriberRequest) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TRegisterSubscriberRequest) ReadField3 

func (p *TRegisterSubscriberRequest) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TRegisterSubscriberRequest) ReadField4 

func (p *TRegisterSubscriberRequest) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TRegisterSubscriberRequest) String 

func (p *TRegisterSubscriberRequest) String() string

func (*TRegisterSubscriberRequest) Write 

func (p *TRegisterSubscriberRequest) Write(ctx context.Context, oprot thrift.TProtocol) error

type TRegisterSubscriberResponse 

type TRegisterSubscriberResponse struct {
	Status         *status.TStatus  `thrift:"status,1,required" db:"status" json:"status"`
	RegistrationID *types.TUniqueId `thrift:"registration_id,2" db:"registration_id" json:"registration_id,omitempty"`
}

Attributes:

  • Status
  • RegistrationID
var StatestoreServiceRegisterSubscriberResult_Success_DEFAULT *TRegisterSubscriberResponse

func NewTRegisterSubscriberResponse 

func NewTRegisterSubscriberResponse() *TRegisterSubscriberResponse

func (*TRegisterSubscriberResponse) Equals 

func (p *TRegisterSubscriberResponse) Equals(other *TRegisterSubscriberResponse) bool

func (*TRegisterSubscriberResponse) GetRegistrationID 

func (p *TRegisterSubscriberResponse) GetRegistrationID() *types.TUniqueId

func (*TRegisterSubscriberResponse) GetStatus 

func (p *TRegisterSubscriberResponse) GetStatus() *status.TStatus

func (*TRegisterSubscriberResponse) IsSetRegistrationID 

func (p *TRegisterSubscriberResponse) IsSetRegistrationID() bool

func (*TRegisterSubscriberResponse) IsSetStatus 

func (p *TRegisterSubscriberResponse) IsSetStatus() bool

func (*TRegisterSubscriberResponse) Read 

func (p *TRegisterSubscriberResponse) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TRegisterSubscriberResponse) ReadField1 

func (p *TRegisterSubscriberResponse) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TRegisterSubscriberResponse) ReadField2 

func (p *TRegisterSubscriberResponse) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TRegisterSubscriberResponse) String 

func (p *TRegisterSubscriberResponse) String() string

func (*TRegisterSubscriberResponse) Write 

func (p *TRegisterSubscriberResponse) Write(ctx context.Context, oprot thrift.TProtocol) error

type TTopicDelta 

type TTopicDelta struct {
	TopicName                 string        `thrift:"topic_name,1,required" db:"topic_name" json:"topic_name"`
	TopicEntries              []*TTopicItem `thrift:"topic_entries,2,required" db:"topic_entries" json:"topic_entries"`
	IsDelta                   bool          `thrift:"is_delta,3,required" db:"is_delta" json:"is_delta"`
	FromVersion               *int64        `thrift:"from_version,4" db:"from_version" json:"from_version,omitempty"`
	ToVersion                 *int64        `thrift:"to_version,5" db:"to_version" json:"to_version,omitempty"`
	MinSubscriberTopicVersion *int64        `thrift:"min_subscriber_topic_version,6" db:"min_subscriber_topic_version" json:"min_subscriber_topic_version,omitempty"`
	ClearTopicEntries         *bool         `thrift:"clear_topic_entries,7" db:"clear_topic_entries" json:"clear_topic_entries,omitempty"`
}

Attributes:

  • TopicName
  • TopicEntries
  • IsDelta
  • FromVersion
  • ToVersion
  • MinSubscriberTopicVersion
  • ClearTopicEntries

func NewTTopicDelta 

func NewTTopicDelta() *TTopicDelta

func (*TTopicDelta) Equals 

func (p *TTopicDelta) Equals(other *TTopicDelta) bool

func (*TTopicDelta) GetClearTopicEntries 

func (p *TTopicDelta) GetClearTopicEntries() bool

func (*TTopicDelta) GetFromVersion 

func (p *TTopicDelta) GetFromVersion() int64

func (*TTopicDelta) GetIsDelta 

func (p *TTopicDelta) GetIsDelta() bool

func (*TTopicDelta) GetMinSubscriberTopicVersion 

func (p *TTopicDelta) GetMinSubscriberTopicVersion() int64

func (*TTopicDelta) GetToVersion 

func (p *TTopicDelta) GetToVersion() int64

func (*TTopicDelta) GetTopicEntries 

func (p *TTopicDelta) GetTopicEntries() []*TTopicItem

func (*TTopicDelta) GetTopicName 

func (p *TTopicDelta) GetTopicName() string

func (*TTopicDelta) IsSetClearTopicEntries 

func (p *TTopicDelta) IsSetClearTopicEntries() bool

func (*TTopicDelta) IsSetFromVersion 

func (p *TTopicDelta) IsSetFromVersion() bool

func (*TTopicDelta) IsSetMinSubscriberTopicVersion 

func (p *TTopicDelta) IsSetMinSubscriberTopicVersion() bool

func (*TTopicDelta) IsSetToVersion 

func (p *TTopicDelta) IsSetToVersion() bool

func (*TTopicDelta) Read 

func (p *TTopicDelta) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TTopicDelta) ReadField1 

func (p *TTopicDelta) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TTopicDelta) ReadField2 

func (p *TTopicDelta) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TTopicDelta) ReadField3 

func (p *TTopicDelta) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TTopicDelta) ReadField4 

func (p *TTopicDelta) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TTopicDelta) ReadField5 

func (p *TTopicDelta) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TTopicDelta) ReadField6 

func (p *TTopicDelta) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TTopicDelta) ReadField7 

func (p *TTopicDelta) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TTopicDelta) String 

func (p *TTopicDelta) String() string

func (*TTopicDelta) Write 

func (p *TTopicDelta) Write(ctx context.Context, oprot thrift.TProtocol) error

type TTopicItem 

type TTopicItem struct {
	Key     string `thrift:"key,1,required" db:"key" json:"key"`
	Value   string `thrift:"value,2,required" db:"value" json:"value"`
	Deleted bool   `thrift:"deleted,3,required" db:"deleted" json:"deleted"`
}

Attributes:

  • Key
  • Value
  • Deleted

func NewTTopicItem 

func NewTTopicItem() *TTopicItem

func (*TTopicItem) Equals 

func (p *TTopicItem) Equals(other *TTopicItem) bool

func (*TTopicItem) GetDeleted 

func (p *TTopicItem) GetDeleted() bool

func (*TTopicItem) GetKey 

func (p *TTopicItem) GetKey() string

func (*TTopicItem) GetValue 

func (p *TTopicItem) GetValue() string

func (*TTopicItem) Read 

func (p *TTopicItem) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TTopicItem) ReadField1 

func (p *TTopicItem) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TTopicItem) ReadField2 

func (p *TTopicItem) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TTopicItem) ReadField3 

func (p *TTopicItem) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TTopicItem) String 

func (p *TTopicItem) String() string

func (*TTopicItem) Write 

func (p *TTopicItem) Write(ctx context.Context, oprot thrift.TProtocol) error

type TTopicRegistration 

type TTopicRegistration struct {
	TopicName                         string  `thrift:"topic_name,1,required" db:"topic_name" json:"topic_name"`
	IsTransient                       bool    `thrift:"is_transient,2,required" db:"is_transient" json:"is_transient"`
	PopulateMinSubscriberTopicVersion bool    `` /* 145-byte string literal not displayed */
	FilterPrefix                      *string `thrift:"filter_prefix,4" db:"filter_prefix" json:"filter_prefix,omitempty"`
}

Attributes:

  • TopicName
  • IsTransient
  • PopulateMinSubscriberTopicVersion
  • FilterPrefix

func NewTTopicRegistration 

func NewTTopicRegistration() *TTopicRegistration

func (*TTopicRegistration) Equals 

func (p *TTopicRegistration) Equals(other *TTopicRegistration) bool

func (*TTopicRegistration) GetFilterPrefix 

func (p *TTopicRegistration) GetFilterPrefix() string

func (*TTopicRegistration) GetIsTransient 

func (p *TTopicRegistration) GetIsTransient() bool

func (*TTopicRegistration) GetPopulateMinSubscriberTopicVersion 

func (p *TTopicRegistration) GetPopulateMinSubscriberTopicVersion() bool

func (*TTopicRegistration) GetTopicName 

func (p *TTopicRegistration) GetTopicName() string

func (*TTopicRegistration) IsSetFilterPrefix 

func (p *TTopicRegistration) IsSetFilterPrefix() bool

func (*TTopicRegistration) Read 

func (p *TTopicRegistration) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TTopicRegistration) ReadField1 

func (p *TTopicRegistration) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TTopicRegistration) ReadField2 

func (p *TTopicRegistration) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TTopicRegistration) ReadField3 

func (p *TTopicRegistration) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TTopicRegistration) ReadField4 

func (p *TTopicRegistration) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TTopicRegistration) String 

func (p *TTopicRegistration) String() string

func (*TTopicRegistration) Write 

func (p *TTopicRegistration) Write(ctx context.Context, oprot thrift.TProtocol) error

type TUpdateStateRequest 

type TUpdateStateRequest struct {
	ProtocolVersion StatestoreServiceVersion `thrift:"protocol_version,1,required" db:"protocol_version" json:"protocol_version"`
	TopicDeltas     map[string]*TTopicDelta  `thrift:"topic_deltas,2,required" db:"topic_deltas" json:"topic_deltas"`
	RegistrationID  *types.TUniqueId         `thrift:"registration_id,3" db:"registration_id" json:"registration_id,omitempty"`
}

Attributes:

  • ProtocolVersion
  • TopicDeltas
  • RegistrationID
var StatestoreSubscriberUpdateStateArgs_Params_DEFAULT *TUpdateStateRequest

func NewTUpdateStateRequest 

func NewTUpdateStateRequest() *TUpdateStateRequest

func (*TUpdateStateRequest) Equals 

func (p *TUpdateStateRequest) Equals(other *TUpdateStateRequest) bool

func (*TUpdateStateRequest) GetProtocolVersion 

func (p *TUpdateStateRequest) GetProtocolVersion() StatestoreServiceVersion

func (*TUpdateStateRequest) GetRegistrationID 

func (p *TUpdateStateRequest) GetRegistrationID() *types.TUniqueId

func (*TUpdateStateRequest) GetTopicDeltas 

func (p *TUpdateStateRequest) GetTopicDeltas() map[string]*TTopicDelta

func (*TUpdateStateRequest) IsSetRegistrationID 

func (p *TUpdateStateRequest) IsSetRegistrationID() bool

func (*TUpdateStateRequest) Read 

func (p *TUpdateStateRequest) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TUpdateStateRequest) ReadField1 

func (p *TUpdateStateRequest) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TUpdateStateRequest) ReadField2 

func (p *TUpdateStateRequest) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TUpdateStateRequest) ReadField3 

func (p *TUpdateStateRequest) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TUpdateStateRequest) String 

func (p *TUpdateStateRequest) String() string

func (*TUpdateStateRequest) Write 

func (p *TUpdateStateRequest) Write(ctx context.Context, oprot thrift.TProtocol) error

type TUpdateStateResponse 

type TUpdateStateResponse struct {
	Status       *status.TStatus `thrift:"status,1,required" db:"status" json:"status"`
	TopicUpdates []*TTopicDelta  `thrift:"topic_updates,2,required" db:"topic_updates" json:"topic_updates"`
	Skipped      *bool           `thrift:"skipped,3" db:"skipped" json:"skipped,omitempty"`
}

Attributes:

  • Status
  • TopicUpdates
  • Skipped
var StatestoreSubscriberUpdateStateResult_Success_DEFAULT *TUpdateStateResponse

func NewTUpdateStateResponse 

func NewTUpdateStateResponse() *TUpdateStateResponse

func (*TUpdateStateResponse) Equals 

func (p *TUpdateStateResponse) Equals(other *TUpdateStateResponse) bool

func (*TUpdateStateResponse) GetSkipped 

func (p *TUpdateStateResponse) GetSkipped() bool

func (*TUpdateStateResponse) GetStatus 

func (p *TUpdateStateResponse) GetStatus() *status.TStatus

func (*TUpdateStateResponse) GetTopicUpdates 

func (p *TUpdateStateResponse) GetTopicUpdates() []*TTopicDelta

func (*TUpdateStateResponse) IsSetSkipped 

func (p *TUpdateStateResponse) IsSetSkipped() bool

func (*TUpdateStateResponse) IsSetStatus 

func (p *TUpdateStateResponse) IsSetStatus() bool

func (*TUpdateStateResponse) Read 

func (p *TUpdateStateResponse) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TUpdateStateResponse) ReadField1 

func (p *TUpdateStateResponse) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TUpdateStateResponse) ReadField2 

func (p *TUpdateStateResponse) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TUpdateStateResponse) ReadField3 

func (p *TUpdateStateResponse) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TUpdateStateResponse) String 

func (p *TUpdateStateResponse) String() string

func (*TUpdateStateResponse) Write 

func (p *TUpdateStateResponse) Write(ctx context.Context, oprot thrift.TProtocol) error

Source Files

View all Source files

Directories

Path Synopsis

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.