Versions in this module Expand all Collapse all v0 v0.16.1 Sep 22, 2022 Changes in this version + var GoUnusedProtection__ int + var THeartbeatRequest_RegistrationID_DEFAULT *types.TUniqueId + var THeavyMemoryQuery_QueryId_DEFAULT *types.TUniqueId + var TRegisterSubscriberRequest_SubscriberLocation_DEFAULT *types.TNetworkAddress + var TRegisterSubscriberResponse_RegistrationID_DEFAULT *types.TUniqueId + var TRegisterSubscriberResponse_Status_DEFAULT *status.TStatus + var TTopicDelta_ClearTopicEntries_DEFAULT bool + var TTopicDelta_FromVersion_DEFAULT int64 + var TTopicDelta_MinSubscriberTopicVersion_DEFAULT int64 + var TTopicDelta_ToVersion_DEFAULT int64 + var TTopicRegistration_FilterPrefix_DEFAULT string + var TUpdateStateRequest_RegistrationID_DEFAULT *types.TUniqueId + var TUpdateStateResponse_Skipped_DEFAULT bool + var TUpdateStateResponse_Status_DEFAULT *status.TStatus + type StatestoreService interface + RegisterSubscriber func(ctx context.Context, params *TRegisterSubscriberRequest) (_r *TRegisterSubscriberResponse, _err error) + type StatestoreServiceClient struct + func NewStatestoreServiceClient(c thrift.TClient) *StatestoreServiceClient + func NewStatestoreServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *StatestoreServiceClient + func NewStatestoreServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *StatestoreServiceClient + func (p *StatestoreServiceClient) Client_() thrift.TClient + func (p *StatestoreServiceClient) LastResponseMeta_() thrift.ResponseMeta + func (p *StatestoreServiceClient) RegisterSubscriber(ctx context.Context, params *TRegisterSubscriberRequest) (_r *TRegisterSubscriberResponse, _err error) + func (p *StatestoreServiceClient) SetLastResponseMeta_(meta thrift.ResponseMeta) + type StatestoreServiceProcessor struct + func NewStatestoreServiceProcessor(handler StatestoreService) *StatestoreServiceProcessor + func (p *StatestoreServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction) + func (p *StatestoreServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool) + func (p *StatestoreServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) + func (p *StatestoreServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction + type StatestoreServiceRegisterSubscriberArgs struct + Params *TRegisterSubscriberRequest + func NewStatestoreServiceRegisterSubscriberArgs() *StatestoreServiceRegisterSubscriberArgs + func (p *StatestoreServiceRegisterSubscriberArgs) GetParams() *TRegisterSubscriberRequest + func (p *StatestoreServiceRegisterSubscriberArgs) IsSetParams() bool + func (p *StatestoreServiceRegisterSubscriberArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *StatestoreServiceRegisterSubscriberArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *StatestoreServiceRegisterSubscriberArgs) String() string + func (p *StatestoreServiceRegisterSubscriberArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type StatestoreServiceRegisterSubscriberResult struct + Success *TRegisterSubscriberResponse + func NewStatestoreServiceRegisterSubscriberResult() *StatestoreServiceRegisterSubscriberResult + func (p *StatestoreServiceRegisterSubscriberResult) GetSuccess() *TRegisterSubscriberResponse + func (p *StatestoreServiceRegisterSubscriberResult) IsSetSuccess() bool + func (p *StatestoreServiceRegisterSubscriberResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *StatestoreServiceRegisterSubscriberResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *StatestoreServiceRegisterSubscriberResult) String() string + func (p *StatestoreServiceRegisterSubscriberResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type StatestoreServiceVersion int64 + const StatestoreServiceVersion_V1 + func StatestoreServiceVersionFromString(s string) (StatestoreServiceVersion, error) + func StatestoreServiceVersionPtr(v StatestoreServiceVersion) *StatestoreServiceVersion + func (p *StatestoreServiceVersion) Scan(value interface{}) error + func (p *StatestoreServiceVersion) UnmarshalText(text []byte) error + func (p *StatestoreServiceVersion) Value() (driver.Value, error) + func (p StatestoreServiceVersion) MarshalText() ([]byte, error) + func (p StatestoreServiceVersion) String() string + type StatestoreSubscriber interface + Heartbeat func(ctx context.Context, params *THeartbeatRequest) (_r *THeartbeatResponse, _err error) + UpdateState func(ctx context.Context, params *TUpdateStateRequest) (_r *TUpdateStateResponse, _err error) + type StatestoreSubscriberClient struct + func NewStatestoreSubscriberClient(c thrift.TClient) *StatestoreSubscriberClient + func NewStatestoreSubscriberClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *StatestoreSubscriberClient + func NewStatestoreSubscriberClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *StatestoreSubscriberClient + func (p *StatestoreSubscriberClient) Client_() thrift.TClient + func (p *StatestoreSubscriberClient) Heartbeat(ctx context.Context, params *THeartbeatRequest) (_r *THeartbeatResponse, _err error) + func (p *StatestoreSubscriberClient) LastResponseMeta_() thrift.ResponseMeta + func (p *StatestoreSubscriberClient) SetLastResponseMeta_(meta thrift.ResponseMeta) + func (p *StatestoreSubscriberClient) UpdateState(ctx context.Context, params *TUpdateStateRequest) (_r *TUpdateStateResponse, _err error) + type StatestoreSubscriberHeartbeatArgs struct + Params *THeartbeatRequest + func NewStatestoreSubscriberHeartbeatArgs() *StatestoreSubscriberHeartbeatArgs + func (p *StatestoreSubscriberHeartbeatArgs) GetParams() *THeartbeatRequest + func (p *StatestoreSubscriberHeartbeatArgs) IsSetParams() bool + func (p *StatestoreSubscriberHeartbeatArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *StatestoreSubscriberHeartbeatArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *StatestoreSubscriberHeartbeatArgs) String() string + func (p *StatestoreSubscriberHeartbeatArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type StatestoreSubscriberHeartbeatResult struct + Success *THeartbeatResponse + func NewStatestoreSubscriberHeartbeatResult() *StatestoreSubscriberHeartbeatResult + func (p *StatestoreSubscriberHeartbeatResult) GetSuccess() *THeartbeatResponse + func (p *StatestoreSubscriberHeartbeatResult) IsSetSuccess() bool + func (p *StatestoreSubscriberHeartbeatResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *StatestoreSubscriberHeartbeatResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *StatestoreSubscriberHeartbeatResult) String() string + func (p *StatestoreSubscriberHeartbeatResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type StatestoreSubscriberProcessor struct + func NewStatestoreSubscriberProcessor(handler StatestoreSubscriber) *StatestoreSubscriberProcessor + func (p *StatestoreSubscriberProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction) + func (p *StatestoreSubscriberProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool) + func (p *StatestoreSubscriberProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) + func (p *StatestoreSubscriberProcessor) ProcessorMap() map[string]thrift.TProcessorFunction + type StatestoreSubscriberUpdateStateArgs struct + Params *TUpdateStateRequest + func NewStatestoreSubscriberUpdateStateArgs() *StatestoreSubscriberUpdateStateArgs + func (p *StatestoreSubscriberUpdateStateArgs) GetParams() *TUpdateStateRequest + func (p *StatestoreSubscriberUpdateStateArgs) IsSetParams() bool + func (p *StatestoreSubscriberUpdateStateArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *StatestoreSubscriberUpdateStateArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *StatestoreSubscriberUpdateStateArgs) String() string + func (p *StatestoreSubscriberUpdateStateArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type StatestoreSubscriberUpdateStateResult struct + Success *TUpdateStateResponse + func NewStatestoreSubscriberUpdateStateResult() *StatestoreSubscriberUpdateStateResult + func (p *StatestoreSubscriberUpdateStateResult) GetSuccess() *TUpdateStateResponse + func (p *StatestoreSubscriberUpdateStateResult) IsSetSuccess() bool + func (p *StatestoreSubscriberUpdateStateResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *StatestoreSubscriberUpdateStateResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *StatestoreSubscriberUpdateStateResult) String() string + func (p *StatestoreSubscriberUpdateStateResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type THeartbeatRequest struct + RegistrationID *types.TUniqueId + var StatestoreSubscriberHeartbeatArgs_Params_DEFAULT *THeartbeatRequest + func NewTHeartbeatRequest() *THeartbeatRequest + func (p *THeartbeatRequest) Equals(other *THeartbeatRequest) bool + func (p *THeartbeatRequest) GetRegistrationID() *types.TUniqueId + func (p *THeartbeatRequest) IsSetRegistrationID() bool + func (p *THeartbeatRequest) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *THeartbeatRequest) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *THeartbeatRequest) String() string + func (p *THeartbeatRequest) Write(ctx context.Context, oprot thrift.TProtocol) error + type THeartbeatResponse struct + var StatestoreSubscriberHeartbeatResult_Success_DEFAULT *THeartbeatResponse + func NewTHeartbeatResponse() *THeartbeatResponse + func (p *THeartbeatResponse) Equals(other *THeartbeatResponse) bool + func (p *THeartbeatResponse) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *THeartbeatResponse) String() string + func (p *THeartbeatResponse) Write(ctx context.Context, oprot thrift.TProtocol) error + type THeavyMemoryQuery struct + MemoryConsumed int64 + QueryId *types.TUniqueId + func NewTHeavyMemoryQuery() *THeavyMemoryQuery + func (p *THeavyMemoryQuery) Equals(other *THeavyMemoryQuery) bool + func (p *THeavyMemoryQuery) GetMemoryConsumed() int64 + func (p *THeavyMemoryQuery) GetQueryId() *types.TUniqueId + func (p *THeavyMemoryQuery) IsSetQueryId() bool + func (p *THeavyMemoryQuery) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *THeavyMemoryQuery) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *THeavyMemoryQuery) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *THeavyMemoryQuery) String() string + func (p *THeavyMemoryQuery) Write(ctx context.Context, oprot thrift.TProtocol) error + type THostStats struct + MemAdmitted int64 + MemReserved int64 + NumAdmitted int64 + SlotsInUse int64 + var TPerHostStatsUpdateElement_Stats_DEFAULT *THostStats + func NewTHostStats() *THostStats + func (p *THostStats) Equals(other *THostStats) bool + func (p *THostStats) GetMemAdmitted() int64 + func (p *THostStats) GetMemReserved() int64 + func (p *THostStats) GetNumAdmitted() int64 + func (p *THostStats) GetSlotsInUse() int64 + func (p *THostStats) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *THostStats) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *THostStats) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *THostStats) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *THostStats) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *THostStats) String() string + func (p *THostStats) Write(ctx context.Context, oprot thrift.TProtocol) error + type TPerHostStatsUpdate struct + PerHostStats []*TPerHostStatsUpdateElement + func NewTPerHostStatsUpdate() *TPerHostStatsUpdate + func (p *TPerHostStatsUpdate) Equals(other *TPerHostStatsUpdate) bool + func (p *TPerHostStatsUpdate) GetPerHostStats() []*TPerHostStatsUpdateElement + func (p *TPerHostStatsUpdate) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPerHostStatsUpdate) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPerHostStatsUpdate) String() string + func (p *TPerHostStatsUpdate) Write(ctx context.Context, oprot thrift.TProtocol) error + type TPerHostStatsUpdateElement struct + HostAddr string + Stats *THostStats + func NewTPerHostStatsUpdateElement() *TPerHostStatsUpdateElement + func (p *TPerHostStatsUpdateElement) Equals(other *TPerHostStatsUpdateElement) bool + func (p *TPerHostStatsUpdateElement) GetHostAddr() string + func (p *TPerHostStatsUpdateElement) GetStats() *THostStats + func (p *TPerHostStatsUpdateElement) IsSetStats() bool + func (p *TPerHostStatsUpdateElement) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPerHostStatsUpdateElement) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPerHostStatsUpdateElement) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPerHostStatsUpdateElement) String() string + func (p *TPerHostStatsUpdateElement) Write(ctx context.Context, oprot thrift.TProtocol) error + type TPoolStats struct + BackendMemReserved int64 + HeavyMemoryQueries []*THeavyMemoryQuery + MaxMemoryConsumed int64 + MinMemoryConsumed int64 + NumAdmittedRunning int64 + NumQueued int64 + NumRunning int64 + TotalMemoryConsumed int64 + func NewTPoolStats() *TPoolStats + func (p *TPoolStats) Equals(other *TPoolStats) bool + func (p *TPoolStats) GetBackendMemReserved() int64 + func (p *TPoolStats) GetHeavyMemoryQueries() []*THeavyMemoryQuery + func (p *TPoolStats) GetMaxMemoryConsumed() int64 + func (p *TPoolStats) GetMinMemoryConsumed() int64 + func (p *TPoolStats) GetNumAdmittedRunning() int64 + func (p *TPoolStats) GetNumQueued() int64 + func (p *TPoolStats) GetNumRunning() int64 + func (p *TPoolStats) GetTotalMemoryConsumed() int64 + func (p *TPoolStats) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPoolStats) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPoolStats) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPoolStats) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPoolStats) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPoolStats) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPoolStats) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPoolStats) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPoolStats) ReadField8(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPoolStats) String() string + func (p *TPoolStats) Write(ctx context.Context, oprot thrift.TProtocol) error + type TRegisterSubscriberRequest struct + ProtocolVersion StatestoreServiceVersion + SubscriberID string + SubscriberLocation *types.TNetworkAddress + TopicRegistrations []*TTopicRegistration + var StatestoreServiceRegisterSubscriberArgs_Params_DEFAULT *TRegisterSubscriberRequest + func NewTRegisterSubscriberRequest() *TRegisterSubscriberRequest + func (p *TRegisterSubscriberRequest) Equals(other *TRegisterSubscriberRequest) bool + func (p *TRegisterSubscriberRequest) GetProtocolVersion() StatestoreServiceVersion + func (p *TRegisterSubscriberRequest) GetSubscriberID() string + func (p *TRegisterSubscriberRequest) GetSubscriberLocation() *types.TNetworkAddress + func (p *TRegisterSubscriberRequest) GetTopicRegistrations() []*TTopicRegistration + func (p *TRegisterSubscriberRequest) IsSetSubscriberLocation() bool + func (p *TRegisterSubscriberRequest) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRegisterSubscriberRequest) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRegisterSubscriberRequest) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRegisterSubscriberRequest) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRegisterSubscriberRequest) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRegisterSubscriberRequest) String() string + func (p *TRegisterSubscriberRequest) Write(ctx context.Context, oprot thrift.TProtocol) error + type TRegisterSubscriberResponse struct + RegistrationID *types.TUniqueId + Status *status.TStatus + var StatestoreServiceRegisterSubscriberResult_Success_DEFAULT *TRegisterSubscriberResponse + func NewTRegisterSubscriberResponse() *TRegisterSubscriberResponse + func (p *TRegisterSubscriberResponse) Equals(other *TRegisterSubscriberResponse) bool + func (p *TRegisterSubscriberResponse) GetRegistrationID() *types.TUniqueId + func (p *TRegisterSubscriberResponse) GetStatus() *status.TStatus + func (p *TRegisterSubscriberResponse) IsSetRegistrationID() bool + func (p *TRegisterSubscriberResponse) IsSetStatus() bool + func (p *TRegisterSubscriberResponse) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRegisterSubscriberResponse) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRegisterSubscriberResponse) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRegisterSubscriberResponse) String() string + func (p *TRegisterSubscriberResponse) Write(ctx context.Context, oprot thrift.TProtocol) error + type TTopicDelta struct + ClearTopicEntries *bool + FromVersion *int64 + IsDelta bool + MinSubscriberTopicVersion *int64 + ToVersion *int64 + TopicEntries []*TTopicItem + TopicName string + func NewTTopicDelta() *TTopicDelta + func (p *TTopicDelta) Equals(other *TTopicDelta) bool + func (p *TTopicDelta) GetClearTopicEntries() bool + func (p *TTopicDelta) GetFromVersion() int64 + func (p *TTopicDelta) GetIsDelta() bool + func (p *TTopicDelta) GetMinSubscriberTopicVersion() int64 + func (p *TTopicDelta) GetToVersion() int64 + func (p *TTopicDelta) GetTopicEntries() []*TTopicItem + func (p *TTopicDelta) GetTopicName() string + func (p *TTopicDelta) IsSetClearTopicEntries() bool + func (p *TTopicDelta) IsSetFromVersion() bool + func (p *TTopicDelta) IsSetMinSubscriberTopicVersion() bool + func (p *TTopicDelta) IsSetToVersion() bool + func (p *TTopicDelta) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTopicDelta) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTopicDelta) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTopicDelta) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTopicDelta) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTopicDelta) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTopicDelta) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTopicDelta) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTopicDelta) String() string + func (p *TTopicDelta) Write(ctx context.Context, oprot thrift.TProtocol) error + type TTopicItem struct + Deleted bool + Key string + Value string + func NewTTopicItem() *TTopicItem + func (p *TTopicItem) Equals(other *TTopicItem) bool + func (p *TTopicItem) GetDeleted() bool + func (p *TTopicItem) GetKey() string + func (p *TTopicItem) GetValue() string + func (p *TTopicItem) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTopicItem) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTopicItem) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTopicItem) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTopicItem) String() string + func (p *TTopicItem) Write(ctx context.Context, oprot thrift.TProtocol) error + type TTopicRegistration struct + FilterPrefix *string + IsTransient bool + PopulateMinSubscriberTopicVersion bool + TopicName string + func NewTTopicRegistration() *TTopicRegistration + func (p *TTopicRegistration) Equals(other *TTopicRegistration) bool + func (p *TTopicRegistration) GetFilterPrefix() string + func (p *TTopicRegistration) GetIsTransient() bool + func (p *TTopicRegistration) GetPopulateMinSubscriberTopicVersion() bool + func (p *TTopicRegistration) GetTopicName() string + func (p *TTopicRegistration) IsSetFilterPrefix() bool + func (p *TTopicRegistration) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTopicRegistration) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTopicRegistration) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTopicRegistration) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTopicRegistration) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTopicRegistration) String() string + func (p *TTopicRegistration) Write(ctx context.Context, oprot thrift.TProtocol) error + type TUpdateStateRequest struct + ProtocolVersion StatestoreServiceVersion + RegistrationID *types.TUniqueId + TopicDeltas map[string]*TTopicDelta + var StatestoreSubscriberUpdateStateArgs_Params_DEFAULT *TUpdateStateRequest + func NewTUpdateStateRequest() *TUpdateStateRequest + func (p *TUpdateStateRequest) Equals(other *TUpdateStateRequest) bool + func (p *TUpdateStateRequest) GetProtocolVersion() StatestoreServiceVersion + func (p *TUpdateStateRequest) GetRegistrationID() *types.TUniqueId + func (p *TUpdateStateRequest) GetTopicDeltas() map[string]*TTopicDelta + func (p *TUpdateStateRequest) IsSetRegistrationID() bool + func (p *TUpdateStateRequest) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TUpdateStateRequest) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TUpdateStateRequest) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TUpdateStateRequest) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TUpdateStateRequest) String() string + func (p *TUpdateStateRequest) Write(ctx context.Context, oprot thrift.TProtocol) error + type TUpdateStateResponse struct + Skipped *bool + Status *status.TStatus + TopicUpdates []*TTopicDelta + var StatestoreSubscriberUpdateStateResult_Success_DEFAULT *TUpdateStateResponse + func NewTUpdateStateResponse() *TUpdateStateResponse + func (p *TUpdateStateResponse) Equals(other *TUpdateStateResponse) bool + func (p *TUpdateStateResponse) GetSkipped() bool + func (p *TUpdateStateResponse) GetStatus() *status.TStatus + func (p *TUpdateStateResponse) GetTopicUpdates() []*TTopicDelta + func (p *TUpdateStateResponse) IsSetSkipped() bool + func (p *TUpdateStateResponse) IsSetStatus() bool + func (p *TUpdateStateResponse) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TUpdateStateResponse) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TUpdateStateResponse) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TUpdateStateResponse) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TUpdateStateResponse) String() string + func (p *TUpdateStateResponse) Write(ctx context.Context, oprot thrift.TProtocol) error