clustermsgs

package
v0.1.6 Latest Latest
Warning

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

 Go to latest Published: Aug 16, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_squareup_cash_pranadb_clustermsgs_v1_clustermsgs_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ClusterForwardWriteRequest 

type ClusterForwardWriteRequest struct {
	ShardId     int64  `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	RequestBody []byte `protobuf:"bytes,2,opt,name=request_body,json=requestBody,proto3" json:"request_body,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterForwardWriteRequest) Descriptor deprecated 

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

Deprecated: Use ClusterForwardWriteRequest.ProtoReflect.Descriptor instead.

func (*ClusterForwardWriteRequest) GetRequestBody 

func (x *ClusterForwardWriteRequest) GetRequestBody() []byte

func (*ClusterForwardWriteRequest) GetShardId 

func (x *ClusterForwardWriteRequest) GetShardId() int64

func (*ClusterForwardWriteRequest) ProtoMessage 

func (*ClusterForwardWriteRequest) ProtoMessage()

func (*ClusterForwardWriteRequest) ProtoReflect 

func (x *ClusterForwardWriteRequest) ProtoReflect() protoreflect.Message

func (*ClusterForwardWriteRequest) Reset 

func (x *ClusterForwardWriteRequest) Reset()

func (*ClusterForwardWriteRequest) String 

func (x *ClusterForwardWriteRequest) String() string

type ClusterForwardWriteResponse 

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

func (*ClusterForwardWriteResponse) Descriptor deprecated 

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

Deprecated: Use ClusterForwardWriteResponse.ProtoReflect.Descriptor instead.

func (*ClusterForwardWriteResponse) ProtoMessage 

func (*ClusterForwardWriteResponse) ProtoMessage()

func (*ClusterForwardWriteResponse) ProtoReflect 

func (x *ClusterForwardWriteResponse) ProtoReflect() protoreflect.Message

func (*ClusterForwardWriteResponse) Reset 

func (x *ClusterForwardWriteResponse) Reset()

func (*ClusterForwardWriteResponse) String 

func (x *ClusterForwardWriteResponse) String() string

type ClusterProposeRequest 

type ClusterProposeRequest struct {
	ShardId     int64  `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	RequestBody []byte `protobuf:"bytes,2,opt,name=request_body,json=requestBody,proto3" json:"request_body,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterProposeRequest) Descriptor deprecated 

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

Deprecated: Use ClusterProposeRequest.ProtoReflect.Descriptor instead.

func (*ClusterProposeRequest) GetRequestBody 

func (x *ClusterProposeRequest) GetRequestBody() []byte

func (*ClusterProposeRequest) GetShardId 

func (x *ClusterProposeRequest) GetShardId() int64

func (*ClusterProposeRequest) ProtoMessage 

func (*ClusterProposeRequest) ProtoMessage()

func (*ClusterProposeRequest) ProtoReflect 

func (x *ClusterProposeRequest) ProtoReflect() protoreflect.Message

func (*ClusterProposeRequest) Reset 

func (x *ClusterProposeRequest) Reset()

func (*ClusterProposeRequest) String 

func (x *ClusterProposeRequest) String() string

type ClusterProposeResponse 

type ClusterProposeResponse struct {
	RetVal       int64  `protobuf:"varint,1,opt,name=ret_val,json=retVal,proto3" json:"ret_val,omitempty"`
	ResponseBody []byte `protobuf:"bytes,2,opt,name=response_body,json=responseBody,proto3" json:"response_body,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterProposeResponse) Descriptor deprecated 

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

Deprecated: Use ClusterProposeResponse.ProtoReflect.Descriptor instead.

func (*ClusterProposeResponse) GetResponseBody 

func (x *ClusterProposeResponse) GetResponseBody() []byte

func (*ClusterProposeResponse) GetRetVal 

func (x *ClusterProposeResponse) GetRetVal() int64

func (*ClusterProposeResponse) ProtoMessage 

func (*ClusterProposeResponse) ProtoMessage()

func (*ClusterProposeResponse) ProtoReflect 

func (x *ClusterProposeResponse) ProtoReflect() protoreflect.Message

func (*ClusterProposeResponse) Reset 

func (x *ClusterProposeResponse) Reset()

func (*ClusterProposeResponse) String 

func (x *ClusterProposeResponse) String() string

type ClusterReadRequest 

type ClusterReadRequest struct {
	ShardId     int64  `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	RequestBody []byte `protobuf:"bytes,2,opt,name=request_body,json=requestBody,proto3" json:"request_body,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterReadRequest) Descriptor deprecated 

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

Deprecated: Use ClusterReadRequest.ProtoReflect.Descriptor instead.

func (*ClusterReadRequest) GetRequestBody 

func (x *ClusterReadRequest) GetRequestBody() []byte

func (*ClusterReadRequest) GetShardId 

func (x *ClusterReadRequest) GetShardId() int64

func (*ClusterReadRequest) ProtoMessage 

func (*ClusterReadRequest) ProtoMessage()

func (*ClusterReadRequest) ProtoReflect 

func (x *ClusterReadRequest) ProtoReflect() protoreflect.Message

func (*ClusterReadRequest) Reset 

func (x *ClusterReadRequest) Reset()

func (*ClusterReadRequest) String 

func (x *ClusterReadRequest) String() string

type ClusterReadResponse 

type ClusterReadResponse struct {
	ResponseBody []byte `protobuf:"bytes,1,opt,name=response_body,json=responseBody,proto3" json:"response_body,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterReadResponse) Descriptor deprecated 

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

Deprecated: Use ClusterReadResponse.ProtoReflect.Descriptor instead.

func (*ClusterReadResponse) GetResponseBody 

func (x *ClusterReadResponse) GetResponseBody() []byte

func (*ClusterReadResponse) ProtoMessage 

func (*ClusterReadResponse) ProtoMessage()

func (*ClusterReadResponse) ProtoReflect 

func (x *ClusterReadResponse) ProtoReflect() protoreflect.Message

func (*ClusterReadResponse) Reset 

func (x *ClusterReadResponse) Reset()

func (*ClusterReadResponse) String 

func (x *ClusterReadResponse) String() string

type DDLCancelMessage 

type DDLCancelMessage struct {
	SchemaName string `protobuf:"bytes,1,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	// contains filtered or unexported fields
}

func (*DDLCancelMessage) Descriptor deprecated 

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

Deprecated: Use DDLCancelMessage.ProtoReflect.Descriptor instead.

func (*DDLCancelMessage) GetSchemaName 

func (x *DDLCancelMessage) GetSchemaName() string

func (*DDLCancelMessage) ProtoMessage 

func (*DDLCancelMessage) ProtoMessage()

func (*DDLCancelMessage) ProtoReflect 

func (x *DDLCancelMessage) ProtoReflect() protoreflect.Message

func (*DDLCancelMessage) Reset 

func (x *DDLCancelMessage) Reset()

func (*DDLCancelMessage) String 

func (x *DDLCancelMessage) String() string

type DDLStatementInfo 

type DDLStatementInfo struct {
	OriginatingNodeId int64    `protobuf:"varint,1,opt,name=originating_node_id,json=originatingNodeId,proto3" json:"originating_node_id,omitempty"`
	CommandId         int64    `protobuf:"varint,2,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
	Phase             int32    `protobuf:"varint,3,opt,name=phase,proto3" json:"phase,omitempty"`
	CommandType       int32    `protobuf:"varint,4,opt,name=command_type,json=commandType,proto3" json:"command_type,omitempty"`
	SchemaName        string   `protobuf:"bytes,5,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	Sql               string   `protobuf:"bytes,6,opt,name=sql,proto3" json:"sql,omitempty"`
	TableSequences    []uint64 `protobuf:"varint,7,rep,packed,name=table_sequences,json=tableSequences,proto3" json:"table_sequences,omitempty"`
	ExtraData         []byte   `protobuf:"bytes,8,opt,name=extra_data,json=extraData,proto3" json:"extra_data,omitempty"`
	// contains filtered or unexported fields
}

func (*DDLStatementInfo) Descriptor deprecated 

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

Deprecated: Use DDLStatementInfo.ProtoReflect.Descriptor instead.

func (*DDLStatementInfo) GetCommandId 

func (x *DDLStatementInfo) GetCommandId() int64

func (*DDLStatementInfo) GetCommandType 

func (x *DDLStatementInfo) GetCommandType() int32

func (*DDLStatementInfo) GetExtraData 

func (x *DDLStatementInfo) GetExtraData() []byte

func (*DDLStatementInfo) GetOriginatingNodeId 

func (x *DDLStatementInfo) GetOriginatingNodeId() int64

func (*DDLStatementInfo) GetPhase 

func (x *DDLStatementInfo) GetPhase() int32

func (*DDLStatementInfo) GetSchemaName 

func (x *DDLStatementInfo) GetSchemaName() string

func (*DDLStatementInfo) GetSql 

func (x *DDLStatementInfo) GetSql() string

func (*DDLStatementInfo) GetTableSequences 

func (x *DDLStatementInfo) GetTableSequences() []uint64

func (*DDLStatementInfo) ProtoMessage 

func (*DDLStatementInfo) ProtoMessage()

func (*DDLStatementInfo) ProtoReflect 

func (x *DDLStatementInfo) ProtoReflect() protoreflect.Message

func (*DDLStatementInfo) Reset 

func (x *DDLStatementInfo) Reset()

func (*DDLStatementInfo) String 

func (x *DDLStatementInfo) String() string

type LeaderInfo 

type LeaderInfo struct {
	ShardId int64 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	NodeId  int64 `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

func (*LeaderInfo) Descriptor deprecated 

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

Deprecated: Use LeaderInfo.ProtoReflect.Descriptor instead.

func (*LeaderInfo) GetNodeId 

func (x *LeaderInfo) GetNodeId() int64

func (*LeaderInfo) GetShardId 

func (x *LeaderInfo) GetShardId() int64

func (*LeaderInfo) ProtoMessage 

func (*LeaderInfo) ProtoMessage()

func (*LeaderInfo) ProtoReflect 

func (x *LeaderInfo) ProtoReflect() protoreflect.Message

func (*LeaderInfo) Reset 

func (x *LeaderInfo) Reset()

func (*LeaderInfo) String 

func (x *LeaderInfo) String() string

type LeaderInfosMessage 

type LeaderInfosMessage struct {
	LeaderInfos []*LeaderInfo `protobuf:"bytes,1,rep,name=leader_infos,json=leaderInfos,proto3" json:"leader_infos,omitempty"`
	// contains filtered or unexported fields
}

func (*LeaderInfosMessage) Descriptor deprecated 

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

Deprecated: Use LeaderInfosMessage.ProtoReflect.Descriptor instead.

func (*LeaderInfosMessage) GetLeaderInfos 

func (x *LeaderInfosMessage) GetLeaderInfos() []*LeaderInfo

func (*LeaderInfosMessage) ProtoMessage 

func (*LeaderInfosMessage) ProtoMessage()

func (*LeaderInfosMessage) ProtoReflect 

func (x *LeaderInfosMessage) ProtoReflect() protoreflect.Message

func (*LeaderInfosMessage) Reset 

func (x *LeaderInfosMessage) Reset()

func (*LeaderInfosMessage) String 

func (x *LeaderInfosMessage) String() string

type ReloadProtobuf 

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

func (*ReloadProtobuf) Descriptor deprecated 

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

Deprecated: Use ReloadProtobuf.ProtoReflect.Descriptor instead.

func (*ReloadProtobuf) ProtoMessage 

func (*ReloadProtobuf) ProtoMessage()

func (*ReloadProtobuf) ProtoReflect 

func (x *ReloadProtobuf) ProtoReflect() protoreflect.Message

func (*ReloadProtobuf) Reset 

func (x *ReloadProtobuf) Reset()

func (*ReloadProtobuf) String 

func (x *ReloadProtobuf) String() string

type RemotingTestMessage 

type RemotingTestMessage struct {
	SomeField string `protobuf:"bytes,1,opt,name=some_field,json=someField,proto3" json:"some_field,omitempty"`
	// contains filtered or unexported fields
}

func (*RemotingTestMessage) Descriptor deprecated 

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

Deprecated: Use RemotingTestMessage.ProtoReflect.Descriptor instead.

func (*RemotingTestMessage) GetSomeField 

func (x *RemotingTestMessage) GetSomeField() string

func (*RemotingTestMessage) ProtoMessage 

func (*RemotingTestMessage) ProtoMessage()

func (*RemotingTestMessage) ProtoReflect 

func (x *RemotingTestMessage) ProtoReflect() protoreflect.Message

func (*RemotingTestMessage) Reset 

func (x *RemotingTestMessage) Reset()

func (*RemotingTestMessage) String 

func (x *RemotingTestMessage) String() string

type SourceSetMaxIngestRate 

type SourceSetMaxIngestRate struct {
	SchemaName string `protobuf:"bytes,1,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	SourceName string `protobuf:"bytes,2,opt,name=source_name,json=sourceName,proto3" json:"source_name,omitempty"`
	Rate       int64  `protobuf:"varint,3,opt,name=rate,proto3" json:"rate,omitempty"`
	// contains filtered or unexported fields
}

func (*SourceSetMaxIngestRate) Descriptor deprecated 

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

Deprecated: Use SourceSetMaxIngestRate.ProtoReflect.Descriptor instead.

func (*SourceSetMaxIngestRate) GetRate 

func (x *SourceSetMaxIngestRate) GetRate() int64

func (*SourceSetMaxIngestRate) GetSchemaName 

func (x *SourceSetMaxIngestRate) GetSchemaName() string

func (*SourceSetMaxIngestRate) GetSourceName 

func (x *SourceSetMaxIngestRate) GetSourceName() string

func (*SourceSetMaxIngestRate) ProtoMessage 

func (*SourceSetMaxIngestRate) ProtoMessage()

func (*SourceSetMaxIngestRate) ProtoReflect 

func (x *SourceSetMaxIngestRate) ProtoReflect() protoreflect.Message

func (*SourceSetMaxIngestRate) Reset 

func (x *SourceSetMaxIngestRate) Reset()

func (*SourceSetMaxIngestRate) String 

func (x *SourceSetMaxIngestRate) String() string

Source Files

View all Source files

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.