server

package
v0.3.2 Latest Latest
Warning

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

 Go to latest Published: May 31, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	SpecialOffset_name = map[int32]string{
		0: "EARLIEST",
		1: "LATEST",
	}
	SpecialOffset_value = map[string]int32{
		"EARLIEST": 0,
		"LATEST":   1,
	}
)

Enum value maps for SpecialOffset.

View Source 
var (
	CompressionType_name = map[int32]string{
		0: "None",
		1: "Gzip",
		2: "Zstd",
	}
	CompressionType_value = map[string]int32{
		"None": 0,
		"Gzip": 1,
		"Zstd": 2,
	}
)

Enum value maps for CompressionType.

View Source 
var (
	TaskStatusPB_name = map[int32]string{
		0: "TASK_CREATING",
		1: "TASK_RUNNING",
		2: "TASK_ABORTED",
		3: "TASK_PAUSED",
		4: "TASK_RESUMING",
		5: "TASK_TERMINATED",
		6: "TASK_UNKNOWN",
	}
	TaskStatusPB_value = map[string]int32{
		"TASK_CREATING":   0,
		"TASK_RUNNING":    1,
		"TASK_ABORTED":    2,
		"TASK_PAUSED":     3,
		"TASK_RESUMING":   4,
		"TASK_TERMINATED": 5,
		"TASK_UNKNOWN":    6,
	}
)

Enum value maps for TaskStatusPB.

View Source 
var (
	QueryType_name = map[int32]string{
		0: "CreateStreamAs",
		1: "CreateViewAs",
	}
	QueryType_value = map[string]int32{
		"CreateStreamAs": 0,
		"CreateViewAs":   1,
	}
)

Enum value maps for QueryType.

View Source 
var (
	NodeState_name = map[int32]string{
		0: "Starting",
		1: "Running",
		2: "Unavailable",
		3: "Dead",
	}
	NodeState_value = map[string]int32{
		"Starting":    0,
		"Running":     1,
		"Unavailable": 2,
		"Dead":        3,
	}
)

Enum value maps for NodeState.

View Source 
var (
	ResourceType_name = map[int32]string{
		0: "ResStream",
		1: "ResSubscription",
		2: "ResShard",
		3: "ResShardReader",
		4: "ResConnector",
		5: "ResQuery",
		6: "ResView",
	}
	ResourceType_value = map[string]int32{
		"ResStream":       0,
		"ResSubscription": 1,
		"ResShard":        2,
		"ResShardReader":  3,
		"ResConnector":    4,
		"ResQuery":        5,
		"ResView":         6,
	}
)

Enum value maps for ResourceType.

View Source 
var (
	StreamStats_name = map[int32]string{
		0: "AppendInBytes",
		1: "AppendInRecords",
		2: "AppendTotal",
		3: "AppendFailed",
	}
	StreamStats_value = map[string]int32{
		"AppendInBytes":   0,
		"AppendInRecords": 1,
		"AppendTotal":     2,
		"AppendFailed":    3,
	}
)

Enum value maps for StreamStats.

View Source 
var (
	SubscriptionStats_name = map[int32]string{
		0: "SendOutBytes",
		1: "SendOutRecords",
		2: "SendOutRecordsFailed",
		3: "ResendRecords",
		4: "ResendRecordsFailed",
		5: "ReceivedAcks",
		6: "RequestMessages",
		7: "ResponseMessages",
	}
	SubscriptionStats_value = map[string]int32{
		"SendOutBytes":         0,
		"SendOutRecords":       1,
		"SendOutRecordsFailed": 2,
		"ResendRecords":        3,
		"ResendRecordsFailed":  4,
		"ReceivedAcks":         5,
		"RequestMessages":      6,
		"ResponseMessages":     7,
	}
)

Enum value maps for SubscriptionStats.

View Source 
var (
	ConnectorStats_name = map[int32]string{
		0: "DeliveredInRecords",
		1: "DeliveredInBytes",
	}
	ConnectorStats_value = map[string]int32{
		"DeliveredInRecords": 0,
		"DeliveredInBytes":   1,
	}
)

Enum value maps for ConnectorStats.

View Source 
var (
	QueryStats_name = map[int32]string{
		0: "TotalInputRecords",
		1: "TotalOutputRecords",
		2: "TotalExecuteErrors",
	}
	QueryStats_value = map[string]int32{
		"TotalInputRecords":  0,
		"TotalOutputRecords": 1,
		"TotalExecuteErrors": 2,
	}
)

Enum value maps for QueryStats.

View Source 
var (
	ViewStats_name = map[int32]string{
		0: "TotalExecuteQueries",
	}
	ViewStats_value = map[string]int32{
		"TotalExecuteQueries": 0,
	}
)

Enum value maps for ViewStats.

View Source 
var (
	ErrorCode_name = map[int32]string{
		0:   "InternalError",
		200: "StreamNotFound",
		201: "StreamExists",
		202: "StreamFoundSubscription",
		203: "StreamInvalidReplicaFactor",
		204: "StreamInvalidObjectIdentifier",
		205: "StreamInvalidShardCount",
		206: "StreamEmptyBatchedRecord",
		207: "StreamInvalidRecordSize",
		300: "SubscriptionNotFound",
		301: "SubscriptionExists",
		302: "SubscriptionCreationOnNonExistentStream",
		303: "SubscriptionInvalidOffset",
		304: "SubscriptionInvalidObjectIdentifier",
		305: "SubscriptionFoundActiveConsumers",
		400: "QueryNotFound",
		401: "QueryExists",
		402: "QueryInvalidSQL",
		403: "QueryFoundAssociatedView",
		404: "QueryInvalidObjectIdentifier",
		405: "QueryStillRunning",
		406: "QueryNotRunning",
		407: "QueryNotTerminated",
		408: "QueryAlreadyTerminated",
		500: "ViewNotFound",
		501: "ViewExists",
		502: "ViewInvalidSQL",
		503: "ViewInvalidObjectIdentifier",
		600: "ConnectorNotFound",
		601: "ConnectorExists",
		602: "ConnectorInvalidType",
		603: "ConnectorInvalidObjectIdentifier",
		604: "ConnectorCheckFailed",
		605: "ConnectorUnimplemented",
		606: "ConnectorInvalidStatus",
		800: "WrongServer",
		900: "ShardReaderInvalidObjectIdentifier",
	}
	ErrorCode_value = map[string]int32{
		"InternalError":                           0,
		"StreamNotFound":                          200,
		"StreamExists":                            201,
		"StreamFoundSubscription":                 202,
		"StreamInvalidReplicaFactor":              203,
		"StreamInvalidObjectIdentifier":           204,
		"StreamInvalidShardCount":                 205,
		"StreamEmptyBatchedRecord":                206,
		"StreamInvalidRecordSize":                 207,
		"SubscriptionNotFound":                    300,
		"SubscriptionExists":                      301,
		"SubscriptionCreationOnNonExistentStream": 302,
		"SubscriptionInvalidOffset":               303,
		"SubscriptionInvalidObjectIdentifier":     304,
		"SubscriptionFoundActiveConsumers":        305,
		"QueryNotFound":                           400,
		"QueryExists":                             401,
		"QueryInvalidSQL":                         402,
		"QueryFoundAssociatedView":                403,
		"QueryInvalidObjectIdentifier":            404,
		"QueryStillRunning":                       405,
		"QueryNotRunning":                         406,
		"QueryNotTerminated":                      407,
		"QueryAlreadyTerminated":                  408,
		"ViewNotFound":                            500,
		"ViewExists":                              501,
		"ViewInvalidSQL":                          502,
		"ViewInvalidObjectIdentifier":             503,
		"ConnectorNotFound":                       600,
		"ConnectorExists":                         601,
		"ConnectorInvalidType":                    602,
		"ConnectorInvalidObjectIdentifier":        603,
		"ConnectorCheckFailed":                    604,
		"ConnectorUnimplemented":                  605,
		"ConnectorInvalidStatus":                  606,
		"WrongServer":                             800,
		"ShardReaderInvalidObjectIdentifier":      900,
	}
)

Enum value maps for ErrorCode.

View Source 
var (
	HStreamRecordHeader_Flag_name = map[int32]string{
		0: "JSON",
		1: "RAW",
	}
	HStreamRecordHeader_Flag_value = map[string]int32{
		"JSON": 0,
		"RAW":  1,
	}
)

Enum value maps for HStreamRecordHeader_Flag.

View Source 
var File_hstream_proto protoreflect.FileDescriptor
View Source 
var HStreamApi_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "hstream.server.HStreamApi",
	HandlerType: (*HStreamApiServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Echo",
			Handler:    _HStreamApi_Echo_Handler,
		},
		{
			MethodName: "CreateStream",
			Handler:    _HStreamApi_CreateStream_Handler,
		},
		{
			MethodName: "DeleteStream",
			Handler:    _HStreamApi_DeleteStream_Handler,
		},
		{
			MethodName: "GetStream",
			Handler:    _HStreamApi_GetStream_Handler,
		},
		{
			MethodName: "ListStreams",
			Handler:    _HStreamApi_ListStreams_Handler,
		},
		{
			MethodName: "ListStreamsWithPrefix",
			Handler:    _HStreamApi_ListStreamsWithPrefix_Handler,
		},
		{
			MethodName: "LookupShard",
			Handler:    _HStreamApi_LookupShard_Handler,
		},
		{
			MethodName: "Append",
			Handler:    _HStreamApi_Append_Handler,
		},
		{
			MethodName: "ListShards",
			Handler:    _HStreamApi_ListShards_Handler,
		},
		{
			MethodName: "CreateShardReader",
			Handler:    _HStreamApi_CreateShardReader_Handler,
		},
		{
			MethodName: "LookupShardReader",
			Handler:    _HStreamApi_LookupShardReader_Handler,
		},
		{
			MethodName: "ReadShard",
			Handler:    _HStreamApi_ReadShard_Handler,
		},
		{
			MethodName: "ListShardReaders",
			Handler:    _HStreamApi_ListShardReaders_Handler,
		},
		{
			MethodName: "DeleteShardReader",
			Handler:    _HStreamApi_DeleteShardReader_Handler,
		},
		{
			MethodName: "CreateSubscription",
			Handler:    _HStreamApi_CreateSubscription_Handler,
		},
		{
			MethodName: "GetSubscription",
			Handler:    _HStreamApi_GetSubscription_Handler,
		},
		{
			MethodName: "ListSubscriptions",
			Handler:    _HStreamApi_ListSubscriptions_Handler,
		},
		{
			MethodName: "ListSubscriptionsWithPrefix",
			Handler:    _HStreamApi_ListSubscriptionsWithPrefix_Handler,
		},
		{
			MethodName: "ListConsumers",
			Handler:    _HStreamApi_ListConsumers_Handler,
		},
		{
			MethodName: "CheckSubscriptionExist",
			Handler:    _HStreamApi_CheckSubscriptionExist_Handler,
		},
		{
			MethodName: "DeleteSubscription",
			Handler:    _HStreamApi_DeleteSubscription_Handler,
		},
		{
			MethodName: "LookupSubscription",
			Handler:    _HStreamApi_LookupSubscription_Handler,
		},
		{
			MethodName: "DescribeCluster",
			Handler:    _HStreamApi_DescribeCluster_Handler,
		},
		{
			MethodName: "LookupResource",
			Handler:    _HStreamApi_LookupResource_Handler,
		},
		{
			MethodName: "SendAdminCommand",
			Handler:    _HStreamApi_SendAdminCommand_Handler,
		},
		{
			MethodName: "PerStreamTimeSeriesStats",
			Handler:    _HStreamApi_PerStreamTimeSeriesStats_Handler,
		},
		{
			MethodName: "PerStreamTimeSeriesStatsAll",
			Handler:    _HStreamApi_PerStreamTimeSeriesStatsAll_Handler,
		},
		{
			MethodName: "GetStats",
			Handler:    _HStreamApi_GetStats_Handler,
		},
		{
			MethodName: "ExecuteQuery",
			Handler:    _HStreamApi_ExecuteQuery_Handler,
		},
		{
			MethodName: "CreateQuery",
			Handler:    _HStreamApi_CreateQuery_Handler,
		},
		{
			MethodName: "CreateQueryWithNamespace",
			Handler:    _HStreamApi_CreateQueryWithNamespace_Handler,
		},
		{
			MethodName: "ListQueries",
			Handler:    _HStreamApi_ListQueries_Handler,
		},
		{
			MethodName: "GetQuery",
			Handler:    _HStreamApi_GetQuery_Handler,
		},
		{
			MethodName: "TerminateQuery",
			Handler:    _HStreamApi_TerminateQuery_Handler,
		},
		{
			MethodName: "DeleteQuery",
			Handler:    _HStreamApi_DeleteQuery_Handler,
		},
		{
			MethodName: "ResumeQuery",
			Handler:    _HStreamApi_ResumeQuery_Handler,
		},
		{
			MethodName: "PauseQuery",
			Handler:    _HStreamApi_PauseQuery_Handler,
		},
		{
			MethodName: "ParseSql",
			Handler:    _HStreamApi_ParseSql_Handler,
		},
		{
			MethodName: "CreateConnector",
			Handler:    _HStreamApi_CreateConnector_Handler,
		},
		{
			MethodName: "ListConnectors",
			Handler:    _HStreamApi_ListConnectors_Handler,
		},
		{
			MethodName: "GetConnector",
			Handler:    _HStreamApi_GetConnector_Handler,
		},
		{
			MethodName: "GetConnectorSpec",
			Handler:    _HStreamApi_GetConnectorSpec_Handler,
		},
		{
			MethodName: "GetConnectorLogs",
			Handler:    _HStreamApi_GetConnectorLogs_Handler,
		},
		{
			MethodName: "DeleteConnector",
			Handler:    _HStreamApi_DeleteConnector_Handler,
		},
		{
			MethodName: "PauseConnector",
			Handler:    _HStreamApi_PauseConnector_Handler,
		},
		{
			MethodName: "ResumeConnector",
			Handler:    _HStreamApi_ResumeConnector_Handler,
		},
		{
			MethodName: "ListViews",
			Handler:    _HStreamApi_ListViews_Handler,
		},
		{
			MethodName: "GetView",
			Handler:    _HStreamApi_GetView_Handler,
		},
		{
			MethodName: "DeleteView",
			Handler:    _HStreamApi_DeleteView_Handler,
		},
		{
			MethodName: "ExecuteViewQuery",
			Handler:    _HStreamApi_ExecuteViewQuery_Handler,
		},
		{
			MethodName: "ExecuteViewQueryWithNamespace",
			Handler:    _HStreamApi_ExecuteViewQueryWithNamespace_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ReadShardStream",
			Handler:       _HStreamApi_ReadShardStream_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamingFetch",
			Handler:       _HStreamApi_StreamingFetch_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "hstream.proto",
}

HStreamApi_ServiceDesc is the grpc.ServiceDesc for HStreamApi service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterHStreamApiServer 

func RegisterHStreamApiServer(s grpc.ServiceRegistrar, srv HStreamApiServer)

Types

type AdminCommandRequest 

type AdminCommandRequest struct {
	Command string `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	// contains filtered or unexported fields
}

func (*AdminCommandRequest) Descriptor deprecated 

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

Deprecated: Use AdminCommandRequest.ProtoReflect.Descriptor instead.

func (*AdminCommandRequest) GetCommand 

func (x *AdminCommandRequest) GetCommand() string

func (*AdminCommandRequest) ProtoMessage 

func (*AdminCommandRequest) ProtoMessage()

func (*AdminCommandRequest) ProtoReflect 

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

func (*AdminCommandRequest) Reset 

func (x *AdminCommandRequest) Reset()

func (*AdminCommandRequest) String 

func (x *AdminCommandRequest) String() string

type AdminCommandResponse 

type AdminCommandResponse struct {
	Result string `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*AdminCommandResponse) Descriptor deprecated 

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

Deprecated: Use AdminCommandResponse.ProtoReflect.Descriptor instead.

func (*AdminCommandResponse) GetResult 

func (x *AdminCommandResponse) GetResult() string

func (*AdminCommandResponse) ProtoMessage 

func (*AdminCommandResponse) ProtoMessage()

func (*AdminCommandResponse) ProtoReflect 

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

func (*AdminCommandResponse) Reset 

func (x *AdminCommandResponse) Reset()

func (*AdminCommandResponse) String 

func (x *AdminCommandResponse) String() string

type AppendRequest 

type AppendRequest struct {
	StreamName string         `protobuf:"bytes,1,opt,name=streamName,proto3" json:"streamName,omitempty"`
	ShardId    uint64         `protobuf:"varint,2,opt,name=shardId,proto3" json:"shardId,omitempty"`
	Records    *BatchedRecord `protobuf:"bytes,3,opt,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendRequest) Descriptor deprecated 

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

Deprecated: Use AppendRequest.ProtoReflect.Descriptor instead.

func (*AppendRequest) GetRecords 

func (x *AppendRequest) GetRecords() *BatchedRecord

func (*AppendRequest) GetShardId added in v0.2.0 

func (x *AppendRequest) GetShardId() uint64

func (*AppendRequest) GetStreamName 

func (x *AppendRequest) GetStreamName() string

func (*AppendRequest) ProtoMessage 

func (*AppendRequest) ProtoMessage()

func (*AppendRequest) ProtoReflect 

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

func (*AppendRequest) Reset 

func (x *AppendRequest) Reset()

func (*AppendRequest) String 

func (x *AppendRequest) String() string

type AppendResponse 

type AppendResponse struct {
	StreamName string      `protobuf:"bytes,1,opt,name=streamName,proto3" json:"streamName,omitempty"`
	ShardId    uint64      `protobuf:"varint,2,opt,name=shardId,proto3" json:"shardId,omitempty"`
	RecordIds  []*RecordId `protobuf:"bytes,3,rep,name=recordIds,proto3" json:"recordIds,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendResponse) Descriptor deprecated 

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

Deprecated: Use AppendResponse.ProtoReflect.Descriptor instead.

func (*AppendResponse) GetRecordIds 

func (x *AppendResponse) GetRecordIds() []*RecordId

func (*AppendResponse) GetShardId added in v0.2.0 

func (x *AppendResponse) GetShardId() uint64

func (*AppendResponse) GetStreamName 

func (x *AppendResponse) GetStreamName() string

func (*AppendResponse) ProtoMessage 

func (*AppendResponse) ProtoMessage()

func (*AppendResponse) ProtoReflect 

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

func (*AppendResponse) Reset 

func (x *AppendResponse) Reset()

func (*AppendResponse) String 

func (x *AppendResponse) String() string

type BatchHStreamRecords added in v0.3.0 

type BatchHStreamRecords struct {
	Records []*HStreamRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

Auxiliary types for serialization HStreamRecord

func (*BatchHStreamRecords) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use BatchHStreamRecords.ProtoReflect.Descriptor instead.

func (*BatchHStreamRecords) GetRecords added in v0.3.0 

func (x *BatchHStreamRecords) GetRecords() []*HStreamRecord

func (*BatchHStreamRecords) ProtoMessage added in v0.3.0 

func (*BatchHStreamRecords) ProtoMessage()

func (*BatchHStreamRecords) ProtoReflect added in v0.3.0 

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

func (*BatchHStreamRecords) Reset added in v0.3.0 

func (x *BatchHStreamRecords) Reset()

func (*BatchHStreamRecords) String added in v0.3.0 

func (x *BatchHStreamRecords) String() string

type BatchedRecord added in v0.3.0 

type BatchedRecord struct {
	CompressionType CompressionType `protobuf:"varint,1,opt,name=compressionType,proto3,enum=hstream.server.CompressionType" json:"compressionType,omitempty"`
	// Required.
	// The time at which the message was published,
	// populated by the server.
	PublishTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=publishTime,proto3" json:"publishTime,omitempty"`
	// Required
	// batchSize records the number of compressed HStreamRecords
	// in the current batch. This field allows the server to build
	// the RecordId correctly without decompression after reading
	// the data from the store.
	BatchSize uint32 `protobuf:"varint,3,opt,name=batchSize,proto3" json:"batchSize,omitempty"`
	Payload   []byte `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"` // serialized BatchHStreamRecords
	// contains filtered or unexported fields
}

func (*BatchedRecord) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use BatchedRecord.ProtoReflect.Descriptor instead.

func (*BatchedRecord) GetBatchSize added in v0.3.0 

func (x *BatchedRecord) GetBatchSize() uint32

func (*BatchedRecord) GetCompressionType added in v0.3.0 

func (x *BatchedRecord) GetCompressionType() CompressionType

func (*BatchedRecord) GetPayload added in v0.3.0 

func (x *BatchedRecord) GetPayload() []byte

func (*BatchedRecord) GetPublishTime added in v0.3.0 

func (x *BatchedRecord) GetPublishTime() *timestamp.Timestamp

func (*BatchedRecord) ProtoMessage added in v0.3.0 

func (*BatchedRecord) ProtoMessage()

func (*BatchedRecord) ProtoReflect added in v0.3.0 

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

func (*BatchedRecord) Reset added in v0.3.0 

func (x *BatchedRecord) Reset()

func (*BatchedRecord) String added in v0.3.0 

func (x *BatchedRecord) String() string

type CheckSubscriptionExistRequest 

type CheckSubscriptionExistRequest struct {
	SubscriptionId string `protobuf:"bytes,1,opt,name=subscriptionId,proto3" json:"subscriptionId,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckSubscriptionExistRequest) Descriptor deprecated 

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

Deprecated: Use CheckSubscriptionExistRequest.ProtoReflect.Descriptor instead.

func (*CheckSubscriptionExistRequest) GetSubscriptionId 

func (x *CheckSubscriptionExistRequest) GetSubscriptionId() string

func (*CheckSubscriptionExistRequest) ProtoMessage 

func (*CheckSubscriptionExistRequest) ProtoMessage()

func (*CheckSubscriptionExistRequest) ProtoReflect 

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

func (*CheckSubscriptionExistRequest) Reset 

func (x *CheckSubscriptionExistRequest) Reset()

func (*CheckSubscriptionExistRequest) String 

func (x *CheckSubscriptionExistRequest) String() string

type CheckSubscriptionExistResponse 

type CheckSubscriptionExistResponse struct {
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckSubscriptionExistResponse) Descriptor deprecated 

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

Deprecated: Use CheckSubscriptionExistResponse.ProtoReflect.Descriptor instead.

func (*CheckSubscriptionExistResponse) GetExists 

func (x *CheckSubscriptionExistResponse) GetExists() bool

func (*CheckSubscriptionExistResponse) ProtoMessage 

func (*CheckSubscriptionExistResponse) ProtoMessage()

func (*CheckSubscriptionExistResponse) ProtoReflect 

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

func (*CheckSubscriptionExistResponse) Reset 

func (x *CheckSubscriptionExistResponse) Reset()

func (*CheckSubscriptionExistResponse) String 

func (x *CheckSubscriptionExistResponse) String() string

type CommandConnect 

type CommandConnect struct {
	ClientVersion   string `protobuf:"bytes,1,opt,name=client_version,json=clientVersion,proto3" json:"client_version,omitempty"`
	ProtocolVersion int32  `protobuf:"varint,2,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandConnect) Descriptor deprecated 

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

Deprecated: Use CommandConnect.ProtoReflect.Descriptor instead.

func (*CommandConnect) GetClientVersion 

func (x *CommandConnect) GetClientVersion() string

func (*CommandConnect) GetProtocolVersion 

func (x *CommandConnect) GetProtocolVersion() int32

func (*CommandConnect) ProtoMessage 

func (*CommandConnect) ProtoMessage()

func (*CommandConnect) ProtoReflect 

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

func (*CommandConnect) Reset 

func (x *CommandConnect) Reset()

func (*CommandConnect) String 

func (x *CommandConnect) String() string

type CommandConnected 

type CommandConnected struct {
	ServerVersion   string `protobuf:"bytes,1,opt,name=server_version,json=serverVersion,proto3" json:"server_version,omitempty"`
	ProtocolVersion int32  `protobuf:"varint,2,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandConnected) Descriptor deprecated 

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

Deprecated: Use CommandConnected.ProtoReflect.Descriptor instead.

func (*CommandConnected) GetProtocolVersion 

func (x *CommandConnected) GetProtocolVersion() int32

func (*CommandConnected) GetServerVersion 

func (x *CommandConnected) GetServerVersion() string

func (*CommandConnected) ProtoMessage 

func (*CommandConnected) ProtoMessage()

func (*CommandConnected) ProtoReflect 

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

func (*CommandConnected) Reset 

func (x *CommandConnected) Reset()

func (*CommandConnected) String 

func (x *CommandConnected) String() string

type CommandQuery 

type CommandQuery struct {
	StmtText string `protobuf:"bytes,1,opt,name=stmt_text,json=stmtText,proto3" json:"stmt_text,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandQuery) Descriptor deprecated 

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

Deprecated: Use CommandQuery.ProtoReflect.Descriptor instead.

func (*CommandQuery) GetStmtText 

func (x *CommandQuery) GetStmtText() string

func (*CommandQuery) ProtoMessage 

func (*CommandQuery) ProtoMessage()

func (*CommandQuery) ProtoReflect 

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

func (*CommandQuery) Reset 

func (x *CommandQuery) Reset()

func (*CommandQuery) String 

func (x *CommandQuery) String() string

type CommandQueryResponse 

type CommandQueryResponse struct {
	ResultSet []*_struct.Struct `protobuf:"bytes,1,rep,name=result_set,json=resultSet,proto3" json:"result_set,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandQueryResponse) Descriptor deprecated 

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

Deprecated: Use CommandQueryResponse.ProtoReflect.Descriptor instead.

func (*CommandQueryResponse) GetResultSet 

func (x *CommandQueryResponse) GetResultSet() []*_struct.Struct

func (*CommandQueryResponse) ProtoMessage 

func (*CommandQueryResponse) ProtoMessage()

func (*CommandQueryResponse) ProtoReflect 

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

func (*CommandQueryResponse) Reset 

func (x *CommandQueryResponse) Reset()

func (*CommandQueryResponse) String 

func (x *CommandQueryResponse) String() string

type CommandStreamTask 

type CommandStreamTask struct {
	CommandSql string `protobuf:"bytes,1,opt,name=command_sql,json=commandSql,proto3" json:"command_sql,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandStreamTask) Descriptor deprecated 

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

Deprecated: Use CommandStreamTask.ProtoReflect.Descriptor instead.

func (*CommandStreamTask) GetCommandSql 

func (x *CommandStreamTask) GetCommandSql() string

func (*CommandStreamTask) ProtoMessage 

func (*CommandStreamTask) ProtoMessage()

func (*CommandStreamTask) ProtoReflect 

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

func (*CommandStreamTask) Reset 

func (x *CommandStreamTask) Reset()

func (*CommandStreamTask) String 

func (x *CommandStreamTask) String() string

type CommandStreamTaskResponse 

type CommandStreamTaskResponse struct {
	CommandResp string `protobuf:"bytes,1,opt,name=command_resp,json=commandResp,proto3" json:"command_resp,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandStreamTaskResponse) Descriptor deprecated 

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

Deprecated: Use CommandStreamTaskResponse.ProtoReflect.Descriptor instead.

func (*CommandStreamTaskResponse) GetCommandResp 

func (x *CommandStreamTaskResponse) GetCommandResp() string

func (*CommandStreamTaskResponse) ProtoMessage 

func (*CommandStreamTaskResponse) ProtoMessage()

func (*CommandStreamTaskResponse) ProtoReflect 

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

func (*CommandStreamTaskResponse) Reset 

func (x *CommandStreamTaskResponse) Reset()

func (*CommandStreamTaskResponse) String 

func (x *CommandStreamTaskResponse) String() string

type CompressionType added in v0.3.0 

type CompressionType int32
const (
	CompressionType_None CompressionType = 0
	CompressionType_Gzip CompressionType = 1
	CompressionType_Zstd CompressionType = 2
)

func (CompressionType) Descriptor added in v0.3.0 

func (CompressionType) Descriptor() protoreflect.EnumDescriptor

func (CompressionType) Enum added in v0.3.0 

func (x CompressionType) Enum() *CompressionType

func (CompressionType) EnumDescriptor deprecated added in v0.3.0 

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

Deprecated: Use CompressionType.Descriptor instead.

func (CompressionType) Number added in v0.3.0 

func (x CompressionType) Number() protoreflect.EnumNumber

func (CompressionType) String added in v0.3.0 

func (x CompressionType) String() string

func (CompressionType) Type added in v0.3.0 

func (CompressionType) Type() protoreflect.EnumType

type Connector 

type Connector struct {
	Name         string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type         string               `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Target       string               `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	CreationTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=creationTime,proto3" json:"creationTime,omitempty"`
	Status       string               `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	// Optional, only available for GetConnector
	Cnofig  string            `protobuf:"bytes,6,opt,name=cnofig,proto3" json:"cnofig,omitempty"`
	Offsets []*_struct.Struct `protobuf:"bytes,7,rep,name=offsets,proto3" json:"offsets,omitempty"`
	// contains filtered or unexported fields
}

func (*Connector) Descriptor deprecated 

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

Deprecated: Use Connector.ProtoReflect.Descriptor instead.

func (*Connector) GetCnofig added in v0.3.2 

func (x *Connector) GetCnofig() string

func (*Connector) GetCreationTime added in v0.3.2 

func (x *Connector) GetCreationTime() *timestamp.Timestamp

func (*Connector) GetName added in v0.1.5 

func (x *Connector) GetName() string

func (*Connector) GetOffsets added in v0.3.2 

func (x *Connector) GetOffsets() []*_struct.Struct

func (*Connector) GetStatus 

func (x *Connector) GetStatus() string

func (*Connector) GetTarget added in v0.3.2 

func (x *Connector) GetTarget() string

func (*Connector) GetType added in v0.3.2 

func (x *Connector) GetType() string

func (*Connector) ProtoMessage 

func (*Connector) ProtoMessage()

func (*Connector) ProtoReflect 

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

func (*Connector) Reset 

func (x *Connector) Reset()

func (*Connector) String 

func (x *Connector) String() string

type ConnectorStats added in v0.3.2 

type ConnectorStats int32
const (
	ConnectorStats_DeliveredInRecords ConnectorStats = 0
	ConnectorStats_DeliveredInBytes   ConnectorStats = 1
)

func (ConnectorStats) Descriptor added in v0.3.2 

func (ConnectorStats) Descriptor() protoreflect.EnumDescriptor

func (ConnectorStats) Enum added in v0.3.2 

func (x ConnectorStats) Enum() *ConnectorStats

func (ConnectorStats) EnumDescriptor deprecated added in v0.3.2 

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

Deprecated: Use ConnectorStats.Descriptor instead.

func (ConnectorStats) Number added in v0.3.2 

func (x ConnectorStats) Number() protoreflect.EnumNumber

func (ConnectorStats) String added in v0.3.2 

func (x ConnectorStats) String() string

func (ConnectorStats) Type added in v0.3.2 

func (ConnectorStats) Type() protoreflect.EnumType

type Consumer added in v0.3.1 

type Consumer struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Uri       string `protobuf:"bytes,2,opt,name=uri,proto3" json:"uri,omitempty"`
	UserAgent string `protobuf:"bytes,3,opt,name=userAgent,proto3" json:"userAgent,omitempty"`
	// contains filtered or unexported fields
}

func (*Consumer) Descriptor deprecated added in v0.3.1 

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

Deprecated: Use Consumer.ProtoReflect.Descriptor instead.

func (*Consumer) GetName added in v0.3.1 

func (x *Consumer) GetName() string

func (*Consumer) GetUri added in v0.3.1 

func (x *Consumer) GetUri() string

func (*Consumer) GetUserAgent added in v0.3.1 

func (x *Consumer) GetUserAgent() string

func (*Consumer) ProtoMessage added in v0.3.1 

func (*Consumer) ProtoMessage()

func (*Consumer) ProtoReflect added in v0.3.1 

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

func (*Consumer) Reset added in v0.3.1 

func (x *Consumer) Reset()

func (*Consumer) String added in v0.3.1 

func (x *Consumer) String() string

type CreateConnectorRequest added in v0.1.5 

type CreateConnectorRequest struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type   string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	Config string `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

Connector Related Request and Response

func (*CreateConnectorRequest) Descriptor deprecated added in v0.1.5 

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

Deprecated: Use CreateConnectorRequest.ProtoReflect.Descriptor instead.

func (*CreateConnectorRequest) GetConfig added in v0.3.2 

func (x *CreateConnectorRequest) GetConfig() string

func (*CreateConnectorRequest) GetName added in v0.3.2 

func (x *CreateConnectorRequest) GetName() string

func (*CreateConnectorRequest) GetTarget added in v0.3.2 

func (x *CreateConnectorRequest) GetTarget() string

func (*CreateConnectorRequest) GetType added in v0.3.2 

func (x *CreateConnectorRequest) GetType() string

func (*CreateConnectorRequest) ProtoMessage added in v0.1.5 

func (*CreateConnectorRequest) ProtoMessage()

func (*CreateConnectorRequest) ProtoReflect added in v0.1.5 

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

func (*CreateConnectorRequest) Reset added in v0.1.5 

func (x *CreateConnectorRequest) Reset()

func (*CreateConnectorRequest) String added in v0.1.5 

func (x *CreateConnectorRequest) String() string

type CreateQueryRequest 

type CreateQueryRequest struct {
	Sql       string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
	QueryName string `protobuf:"bytes,2,opt,name=queryName,proto3" json:"queryName,omitempty"`
	// contains filtered or unexported fields
}

Query realated Request and Response

func (*CreateQueryRequest) Descriptor deprecated 

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

Deprecated: Use CreateQueryRequest.ProtoReflect.Descriptor instead.

func (*CreateQueryRequest) GetQueryName added in v0.3.2 

func (x *CreateQueryRequest) GetQueryName() string

func (*CreateQueryRequest) GetSql added in v0.3.1 

func (x *CreateQueryRequest) GetSql() string

func (*CreateQueryRequest) ProtoMessage 

func (*CreateQueryRequest) ProtoMessage()

func (*CreateQueryRequest) ProtoReflect 

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

func (*CreateQueryRequest) Reset 

func (x *CreateQueryRequest) Reset()

func (*CreateQueryRequest) String 

func (x *CreateQueryRequest) String() string

type CreateQueryWithNamespaceRequest added in v0.3.2 

type CreateQueryWithNamespaceRequest struct {
	Sql       string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
	QueryName string `protobuf:"bytes,2,opt,name=queryName,proto3" json:"queryName,omitempty"`
	Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateQueryWithNamespaceRequest) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use CreateQueryWithNamespaceRequest.ProtoReflect.Descriptor instead.

func (*CreateQueryWithNamespaceRequest) GetNamespace added in v0.3.2 

func (x *CreateQueryWithNamespaceRequest) GetNamespace() string

func (*CreateQueryWithNamespaceRequest) GetQueryName added in v0.3.2 

func (x *CreateQueryWithNamespaceRequest) GetQueryName() string

func (*CreateQueryWithNamespaceRequest) GetSql added in v0.3.2 

func (x *CreateQueryWithNamespaceRequest) GetSql() string

func (*CreateQueryWithNamespaceRequest) ProtoMessage added in v0.3.2 

func (*CreateQueryWithNamespaceRequest) ProtoMessage()

func (*CreateQueryWithNamespaceRequest) ProtoReflect added in v0.3.2 

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

func (*CreateQueryWithNamespaceRequest) Reset added in v0.3.2 

func (x *CreateQueryWithNamespaceRequest) Reset()

func (*CreateQueryWithNamespaceRequest) String added in v0.3.2 

func (x *CreateQueryWithNamespaceRequest) String() string

type CreateShardReaderRequest added in v0.2.0 

type CreateShardReaderRequest struct {
	StreamName  string       `protobuf:"bytes,1,opt,name=streamName,proto3" json:"streamName,omitempty"`
	ShardId     uint64       `protobuf:"varint,2,opt,name=shardId,proto3" json:"shardId,omitempty"`
	ShardOffset *ShardOffset `protobuf:"bytes,3,opt,name=shardOffset,proto3" json:"shardOffset,omitempty"`
	ReaderId    string       `protobuf:"bytes,4,opt,name=readerId,proto3" json:"readerId,omitempty"`
	Timeout     uint32       `protobuf:"varint,5,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateShardReaderRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use CreateShardReaderRequest.ProtoReflect.Descriptor instead.

func (*CreateShardReaderRequest) GetReaderId added in v0.2.0 

func (x *CreateShardReaderRequest) GetReaderId() string

func (*CreateShardReaderRequest) GetShardId added in v0.2.0 

func (x *CreateShardReaderRequest) GetShardId() uint64

func (*CreateShardReaderRequest) GetShardOffset added in v0.2.0 

func (x *CreateShardReaderRequest) GetShardOffset() *ShardOffset

func (*CreateShardReaderRequest) GetStreamName added in v0.2.0 

func (x *CreateShardReaderRequest) GetStreamName() string

func (*CreateShardReaderRequest) GetTimeout added in v0.2.0 

func (x *CreateShardReaderRequest) GetTimeout() uint32

func (*CreateShardReaderRequest) ProtoMessage added in v0.2.0 

func (*CreateShardReaderRequest) ProtoMessage()

func (*CreateShardReaderRequest) ProtoReflect added in v0.2.0 

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

func (*CreateShardReaderRequest) Reset added in v0.2.0 

func (x *CreateShardReaderRequest) Reset()

func (*CreateShardReaderRequest) String added in v0.2.0 

func (x *CreateShardReaderRequest) String() string

type CreateShardReaderResponse added in v0.2.0 

type CreateShardReaderResponse struct {
	StreamName  string       `protobuf:"bytes,1,opt,name=streamName,proto3" json:"streamName,omitempty"`
	ShardId     uint64       `protobuf:"varint,2,opt,name=shardId,proto3" json:"shardId,omitempty"`
	ShardOffset *ShardOffset `protobuf:"bytes,3,opt,name=shardOffset,proto3" json:"shardOffset,omitempty"`
	ReaderId    string       `protobuf:"bytes,4,opt,name=readerId,proto3" json:"readerId,omitempty"`
	Timeout     uint32       `protobuf:"varint,5,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateShardReaderResponse) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use CreateShardReaderResponse.ProtoReflect.Descriptor instead.

func (*CreateShardReaderResponse) GetReaderId added in v0.2.0 

func (x *CreateShardReaderResponse) GetReaderId() string

func (*CreateShardReaderResponse) GetShardId added in v0.2.0 

func (x *CreateShardReaderResponse) GetShardId() uint64

func (*CreateShardReaderResponse) GetShardOffset added in v0.2.0 

func (x *CreateShardReaderResponse) GetShardOffset() *ShardOffset

func (*CreateShardReaderResponse) GetStreamName added in v0.2.0 

func (x *CreateShardReaderResponse) GetStreamName() string

func (*CreateShardReaderResponse) GetTimeout added in v0.2.0 

func (x *CreateShardReaderResponse) GetTimeout() uint32

func (*CreateShardReaderResponse) ProtoMessage added in v0.2.0 

func (*CreateShardReaderResponse) ProtoMessage()

func (*CreateShardReaderResponse) ProtoReflect added in v0.2.0 

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

func (*CreateShardReaderResponse) Reset added in v0.2.0 

func (x *CreateShardReaderResponse) Reset()

func (*CreateShardReaderResponse) String added in v0.2.0 

func (x *CreateShardReaderResponse) String() string

type DeleteConnectorRequest 

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

func (*DeleteConnectorRequest) Descriptor deprecated 

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

Deprecated: Use DeleteConnectorRequest.ProtoReflect.Descriptor instead.

func (*DeleteConnectorRequest) GetName added in v0.1.5 

func (x *DeleteConnectorRequest) GetName() string

func (*DeleteConnectorRequest) ProtoMessage 

func (*DeleteConnectorRequest) ProtoMessage()

func (*DeleteConnectorRequest) ProtoReflect 

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

func (*DeleteConnectorRequest) Reset 

func (x *DeleteConnectorRequest) Reset()

func (*DeleteConnectorRequest) String 

func (x *DeleteConnectorRequest) String() string

type DeleteQueryRequest 

type DeleteQueryRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteQueryRequest) Descriptor deprecated 

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

Deprecated: Use DeleteQueryRequest.ProtoReflect.Descriptor instead.

func (*DeleteQueryRequest) GetId 

func (x *DeleteQueryRequest) GetId() string

func (*DeleteQueryRequest) ProtoMessage 

func (*DeleteQueryRequest) ProtoMessage()

func (*DeleteQueryRequest) ProtoReflect 

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

func (*DeleteQueryRequest) Reset 

func (x *DeleteQueryRequest) Reset()

func (*DeleteQueryRequest) String 

func (x *DeleteQueryRequest) String() string

type DeleteShardReaderRequest added in v0.2.0 

type DeleteShardReaderRequest struct {
	ReaderId string `protobuf:"bytes,1,opt,name=readerId,proto3" json:"readerId,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteShardReaderRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use DeleteShardReaderRequest.ProtoReflect.Descriptor instead.

func (*DeleteShardReaderRequest) GetReaderId added in v0.2.0 

func (x *DeleteShardReaderRequest) GetReaderId() string

func (*DeleteShardReaderRequest) ProtoMessage added in v0.2.0 

func (*DeleteShardReaderRequest) ProtoMessage()

func (*DeleteShardReaderRequest) ProtoReflect added in v0.2.0 

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

func (*DeleteShardReaderRequest) Reset added in v0.2.0 

func (x *DeleteShardReaderRequest) Reset()

func (*DeleteShardReaderRequest) String added in v0.2.0 

func (x *DeleteShardReaderRequest) String() string

type DeleteStreamRequest 

type DeleteStreamRequest struct {
	StreamName     string `protobuf:"bytes,1,opt,name=streamName,proto3" json:"streamName,omitempty"`
	IgnoreNonExist bool   `protobuf:"varint,2,opt,name=ignoreNonExist,proto3" json:"ignoreNonExist,omitempty"`
	Force          bool   `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteStreamRequest) Descriptor deprecated 

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

Deprecated: Use DeleteStreamRequest.ProtoReflect.Descriptor instead.

func (*DeleteStreamRequest) GetForce 

func (x *DeleteStreamRequest) GetForce() bool

func (*DeleteStreamRequest) GetIgnoreNonExist 

func (x *DeleteStreamRequest) GetIgnoreNonExist() bool

func (*DeleteStreamRequest) GetStreamName 

func (x *DeleteStreamRequest) GetStreamName() string

func (*DeleteStreamRequest) ProtoMessage 

func (*DeleteStreamRequest) ProtoMessage()

func (*DeleteStreamRequest) ProtoReflect 

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

func (*DeleteStreamRequest) Reset 

func (x *DeleteStreamRequest) Reset()

func (*DeleteStreamRequest) String 

func (x *DeleteStreamRequest) String() string

type DeleteSubscriptionRequest 

type DeleteSubscriptionRequest struct {
	SubscriptionId string `protobuf:"bytes,1,opt,name=subscriptionId,proto3" json:"subscriptionId,omitempty"`
	Force          bool   `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use DeleteSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*DeleteSubscriptionRequest) GetForce added in v0.1.3 

func (x *DeleteSubscriptionRequest) GetForce() bool

func (*DeleteSubscriptionRequest) GetSubscriptionId 

func (x *DeleteSubscriptionRequest) GetSubscriptionId() string

func (*DeleteSubscriptionRequest) ProtoMessage 

func (*DeleteSubscriptionRequest) ProtoMessage()

func (*DeleteSubscriptionRequest) ProtoReflect 

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

func (*DeleteSubscriptionRequest) Reset 

func (x *DeleteSubscriptionRequest) Reset()

func (*DeleteSubscriptionRequest) String 

func (x *DeleteSubscriptionRequest) String() string

type DeleteViewRequest 

type DeleteViewRequest struct {
	ViewId         string `protobuf:"bytes,1,opt,name=viewId,proto3" json:"viewId,omitempty"`
	IgnoreNonExist bool   `protobuf:"varint,2,opt,name=ignoreNonExist,proto3" json:"ignoreNonExist,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteViewRequest) Descriptor deprecated 

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

Deprecated: Use DeleteViewRequest.ProtoReflect.Descriptor instead.

func (*DeleteViewRequest) GetIgnoreNonExist 

func (x *DeleteViewRequest) GetIgnoreNonExist() bool

func (*DeleteViewRequest) GetViewId 

func (x *DeleteViewRequest) GetViewId() string

func (*DeleteViewRequest) ProtoMessage 

func (*DeleteViewRequest) ProtoMessage()

func (*DeleteViewRequest) ProtoReflect 

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

func (*DeleteViewRequest) Reset 

func (x *DeleteViewRequest) Reset()

func (*DeleteViewRequest) String 

func (x *DeleteViewRequest) String() string

type DescribeClusterResponse 

type DescribeClusterResponse struct {
	ProtocolVersion   string              `protobuf:"bytes,1,opt,name=protocolVersion,proto3" json:"protocolVersion,omitempty"`
	ServerVersion     string              `protobuf:"bytes,2,opt,name=serverVersion,proto3" json:"serverVersion,omitempty"`
	ServerNodes       []*ServerNode       `protobuf:"bytes,3,rep,name=serverNodes,proto3" json:"serverNodes,omitempty"`
	ServerNodesStatus []*ServerNodeStatus `protobuf:"bytes,4,rep,name=serverNodesStatus,proto3" json:"serverNodesStatus,omitempty"`
	ClusterUpTime     uint64              `protobuf:"varint,5,opt,name=clusterUpTime,proto3" json:"clusterUpTime,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeClusterResponse) Descriptor deprecated 

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

Deprecated: Use DescribeClusterResponse.ProtoReflect.Descriptor instead.

func (*DescribeClusterResponse) GetClusterUpTime added in v0.3.0 

func (x *DescribeClusterResponse) GetClusterUpTime() uint64

func (*DescribeClusterResponse) GetProtocolVersion 

func (x *DescribeClusterResponse) GetProtocolVersion() string

func (*DescribeClusterResponse) GetServerNodes 

func (x *DescribeClusterResponse) GetServerNodes() []*ServerNode

func (*DescribeClusterResponse) GetServerNodesStatus added in v0.2.0 

func (x *DescribeClusterResponse) GetServerNodesStatus() []*ServerNodeStatus

func (*DescribeClusterResponse) GetServerVersion 

func (x *DescribeClusterResponse) GetServerVersion() string

func (*DescribeClusterResponse) ProtoMessage 

func (*DescribeClusterResponse) ProtoMessage()

func (*DescribeClusterResponse) ProtoReflect 

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

func (*DescribeClusterResponse) Reset 

func (x *DescribeClusterResponse) Reset()

func (*DescribeClusterResponse) String 

func (x *DescribeClusterResponse) String() string

type EchoRequest 

type EchoRequest struct {
	Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*EchoRequest) Descriptor deprecated 

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

Deprecated: Use EchoRequest.ProtoReflect.Descriptor instead.

func (*EchoRequest) GetMsg 

func (x *EchoRequest) GetMsg() string

func (*EchoRequest) ProtoMessage 

func (*EchoRequest) ProtoMessage()

func (*EchoRequest) ProtoReflect 

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

func (*EchoRequest) Reset 

func (x *EchoRequest) Reset()

func (*EchoRequest) String 

func (x *EchoRequest) String() string

type EchoResponse 

type EchoResponse struct {
	Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*EchoResponse) Descriptor deprecated 

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

Deprecated: Use EchoResponse.ProtoReflect.Descriptor instead.

func (*EchoResponse) GetMsg 

func (x *EchoResponse) GetMsg() string

func (*EchoResponse) ProtoMessage 

func (*EchoResponse) ProtoMessage()

func (*EchoResponse) ProtoReflect 

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

func (*EchoResponse) Reset 

func (x *EchoResponse) Reset()

func (*EchoResponse) String 

func (x *EchoResponse) String() string

type ErrorCode added in v0.3.2 

type ErrorCode int32

ErrorCodes 

const (
	// 0xx -> internal error
	ErrorCode_InternalError ErrorCode = 0
	// 2xx -> Stream Errors
	ErrorCode_StreamNotFound                ErrorCode = 200
	ErrorCode_StreamExists                  ErrorCode = 201
	ErrorCode_StreamFoundSubscription       ErrorCode = 202
	ErrorCode_StreamInvalidReplicaFactor    ErrorCode = 203
	ErrorCode_StreamInvalidObjectIdentifier ErrorCode = 204
	ErrorCode_StreamInvalidShardCount       ErrorCode = 205
	ErrorCode_StreamEmptyBatchedRecord      ErrorCode = 206
	ErrorCode_StreamInvalidRecordSize       ErrorCode = 207
	// 3xx -> Subscription Errors
	ErrorCode_SubscriptionNotFound                    ErrorCode = 300
	ErrorCode_SubscriptionExists                      ErrorCode = 301
	ErrorCode_SubscriptionCreationOnNonExistentStream ErrorCode = 302
	ErrorCode_SubscriptionInvalidOffset               ErrorCode = 303
	ErrorCode_SubscriptionInvalidObjectIdentifier     ErrorCode = 304
	ErrorCode_SubscriptionFoundActiveConsumers        ErrorCode = 305
	// 4xx -> Query Errors
	ErrorCode_QueryNotFound                ErrorCode = 400
	ErrorCode_QueryExists                  ErrorCode = 401
	ErrorCode_QueryInvalidSQL              ErrorCode = 402
	ErrorCode_QueryFoundAssociatedView     ErrorCode = 403
	ErrorCode_QueryInvalidObjectIdentifier ErrorCode = 404
	ErrorCode_QueryStillRunning            ErrorCode = 405
	ErrorCode_QueryNotRunning              ErrorCode = 406
	ErrorCode_QueryNotTerminated           ErrorCode = 407
	ErrorCode_QueryAlreadyTerminated       ErrorCode = 408
	// 5xx -> View Errors
	ErrorCode_ViewNotFound                ErrorCode = 500
	ErrorCode_ViewExists                  ErrorCode = 501
	ErrorCode_ViewInvalidSQL              ErrorCode = 502
	ErrorCode_ViewInvalidObjectIdentifier ErrorCode = 503
	// 6xx -> IO
	ErrorCode_ConnectorNotFound                ErrorCode = 600
	ErrorCode_ConnectorExists                  ErrorCode = 601
	ErrorCode_ConnectorInvalidType             ErrorCode = 602
	ErrorCode_ConnectorInvalidObjectIdentifier ErrorCode = 603
	ErrorCode_ConnectorCheckFailed             ErrorCode = 604
	ErrorCode_ConnectorUnimplemented           ErrorCode = 605
	ErrorCode_ConnectorInvalidStatus           ErrorCode = 606
	// 8xx -> Cluster
	ErrorCode_WrongServer ErrorCode = 800
	// 9xx -> ShardReader
	ErrorCode_ShardReaderInvalidObjectIdentifier ErrorCode = 900
)

func (ErrorCode) Descriptor added in v0.3.2 

func (ErrorCode) Descriptor() protoreflect.EnumDescriptor

func (ErrorCode) Enum added in v0.3.2 

func (x ErrorCode) Enum() *ErrorCode

func (ErrorCode) EnumDescriptor deprecated added in v0.3.2 

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

Deprecated: Use ErrorCode.Descriptor instead.

func (ErrorCode) Number added in v0.3.2 

func (x ErrorCode) Number() protoreflect.EnumNumber

func (ErrorCode) String added in v0.3.2 

func (x ErrorCode) String() string

func (ErrorCode) Type added in v0.3.2 

func (ErrorCode) Type() protoreflect.EnumType

type ExecuteViewQueryRequest added in v0.3.2 

type ExecuteViewQueryRequest struct {
	Sql string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteViewQueryRequest) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use ExecuteViewQueryRequest.ProtoReflect.Descriptor instead.

func (*ExecuteViewQueryRequest) GetSql added in v0.3.2 

func (x *ExecuteViewQueryRequest) GetSql() string

func (*ExecuteViewQueryRequest) ProtoMessage added in v0.3.2 

func (*ExecuteViewQueryRequest) ProtoMessage()

func (*ExecuteViewQueryRequest) ProtoReflect added in v0.3.2 

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

func (*ExecuteViewQueryRequest) Reset added in v0.3.2 

func (x *ExecuteViewQueryRequest) Reset()

func (*ExecuteViewQueryRequest) String added in v0.3.2 

func (x *ExecuteViewQueryRequest) String() string

type ExecuteViewQueryResponse added in v0.3.2 

type ExecuteViewQueryResponse struct {
	Results []*_struct.Struct `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteViewQueryResponse) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use ExecuteViewQueryResponse.ProtoReflect.Descriptor instead.

func (*ExecuteViewQueryResponse) GetResults added in v0.3.2 

func (x *ExecuteViewQueryResponse) GetResults() []*_struct.Struct

func (*ExecuteViewQueryResponse) ProtoMessage added in v0.3.2 

func (*ExecuteViewQueryResponse) ProtoMessage()

func (*ExecuteViewQueryResponse) ProtoReflect added in v0.3.2 

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

func (*ExecuteViewQueryResponse) Reset added in v0.3.2 

func (x *ExecuteViewQueryResponse) Reset()

func (*ExecuteViewQueryResponse) String added in v0.3.2 

func (x *ExecuteViewQueryResponse) String() string

type ExecuteViewQuerySql added in v0.3.2 

type ExecuteViewQuerySql struct {
	View string `protobuf:"bytes,1,opt,name=view,proto3" json:"view,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteViewQuerySql) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use ExecuteViewQuerySql.ProtoReflect.Descriptor instead.

func (*ExecuteViewQuerySql) GetView added in v0.3.2 

func (x *ExecuteViewQuerySql) GetView() string

func (*ExecuteViewQuerySql) ProtoMessage added in v0.3.2 

func (*ExecuteViewQuerySql) ProtoMessage()

func (*ExecuteViewQuerySql) ProtoReflect added in v0.3.2 

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

func (*ExecuteViewQuerySql) Reset added in v0.3.2 

func (x *ExecuteViewQuerySql) Reset()

func (*ExecuteViewQuerySql) String added in v0.3.2 

func (x *ExecuteViewQuerySql) String() string

type ExecuteViewQueryWithNamespaceRequest added in v0.3.2 

type ExecuteViewQueryWithNamespaceRequest struct {
	Sql       string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteViewQueryWithNamespaceRequest) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use ExecuteViewQueryWithNamespaceRequest.ProtoReflect.Descriptor instead.

func (*ExecuteViewQueryWithNamespaceRequest) GetNamespace added in v0.3.2 

func (x *ExecuteViewQueryWithNamespaceRequest) GetNamespace() string

func (*ExecuteViewQueryWithNamespaceRequest) GetSql added in v0.3.2 

func (x *ExecuteViewQueryWithNamespaceRequest) GetSql() string

func (*ExecuteViewQueryWithNamespaceRequest) ProtoMessage added in v0.3.2 

func (*ExecuteViewQueryWithNamespaceRequest) ProtoMessage()

func (*ExecuteViewQueryWithNamespaceRequest) ProtoReflect added in v0.3.2 

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

func (*ExecuteViewQueryWithNamespaceRequest) Reset added in v0.3.2 

func (x *ExecuteViewQueryWithNamespaceRequest) Reset()

func (*ExecuteViewQueryWithNamespaceRequest) String added in v0.3.2 

func (x *ExecuteViewQueryWithNamespaceRequest) String() string

type GetConnectorLogsRequest added in v0.3.2 

type GetConnectorLogsRequest struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Begin int32  `protobuf:"varint,2,opt,name=begin,proto3" json:"begin,omitempty"`
	Count int32  `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConnectorLogsRequest) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use GetConnectorLogsRequest.ProtoReflect.Descriptor instead.

func (*GetConnectorLogsRequest) GetBegin added in v0.3.2 

func (x *GetConnectorLogsRequest) GetBegin() int32

func (*GetConnectorLogsRequest) GetCount added in v0.3.2 

func (x *GetConnectorLogsRequest) GetCount() int32

func (*GetConnectorLogsRequest) GetName added in v0.3.2 

func (x *GetConnectorLogsRequest) GetName() string

func (*GetConnectorLogsRequest) ProtoMessage added in v0.3.2 

func (*GetConnectorLogsRequest) ProtoMessage()

func (*GetConnectorLogsRequest) ProtoReflect added in v0.3.2 

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

func (*GetConnectorLogsRequest) Reset added in v0.3.2 

func (x *GetConnectorLogsRequest) Reset()

func (*GetConnectorLogsRequest) String added in v0.3.2 

func (x *GetConnectorLogsRequest) String() string

type GetConnectorLogsResponse added in v0.3.2 

type GetConnectorLogsResponse struct {
	Logs string `protobuf:"bytes,1,opt,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConnectorLogsResponse) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use GetConnectorLogsResponse.ProtoReflect.Descriptor instead.

func (*GetConnectorLogsResponse) GetLogs added in v0.3.2 

func (x *GetConnectorLogsResponse) GetLogs() string

func (*GetConnectorLogsResponse) ProtoMessage added in v0.3.2 

func (*GetConnectorLogsResponse) ProtoMessage()

func (*GetConnectorLogsResponse) ProtoReflect added in v0.3.2 

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

func (*GetConnectorLogsResponse) Reset added in v0.3.2 

func (x *GetConnectorLogsResponse) Reset()

func (*GetConnectorLogsResponse) String added in v0.3.2 

func (x *GetConnectorLogsResponse) String() string

type GetConnectorRequest 

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

func (*GetConnectorRequest) Descriptor deprecated 

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

Deprecated: Use GetConnectorRequest.ProtoReflect.Descriptor instead.

func (*GetConnectorRequest) GetName added in v0.1.5 

func (x *GetConnectorRequest) GetName() string

func (*GetConnectorRequest) ProtoMessage 

func (*GetConnectorRequest) ProtoMessage()

func (*GetConnectorRequest) ProtoReflect 

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

func (*GetConnectorRequest) Reset 

func (x *GetConnectorRequest) Reset()

func (*GetConnectorRequest) String 

func (x *GetConnectorRequest) String() string

type GetConnectorSpecRequest added in v0.3.2 

type GetConnectorSpecRequest struct {

	// SOURCE or SINK
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// e.g. mysql, postgresql, etc.
	Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConnectorSpecRequest) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use GetConnectorSpecRequest.ProtoReflect.Descriptor instead.

func (*GetConnectorSpecRequest) GetTarget added in v0.3.2 

func (x *GetConnectorSpecRequest) GetTarget() string

func (*GetConnectorSpecRequest) GetType added in v0.3.2 

func (x *GetConnectorSpecRequest) GetType() string

func (*GetConnectorSpecRequest) ProtoMessage added in v0.3.2 

func (*GetConnectorSpecRequest) ProtoMessage()

func (*GetConnectorSpecRequest) ProtoReflect added in v0.3.2 

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

func (*GetConnectorSpecRequest) Reset added in v0.3.2 

func (x *GetConnectorSpecRequest) Reset()

func (*GetConnectorSpecRequest) String added in v0.3.2 

func (x *GetConnectorSpecRequest) String() string

type GetConnectorSpecResponse added in v0.3.2 

type GetConnectorSpecResponse struct {
	Spec string `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConnectorSpecResponse) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use GetConnectorSpecResponse.ProtoReflect.Descriptor instead.

func (*GetConnectorSpecResponse) GetSpec added in v0.3.2 

func (x *GetConnectorSpecResponse) GetSpec() string

func (*GetConnectorSpecResponse) ProtoMessage added in v0.3.2 

func (*GetConnectorSpecResponse) ProtoMessage()

func (*GetConnectorSpecResponse) ProtoReflect added in v0.3.2 

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

func (*GetConnectorSpecResponse) Reset added in v0.3.2 

func (x *GetConnectorSpecResponse) Reset()

func (*GetConnectorSpecResponse) String added in v0.3.2 

func (x *GetConnectorSpecResponse) String() string

type GetQueryRequest 

type GetQueryRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetQueryRequest) Descriptor deprecated 

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

Deprecated: Use GetQueryRequest.ProtoReflect.Descriptor instead.

func (*GetQueryRequest) GetId 

func (x *GetQueryRequest) GetId() string

func (*GetQueryRequest) ProtoMessage 

func (*GetQueryRequest) ProtoMessage()

func (*GetQueryRequest) ProtoReflect 

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

func (*GetQueryRequest) Reset 

func (x *GetQueryRequest) Reset()

func (*GetQueryRequest) String 

func (x *GetQueryRequest) String() string

type GetStatsRequest added in v0.3.2 

type GetStatsRequest struct {
	Stats []*StatType `protobuf:"bytes,1,rep,name=stats,proto3" json:"stats,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStatsRequest) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use GetStatsRequest.ProtoReflect.Descriptor instead.

func (*GetStatsRequest) GetStats added in v0.3.2 

func (x *GetStatsRequest) GetStats() []*StatType

func (*GetStatsRequest) ProtoMessage added in v0.3.2 

func (*GetStatsRequest) ProtoMessage()

func (*GetStatsRequest) ProtoReflect added in v0.3.2 

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

func (*GetStatsRequest) Reset added in v0.3.2 

func (x *GetStatsRequest) Reset()

func (*GetStatsRequest) String added in v0.3.2 

func (x *GetStatsRequest) String() string

type GetStatsResponse added in v0.3.2 

type GetStatsResponse struct {
	StatsValues []*StatValue `protobuf:"bytes,1,rep,name=statsValues,proto3" json:"statsValues,omitempty"`
	Errors      []*StatError `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStatsResponse) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use GetStatsResponse.ProtoReflect.Descriptor instead.

func (*GetStatsResponse) GetErrors added in v0.3.2 

func (x *GetStatsResponse) GetErrors() []*StatError

func (*GetStatsResponse) GetStatsValues added in v0.3.2 

func (x *GetStatsResponse) GetStatsValues() []*StatValue

func (*GetStatsResponse) ProtoMessage added in v0.3.2 

func (*GetStatsResponse) ProtoMessage()

func (*GetStatsResponse) ProtoReflect added in v0.3.2 

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

func (*GetStatsResponse) Reset added in v0.3.2 

func (x *GetStatsResponse) Reset()

func (*GetStatsResponse) String added in v0.3.2 

func (x *GetStatsResponse) String() string

type GetStreamRequest added in v0.3.1 

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

func (*GetStreamRequest) Descriptor deprecated added in v0.3.1 

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

Deprecated: Use GetStreamRequest.ProtoReflect.Descriptor instead.

func (*GetStreamRequest) GetName added in v0.3.1 

func (x *GetStreamRequest) GetName() string

func (*GetStreamRequest) ProtoMessage added in v0.3.1 

func (*GetStreamRequest) ProtoMessage()

func (*GetStreamRequest) ProtoReflect added in v0.3.1 

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

func (*GetStreamRequest) Reset added in v0.3.1 

func (x *GetStreamRequest) Reset()

func (*GetStreamRequest) String added in v0.3.1 

func (x *GetStreamRequest) String() string

type GetStreamResponse added in v0.3.1 

type GetStreamResponse struct {
	Stream *Stream `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStreamResponse) Descriptor deprecated added in v0.3.1 

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

Deprecated: Use GetStreamResponse.ProtoReflect.Descriptor instead.

func (*GetStreamResponse) GetStream added in v0.3.1 

func (x *GetStreamResponse) GetStream() *Stream

func (*GetStreamResponse) ProtoMessage added in v0.3.1 

func (*GetStreamResponse) ProtoMessage()

func (*GetStreamResponse) ProtoReflect added in v0.3.1 

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

func (*GetStreamResponse) Reset added in v0.3.1 

func (x *GetStreamResponse) Reset()

func (*GetStreamResponse) String added in v0.3.1 

func (x *GetStreamResponse) String() string

type GetSubscriptionRequest added in v0.3.1 

type GetSubscriptionRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSubscriptionRequest) Descriptor deprecated added in v0.3.1 

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

Deprecated: Use GetSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*GetSubscriptionRequest) GetId added in v0.3.1 

func (x *GetSubscriptionRequest) GetId() string

func (*GetSubscriptionRequest) ProtoMessage added in v0.3.1 

func (*GetSubscriptionRequest) ProtoMessage()

func (*GetSubscriptionRequest) ProtoReflect added in v0.3.1 

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

func (*GetSubscriptionRequest) Reset added in v0.3.1 

func (x *GetSubscriptionRequest) Reset()

func (*GetSubscriptionRequest) String added in v0.3.1 

func (x *GetSubscriptionRequest) String() string

type GetSubscriptionResponse added in v0.3.1 

type GetSubscriptionResponse struct {
	Subscription *Subscription         `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
	Offsets      []*SubscriptionOffset `protobuf:"bytes,2,rep,name=offsets,proto3" json:"offsets,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSubscriptionResponse) Descriptor deprecated added in v0.3.1 

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

Deprecated: Use GetSubscriptionResponse.ProtoReflect.Descriptor instead.

func (*GetSubscriptionResponse) GetOffsets added in v0.3.1 

func (x *GetSubscriptionResponse) GetOffsets() []*SubscriptionOffset

func (*GetSubscriptionResponse) GetSubscription added in v0.3.1 

func (x *GetSubscriptionResponse) GetSubscription() *Subscription

func (*GetSubscriptionResponse) ProtoMessage added in v0.3.1 

func (*GetSubscriptionResponse) ProtoMessage()

func (*GetSubscriptionResponse) ProtoReflect added in v0.3.1 

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

func (*GetSubscriptionResponse) Reset added in v0.3.1 

func (x *GetSubscriptionResponse) Reset()

func (*GetSubscriptionResponse) String added in v0.3.1 

func (x *GetSubscriptionResponse) String() string

type GetViewRequest 

type GetViewRequest struct {
	ViewId string `protobuf:"bytes,1,opt,name=viewId,proto3" json:"viewId,omitempty"`
	// contains filtered or unexported fields
}

View related Request and Response

func (*GetViewRequest) Descriptor deprecated 

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

Deprecated: Use GetViewRequest.ProtoReflect.Descriptor instead.

func (*GetViewRequest) GetViewId 

func (x *GetViewRequest) GetViewId() string

func (*GetViewRequest) ProtoMessage 

func (*GetViewRequest) ProtoMessage()

func (*GetViewRequest) ProtoReflect 

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

func (*GetViewRequest) Reset 

func (x *GetViewRequest) Reset()

func (*GetViewRequest) String 

func (x *GetViewRequest) String() string

type HStreamApiClient 

type HStreamApiClient interface {
	Echo(ctx context.Context, in *EchoRequest, opts ...grpc.CallOption) (*EchoResponse, error)
	// Stream APIs
	CreateStream(ctx context.Context, in *Stream, opts ...grpc.CallOption) (*Stream, error)
	DeleteStream(ctx context.Context, in *DeleteStreamRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	GetStream(ctx context.Context, in *GetStreamRequest, opts ...grpc.CallOption) (*GetStreamResponse, error)
	ListStreams(ctx context.Context, in *ListStreamsRequest, opts ...grpc.CallOption) (*ListStreamsResponse, error)
	ListStreamsWithPrefix(ctx context.Context, in *ListStreamsWithPrefixRequest, opts ...grpc.CallOption) (*ListStreamsResponse, error)
	LookupShard(ctx context.Context, in *LookupShardRequest, opts ...grpc.CallOption) (*LookupShardResponse, error)
	Append(ctx context.Context, in *AppendRequest, opts ...grpc.CallOption) (*AppendResponse, error)
	// Shard APIs
	ListShards(ctx context.Context, in *ListShardsRequest, opts ...grpc.CallOption) (*ListShardsResponse, error)
	CreateShardReader(ctx context.Context, in *CreateShardReaderRequest, opts ...grpc.CallOption) (*CreateShardReaderResponse, error)
	LookupShardReader(ctx context.Context, in *LookupShardReaderRequest, opts ...grpc.CallOption) (*LookupShardReaderResponse, error)
	ReadShard(ctx context.Context, in *ReadShardRequest, opts ...grpc.CallOption) (*ReadShardResponse, error)
	ReadShardStream(ctx context.Context, in *ReadShardStreamRequest, opts ...grpc.CallOption) (HStreamApi_ReadShardStreamClient, error)
	ListShardReaders(ctx context.Context, in *ListShardReadersRequest, opts ...grpc.CallOption) (*ListShardReadersResponse, error)
	DeleteShardReader(ctx context.Context, in *DeleteShardReaderRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Subscribe APIs
	CreateSubscription(ctx context.Context, in *Subscription, opts ...grpc.CallOption) (*Subscription, error)
	GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*GetSubscriptionResponse, error)
	ListSubscriptions(ctx context.Context, in *ListSubscriptionsRequest, opts ...grpc.CallOption) (*ListSubscriptionsResponse, error)
	ListSubscriptionsWithPrefix(ctx context.Context, in *ListSubscriptionsWithPrefixRequest, opts ...grpc.CallOption) (*ListSubscriptionsResponse, error)
	ListConsumers(ctx context.Context, in *ListConsumersRequest, opts ...grpc.CallOption) (*ListConsumersResponse, error)
	CheckSubscriptionExist(ctx context.Context, in *CheckSubscriptionExistRequest, opts ...grpc.CallOption) (*CheckSubscriptionExistResponse, error)
	DeleteSubscription(ctx context.Context, in *DeleteSubscriptionRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	LookupSubscription(ctx context.Context, in *LookupSubscriptionRequest, opts ...grpc.CallOption) (*LookupSubscriptionResponse, error)
	StreamingFetch(ctx context.Context, opts ...grpc.CallOption) (HStreamApi_StreamingFetchClient, error)
	// Cluster APIs
	DescribeCluster(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*DescribeClusterResponse, error)
	LookupResource(ctx context.Context, in *LookupResourceRequest, opts ...grpc.CallOption) (*ServerNode, error)
	// Admin Command
	SendAdminCommand(ctx context.Context, in *AdminCommandRequest, opts ...grpc.CallOption) (*AdminCommandResponse, error)
	// Stats
	PerStreamTimeSeriesStats(ctx context.Context, in *PerStreamTimeSeriesStatsRequest, opts ...grpc.CallOption) (*PerStreamTimeSeriesStatsResponse, error)
	PerStreamTimeSeriesStatsAll(ctx context.Context, in *PerStreamTimeSeriesStatsAllRequest, opts ...grpc.CallOption) (*PerStreamTimeSeriesStatsAllResponse, error)
	GetStats(ctx context.Context, in *GetStatsRequest, opts ...grpc.CallOption) (*GetStatsResponse, error)
	// for execute any sql stmt except push query,
	// e.g., insert, create, show/list, select(without emit changes) ...
	ExecuteQuery(ctx context.Context, in *CommandQuery, opts ...grpc.CallOption) (*CommandQueryResponse, error)
	// query related apis
	CreateQuery(ctx context.Context, in *CreateQueryRequest, opts ...grpc.CallOption) (*Query, error)
	CreateQueryWithNamespace(ctx context.Context, in *CreateQueryWithNamespaceRequest, opts ...grpc.CallOption) (*Query, error)
	ListQueries(ctx context.Context, in *ListQueriesRequest, opts ...grpc.CallOption) (*ListQueriesResponse, error)
	GetQuery(ctx context.Context, in *GetQueryRequest, opts ...grpc.CallOption) (*Query, error)
	TerminateQuery(ctx context.Context, in *TerminateQueryRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	DeleteQuery(ctx context.Context, in *DeleteQueryRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ResumeQuery(ctx context.Context, in *ResumeQueryRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	PauseQuery(ctx context.Context, in *PauseQueryRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// parse query sql, return structuralized information
	ParseSql(ctx context.Context, in *ParseSqlRequest, opts ...grpc.CallOption) (*ParseSqlResponse, error)
	// connector related apis
	CreateConnector(ctx context.Context, in *CreateConnectorRequest, opts ...grpc.CallOption) (*Connector, error)
	ListConnectors(ctx context.Context, in *ListConnectorsRequest, opts ...grpc.CallOption) (*ListConnectorsResponse, error)
	GetConnector(ctx context.Context, in *GetConnectorRequest, opts ...grpc.CallOption) (*Connector, error)
	GetConnectorSpec(ctx context.Context, in *GetConnectorSpecRequest, opts ...grpc.CallOption) (*GetConnectorSpecResponse, error)
	GetConnectorLogs(ctx context.Context, in *GetConnectorLogsRequest, opts ...grpc.CallOption) (*GetConnectorLogsResponse, error)
	DeleteConnector(ctx context.Context, in *DeleteConnectorRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	PauseConnector(ctx context.Context, in *PauseConnectorRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ResumeConnector(ctx context.Context, in *ResumeConnectorRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// view related apis
	ListViews(ctx context.Context, in *ListViewsRequest, opts ...grpc.CallOption) (*ListViewsResponse, error)
	GetView(ctx context.Context, in *GetViewRequest, opts ...grpc.CallOption) (*View, error)
	DeleteView(ctx context.Context, in *DeleteViewRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ExecuteViewQuery(ctx context.Context, in *ExecuteViewQueryRequest, opts ...grpc.CallOption) (*ExecuteViewQueryResponse, error)
	ExecuteViewQueryWithNamespace(ctx context.Context, in *ExecuteViewQueryWithNamespaceRequest, opts ...grpc.CallOption) (*ExecuteViewQueryResponse, error)
}

HStreamApiClient is the client API for HStreamApi service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewHStreamApiClient 

func NewHStreamApiClient(cc grpc.ClientConnInterface) HStreamApiClient

type HStreamApiServer 

type HStreamApiServer interface {
	Echo(context.Context, *EchoRequest) (*EchoResponse, error)
	// Stream APIs
	CreateStream(context.Context, *Stream) (*Stream, error)
	DeleteStream(context.Context, *DeleteStreamRequest) (*empty.Empty, error)
	GetStream(context.Context, *GetStreamRequest) (*GetStreamResponse, error)
	ListStreams(context.Context, *ListStreamsRequest) (*ListStreamsResponse, error)
	ListStreamsWithPrefix(context.Context, *ListStreamsWithPrefixRequest) (*ListStreamsResponse, error)
	LookupShard(context.Context, *LookupShardRequest) (*LookupShardResponse, error)
	Append(context.Context, *AppendRequest) (*AppendResponse, error)
	// Shard APIs
	ListShards(context.Context, *ListShardsRequest) (*ListShardsResponse, error)
	CreateShardReader(context.Context, *CreateShardReaderRequest) (*CreateShardReaderResponse, error)
	LookupShardReader(context.Context, *LookupShardReaderRequest) (*LookupShardReaderResponse, error)
	ReadShard(context.Context, *ReadShardRequest) (*ReadShardResponse, error)
	ReadShardStream(*ReadShardStreamRequest, HStreamApi_ReadShardStreamServer) error
	ListShardReaders(context.Context, *ListShardReadersRequest) (*ListShardReadersResponse, error)
	DeleteShardReader(context.Context, *DeleteShardReaderRequest) (*empty.Empty, error)
	// Subscribe APIs
	CreateSubscription(context.Context, *Subscription) (*Subscription, error)
	GetSubscription(context.Context, *GetSubscriptionRequest) (*GetSubscriptionResponse, error)
	ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)
	ListSubscriptionsWithPrefix(context.Context, *ListSubscriptionsWithPrefixRequest) (*ListSubscriptionsResponse, error)
	ListConsumers(context.Context, *ListConsumersRequest) (*ListConsumersResponse, error)
	CheckSubscriptionExist(context.Context, *CheckSubscriptionExistRequest) (*CheckSubscriptionExistResponse, error)
	DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*empty.Empty, error)
	LookupSubscription(context.Context, *LookupSubscriptionRequest) (*LookupSubscriptionResponse, error)
	StreamingFetch(HStreamApi_StreamingFetchServer) error
	// Cluster APIs
	DescribeCluster(context.Context, *empty.Empty) (*DescribeClusterResponse, error)
	LookupResource(context.Context, *LookupResourceRequest) (*ServerNode, error)
	// Admin Command
	SendAdminCommand(context.Context, *AdminCommandRequest) (*AdminCommandResponse, error)
	// Stats
	PerStreamTimeSeriesStats(context.Context, *PerStreamTimeSeriesStatsRequest) (*PerStreamTimeSeriesStatsResponse, error)
	PerStreamTimeSeriesStatsAll(context.Context, *PerStreamTimeSeriesStatsAllRequest) (*PerStreamTimeSeriesStatsAllResponse, error)
	GetStats(context.Context, *GetStatsRequest) (*GetStatsResponse, error)
	// for execute any sql stmt except push query,
	// e.g., insert, create, show/list, select(without emit changes) ...
	ExecuteQuery(context.Context, *CommandQuery) (*CommandQueryResponse, error)
	// query related apis
	CreateQuery(context.Context, *CreateQueryRequest) (*Query, error)
	CreateQueryWithNamespace(context.Context, *CreateQueryWithNamespaceRequest) (*Query, error)
	ListQueries(context.Context, *ListQueriesRequest) (*ListQueriesResponse, error)
	GetQuery(context.Context, *GetQueryRequest) (*Query, error)
	TerminateQuery(context.Context, *TerminateQueryRequest) (*empty.Empty, error)
	DeleteQuery(context.Context, *DeleteQueryRequest) (*empty.Empty, error)
	ResumeQuery(context.Context, *ResumeQueryRequest) (*empty.Empty, error)
	PauseQuery(context.Context, *PauseQueryRequest) (*empty.Empty, error)
	// parse query sql, return structuralized information
	ParseSql(context.Context, *ParseSqlRequest) (*ParseSqlResponse, error)
	// connector related apis
	CreateConnector(context.Context, *CreateConnectorRequest) (*Connector, error)
	ListConnectors(context.Context, *ListConnectorsRequest) (*ListConnectorsResponse, error)
	GetConnector(context.Context, *GetConnectorRequest) (*Connector, error)
	GetConnectorSpec(context.Context, *GetConnectorSpecRequest) (*GetConnectorSpecResponse, error)
	GetConnectorLogs(context.Context, *GetConnectorLogsRequest) (*GetConnectorLogsResponse, error)
	DeleteConnector(context.Context, *DeleteConnectorRequest) (*empty.Empty, error)
	PauseConnector(context.Context, *PauseConnectorRequest) (*empty.Empty, error)
	ResumeConnector(context.Context, *ResumeConnectorRequest) (*empty.Empty, error)
	// view related apis
	ListViews(context.Context, *ListViewsRequest) (*ListViewsResponse, error)
	GetView(context.Context, *GetViewRequest) (*View, error)
	DeleteView(context.Context, *DeleteViewRequest) (*empty.Empty, error)
	ExecuteViewQuery(context.Context, *ExecuteViewQueryRequest) (*ExecuteViewQueryResponse, error)
	ExecuteViewQueryWithNamespace(context.Context, *ExecuteViewQueryWithNamespaceRequest) (*ExecuteViewQueryResponse, error)
	// contains filtered or unexported methods
}

HStreamApiServer is the server API for HStreamApi service. All implementations must embed UnimplementedHStreamApiServer for forward compatibility

type HStreamApi_ReadShardStreamClient added in v0.3.2 

type HStreamApi_ReadShardStreamClient interface {
	Recv() (*ReadShardStreamResponse, error)
	grpc.ClientStream
}

type HStreamApi_ReadShardStreamServer added in v0.3.2 

type HStreamApi_ReadShardStreamServer interface {
	Send(*ReadShardStreamResponse) error
	grpc.ServerStream
}

type HStreamApi_StreamingFetchClient 

type HStreamApi_StreamingFetchClient interface {
	Send(*StreamingFetchRequest) error
	Recv() (*StreamingFetchResponse, error)
	grpc.ClientStream
}

type HStreamApi_StreamingFetchServer 

type HStreamApi_StreamingFetchServer interface {
	Send(*StreamingFetchResponse) error
	Recv() (*StreamingFetchRequest, error)
	grpc.ServerStream
}

type HStreamRecord 

type HStreamRecord struct {

	// Required.
	Header *HStreamRecordHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Optional.
	// Payload may be empty.
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*HStreamRecord) Descriptor deprecated 

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

Deprecated: Use HStreamRecord.ProtoReflect.Descriptor instead.

func (*HStreamRecord) GetHeader 

func (x *HStreamRecord) GetHeader() *HStreamRecordHeader

func (*HStreamRecord) GetPayload 

func (x *HStreamRecord) GetPayload() []byte

func (*HStreamRecord) ProtoMessage 

func (*HStreamRecord) ProtoMessage()

func (*HStreamRecord) ProtoReflect 

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

func (*HStreamRecord) Reset 

func (x *HStreamRecord) Reset()

func (*HStreamRecord) String 

func (x *HStreamRecord) String() string

type HStreamRecordHeader 

type HStreamRecordHeader struct {
	Flag HStreamRecordHeader_Flag `protobuf:"varint,1,opt,name=flag,proto3,enum=hstream.server.HStreamRecordHeader_Flag" json:"flag,omitempty"`
	// Optional.
	// Attributes attached to this record.
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// Optional.
	// key for the message.
	Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*HStreamRecordHeader) Descriptor deprecated 

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

Deprecated: Use HStreamRecordHeader.ProtoReflect.Descriptor instead.

func (*HStreamRecordHeader) GetAttributes 

func (x *HStreamRecordHeader) GetAttributes() map[string]string

func (*HStreamRecordHeader) GetFlag 

func (x *HStreamRecordHeader) GetFlag() HStreamRecordHeader_Flag

func (*HStreamRecordHeader) GetKey 

func (x *HStreamRecordHeader) GetKey() string

func (*HStreamRecordHeader) ProtoMessage 

func (*HStreamRecordHeader) ProtoMessage()

func (*HStreamRecordHeader) ProtoReflect 

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

func (*HStreamRecordHeader) Reset 

func (x *HStreamRecordHeader) Reset()

func (*HStreamRecordHeader) String 

func (x *HStreamRecordHeader) String() string

type HStreamRecordHeader_Flag 

type HStreamRecordHeader_Flag int32

Required. Flag for payload. 

const (
	HStreamRecordHeader_JSON HStreamRecordHeader_Flag = 0
	HStreamRecordHeader_RAW  HStreamRecordHeader_Flag = 1
)

func (HStreamRecordHeader_Flag) Descriptor 

func (HStreamRecordHeader_Flag) Descriptor() protoreflect.EnumDescriptor

func (HStreamRecordHeader_Flag) Enum 

func (x HStreamRecordHeader_Flag) Enum() *HStreamRecordHeader_Flag

func (HStreamRecordHeader_Flag) EnumDescriptor deprecated 

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

Deprecated: Use HStreamRecordHeader_Flag.Descriptor instead.

func (HStreamRecordHeader_Flag) Number 

func (x HStreamRecordHeader_Flag) Number() protoreflect.EnumNumber

func (HStreamRecordHeader_Flag) String 

func (x HStreamRecordHeader_Flag) String() string

func (HStreamRecordHeader_Flag) Type 

func (HStreamRecordHeader_Flag) Type() protoreflect.EnumType

type ListConnectorsRequest 

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

func (*ListConnectorsRequest) Descriptor deprecated 

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

Deprecated: Use ListConnectorsRequest.ProtoReflect.Descriptor instead.

func (*ListConnectorsRequest) ProtoMessage 

func (*ListConnectorsRequest) ProtoMessage()

func (*ListConnectorsRequest) ProtoReflect 

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

func (*ListConnectorsRequest) Reset 

func (x *ListConnectorsRequest) Reset()

func (*ListConnectorsRequest) String 

func (x *ListConnectorsRequest) String() string

type ListConnectorsResponse 

type ListConnectorsResponse struct {
	Connectors []*Connector `protobuf:"bytes,1,rep,name=connectors,proto3" json:"connectors,omitempty"`
	// contains filtered or unexported fields
}

func (*ListConnectorsResponse) Descriptor deprecated 

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

Deprecated: Use ListConnectorsResponse.ProtoReflect.Descriptor instead.

func (*ListConnectorsResponse) GetConnectors 

func (x *ListConnectorsResponse) GetConnectors() []*Connector

func (*ListConnectorsResponse) ProtoMessage 

func (*ListConnectorsResponse) ProtoMessage()

func (*ListConnectorsResponse) ProtoReflect 

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

func (*ListConnectorsResponse) Reset 

func (x *ListConnectorsResponse) Reset()

func (*ListConnectorsResponse) String 

func (x *ListConnectorsResponse) String() string

type ListConsumersRequest added in v0.3.1 

type ListConsumersRequest struct {
	SubscriptionId string `protobuf:"bytes,1,opt,name=subscriptionId,proto3" json:"subscriptionId,omitempty"`
	// contains filtered or unexported fields
}

func (*ListConsumersRequest) Descriptor deprecated added in v0.3.1 

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

Deprecated: Use ListConsumersRequest.ProtoReflect.Descriptor instead.

func (*ListConsumersRequest) GetSubscriptionId added in v0.3.1 

func (x *ListConsumersRequest) GetSubscriptionId() string

func (*ListConsumersRequest) ProtoMessage added in v0.3.1 

func (*ListConsumersRequest) ProtoMessage()

func (*ListConsumersRequest) ProtoReflect added in v0.3.1 

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

func (*ListConsumersRequest) Reset added in v0.3.1 

func (x *ListConsumersRequest) Reset()

func (*ListConsumersRequest) String added in v0.3.1 

func (x *ListConsumersRequest) String() string

type ListConsumersResponse added in v0.3.1 

type ListConsumersResponse struct {
	Consumers []*Consumer `protobuf:"bytes,1,rep,name=consumers,proto3" json:"consumers,omitempty"`
	// contains filtered or unexported fields
}

func (*ListConsumersResponse) Descriptor deprecated added in v0.3.1 

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

Deprecated: Use ListConsumersResponse.ProtoReflect.Descriptor instead.

func (*ListConsumersResponse) GetConsumers added in v0.3.1 

func (x *ListConsumersResponse) GetConsumers() []*Consumer

func (*ListConsumersResponse) ProtoMessage added in v0.3.1 

func (*ListConsumersResponse) ProtoMessage()

func (*ListConsumersResponse) ProtoReflect added in v0.3.1 

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

func (*ListConsumersResponse) Reset added in v0.3.1 

func (x *ListConsumersResponse) Reset()

func (*ListConsumersResponse) String added in v0.3.1 

func (x *ListConsumersResponse) String() string

type ListQueriesRequest 

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

func (*ListQueriesRequest) Descriptor deprecated 

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

Deprecated: Use ListQueriesRequest.ProtoReflect.Descriptor instead.

func (*ListQueriesRequest) ProtoMessage 

func (*ListQueriesRequest) ProtoMessage()

func (*ListQueriesRequest) ProtoReflect 

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

func (*ListQueriesRequest) Reset 

func (x *ListQueriesRequest) Reset()

func (*ListQueriesRequest) String 

func (x *ListQueriesRequest) String() string

type ListQueriesResponse 

type ListQueriesResponse struct {
	Queries []*Query `protobuf:"bytes,1,rep,name=queries,proto3" json:"queries,omitempty"`
	// contains filtered or unexported fields
}

func (*ListQueriesResponse) Descriptor deprecated 

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

Deprecated: Use ListQueriesResponse.ProtoReflect.Descriptor instead.

func (*ListQueriesResponse) GetQueries 

func (x *ListQueriesResponse) GetQueries() []*Query

func (*ListQueriesResponse) ProtoMessage 

func (*ListQueriesResponse) ProtoMessage()

func (*ListQueriesResponse) ProtoReflect 

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

func (*ListQueriesResponse) Reset 

func (x *ListQueriesResponse) Reset()

func (*ListQueriesResponse) String 

func (x *ListQueriesResponse) String() string

type ListShardReadersRequest added in v0.3.1 

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

func (*ListShardReadersRequest) Descriptor deprecated added in v0.3.1 

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

Deprecated: Use ListShardReadersRequest.ProtoReflect.Descriptor instead.

func (*ListShardReadersRequest) ProtoMessage added in v0.3.1 

func (*ListShardReadersRequest) ProtoMessage()

func (*ListShardReadersRequest) ProtoReflect added in v0.3.1 

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

func (*ListShardReadersRequest) Reset added in v0.3.1 

func (x *ListShardReadersRequest) Reset()

func (*ListShardReadersRequest) String added in v0.3.1 

func (x *ListShardReadersRequest) String() string

type ListShardReadersResponse added in v0.3.1 

type ListShardReadersResponse struct {
	ReaderId []string `protobuf:"bytes,1,rep,name=readerId,proto3" json:"readerId,omitempty"`
	// contains filtered or unexported fields
}

func (*ListShardReadersResponse) Descriptor deprecated added in v0.3.1 

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

Deprecated: Use ListShardReadersResponse.ProtoReflect.Descriptor instead.

func (*ListShardReadersResponse) GetReaderId added in v0.3.1 

func (x *ListShardReadersResponse) GetReaderId() []string

func (*ListShardReadersResponse) ProtoMessage added in v0.3.1 

func (*ListShardReadersResponse) ProtoMessage()

func (*ListShardReadersResponse) ProtoReflect added in v0.3.1 

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

func (*ListShardReadersResponse) Reset added in v0.3.1 

func (x *ListShardReadersResponse) Reset()

func (*ListShardReadersResponse) String added in v0.3.1 

func (x *ListShardReadersResponse) String() string

type ListShardsRequest added in v0.2.0 

type ListShardsRequest struct {
	StreamName string `protobuf:"bytes,1,opt,name=streamName,proto3" json:"streamName,omitempty"`
	// contains filtered or unexported fields
}

func (*ListShardsRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use ListShardsRequest.ProtoReflect.Descriptor instead.

func (*ListShardsRequest) GetStreamName added in v0.2.0 

func (x *ListShardsRequest) GetStreamName() string

func (*ListShardsRequest) ProtoMessage added in v0.2.0 

func (*ListShardsRequest) ProtoMessage()

func (*ListShardsRequest) ProtoReflect added in v0.2.0 

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

func (*ListShardsRequest) Reset added in v0.2.0 

func (x *ListShardsRequest) Reset()

func (*ListShardsRequest) String added in v0.2.0 

func (x *ListShardsRequest) String() string

type ListShardsResponse added in v0.2.0 

type ListShardsResponse struct {
	Shards []*Shard `protobuf:"bytes,1,rep,name=shards,proto3" json:"shards,omitempty"`
	// contains filtered or unexported fields
}

func (*ListShardsResponse) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use ListShardsResponse.ProtoReflect.Descriptor instead.

func (*ListShardsResponse) GetShards added in v0.2.0 

func (x *ListShardsResponse) GetShards() []*Shard

func (*ListShardsResponse) ProtoMessage added in v0.2.0 

func (*ListShardsResponse) ProtoMessage()

func (*ListShardsResponse) ProtoReflect added in v0.2.0 

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

func (*ListShardsResponse) Reset added in v0.2.0 

func (x *ListShardsResponse) Reset()

func (*ListShardsResponse) String added in v0.2.0 

func (x *ListShardsResponse) String() string

type ListStreamsRequest 

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

TODO: Add options for filtering or max_size

func (*ListStreamsRequest) Descriptor deprecated 

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

Deprecated: Use ListStreamsRequest.ProtoReflect.Descriptor instead.

func (*ListStreamsRequest) ProtoMessage 

func (*ListStreamsRequest) ProtoMessage()

func (*ListStreamsRequest) ProtoReflect 

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

func (*ListStreamsRequest) Reset 

func (x *ListStreamsRequest) Reset()

func (*ListStreamsRequest) String 

func (x *ListStreamsRequest) String() string

type ListStreamsResponse 

type ListStreamsResponse struct {
	Streams []*Stream `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"`
	// contains filtered or unexported fields
}

func (*ListStreamsResponse) Descriptor deprecated 

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

Deprecated: Use ListStreamsResponse.ProtoReflect.Descriptor instead.

func (*ListStreamsResponse) GetStreams 

func (x *ListStreamsResponse) GetStreams() []*Stream

func (*ListStreamsResponse) ProtoMessage 

func (*ListStreamsResponse) ProtoMessage()

func (*ListStreamsResponse) ProtoReflect 

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

func (*ListStreamsResponse) Reset 

func (x *ListStreamsResponse) Reset()

func (*ListStreamsResponse) String 

func (x *ListStreamsResponse) String() string

type ListStreamsWithPrefixRequest added in v0.3.1 

type ListStreamsWithPrefixRequest struct {
	Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*ListStreamsWithPrefixRequest) Descriptor deprecated added in v0.3.1 

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

Deprecated: Use ListStreamsWithPrefixRequest.ProtoReflect.Descriptor instead.

func (*ListStreamsWithPrefixRequest) GetPrefix added in v0.3.1 

func (x *ListStreamsWithPrefixRequest) GetPrefix() string

func (*ListStreamsWithPrefixRequest) ProtoMessage added in v0.3.1 

func (*ListStreamsWithPrefixRequest) ProtoMessage()

func (*ListStreamsWithPrefixRequest) ProtoReflect added in v0.3.1 

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

func (*ListStreamsWithPrefixRequest) Reset added in v0.3.1 

func (x *ListStreamsWithPrefixRequest) Reset()

func (*ListStreamsWithPrefixRequest) String added in v0.3.1 

func (x *ListStreamsWithPrefixRequest) String() string

type ListSubscriptionsRequest 

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

func (*ListSubscriptionsRequest) Descriptor deprecated 

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

Deprecated: Use ListSubscriptionsRequest.ProtoReflect.Descriptor instead.

func (*ListSubscriptionsRequest) ProtoMessage 

func (*ListSubscriptionsRequest) ProtoMessage()

func (*ListSubscriptionsRequest) ProtoReflect 

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

func (*ListSubscriptionsRequest) Reset 

func (x *ListSubscriptionsRequest) Reset()

func (*ListSubscriptionsRequest) String 

func (x *ListSubscriptionsRequest) String() string

type ListSubscriptionsResponse 

type ListSubscriptionsResponse struct {
	Subscription []*Subscription `protobuf:"bytes,1,rep,name=subscription,proto3" json:"subscription,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSubscriptionsResponse) Descriptor deprecated 

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

Deprecated: Use ListSubscriptionsResponse.ProtoReflect.Descriptor instead.

func (*ListSubscriptionsResponse) GetSubscription 

func (x *ListSubscriptionsResponse) GetSubscription() []*Subscription

func (*ListSubscriptionsResponse) ProtoMessage 

func (*ListSubscriptionsResponse) ProtoMessage()

func (*ListSubscriptionsResponse) ProtoReflect 

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

func (*ListSubscriptionsResponse) Reset 

func (x *ListSubscriptionsResponse) Reset()

func (*ListSubscriptionsResponse) String 

func (x *ListSubscriptionsResponse) String() string

type ListSubscriptionsWithPrefixRequest added in v0.3.1 

type ListSubscriptionsWithPrefixRequest struct {
	Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSubscriptionsWithPrefixRequest) Descriptor deprecated added in v0.3.1 

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

Deprecated: Use ListSubscriptionsWithPrefixRequest.ProtoReflect.Descriptor instead.

func (*ListSubscriptionsWithPrefixRequest) GetPrefix added in v0.3.1 

func (x *ListSubscriptionsWithPrefixRequest) GetPrefix() string

func (*ListSubscriptionsWithPrefixRequest) ProtoMessage added in v0.3.1 

func (*ListSubscriptionsWithPrefixRequest) ProtoMessage()

func (*ListSubscriptionsWithPrefixRequest) ProtoReflect added in v0.3.1 

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

func (*ListSubscriptionsWithPrefixRequest) Reset added in v0.3.1 

func (x *ListSubscriptionsWithPrefixRequest) Reset()

func (*ListSubscriptionsWithPrefixRequest) String added in v0.3.1 

func (x *ListSubscriptionsWithPrefixRequest) String() string

type ListViewsRequest 

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

func (*ListViewsRequest) Descriptor deprecated 

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

Deprecated: Use ListViewsRequest.ProtoReflect.Descriptor instead.

func (*ListViewsRequest) ProtoMessage 

func (*ListViewsRequest) ProtoMessage()

func (*ListViewsRequest) ProtoReflect 

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

func (*ListViewsRequest) Reset 

func (x *ListViewsRequest) Reset()

func (*ListViewsRequest) String 

func (x *ListViewsRequest) String() string

type ListViewsResponse 

type ListViewsResponse struct {
	Views []*View `protobuf:"bytes,1,rep,name=views,proto3" json:"views,omitempty"`
	// contains filtered or unexported fields
}

func (*ListViewsResponse) Descriptor deprecated 

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

Deprecated: Use ListViewsResponse.ProtoReflect.Descriptor instead.

func (*ListViewsResponse) GetViews 

func (x *ListViewsResponse) GetViews() []*View

func (*ListViewsResponse) ProtoMessage 

func (*ListViewsResponse) ProtoMessage()

func (*ListViewsResponse) ProtoReflect 

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

func (*ListViewsResponse) Reset 

func (x *ListViewsResponse) Reset()

func (*ListViewsResponse) String 

func (x *ListViewsResponse) String() string

type LookupResourceRequest added in v0.3.1 

type LookupResourceRequest struct {
	ResType ResourceType `protobuf:"varint,1,opt,name=resType,proto3,enum=hstream.server.ResourceType" json:"resType,omitempty"`
	ResId   string       `protobuf:"bytes,2,opt,name=resId,proto3" json:"resId,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupResourceRequest) Descriptor deprecated added in v0.3.1 

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

Deprecated: Use LookupResourceRequest.ProtoReflect.Descriptor instead.

func (*LookupResourceRequest) GetResId added in v0.3.1 

func (x *LookupResourceRequest) GetResId() string

func (*LookupResourceRequest) GetResType added in v0.3.1 

func (x *LookupResourceRequest) GetResType() ResourceType

func (*LookupResourceRequest) ProtoMessage added in v0.3.1 

func (*LookupResourceRequest) ProtoMessage()

func (*LookupResourceRequest) ProtoReflect added in v0.3.1 

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

func (*LookupResourceRequest) Reset added in v0.3.1 

func (x *LookupResourceRequest) Reset()

func (*LookupResourceRequest) String added in v0.3.1 

func (x *LookupResourceRequest) String() string

type LookupShardReaderRequest added in v0.2.0 

type LookupShardReaderRequest struct {
	ReaderId string `protobuf:"bytes,1,opt,name=readerId,proto3" json:"readerId,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupShardReaderRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use LookupShardReaderRequest.ProtoReflect.Descriptor instead.

func (*LookupShardReaderRequest) GetReaderId added in v0.2.0 

func (x *LookupShardReaderRequest) GetReaderId() string

func (*LookupShardReaderRequest) ProtoMessage added in v0.2.0 

func (*LookupShardReaderRequest) ProtoMessage()

func (*LookupShardReaderRequest) ProtoReflect added in v0.2.0 

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

func (*LookupShardReaderRequest) Reset added in v0.2.0 

func (x *LookupShardReaderRequest) Reset()

func (*LookupShardReaderRequest) String added in v0.2.0 

func (x *LookupShardReaderRequest) String() string

type LookupShardReaderResponse added in v0.2.0 

type LookupShardReaderResponse struct {
	ReaderId   string      `protobuf:"bytes,1,opt,name=readerId,proto3" json:"readerId,omitempty"`
	ServerNode *ServerNode `protobuf:"bytes,2,opt,name=serverNode,proto3" json:"serverNode,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupShardReaderResponse) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use LookupShardReaderResponse.ProtoReflect.Descriptor instead.

func (*LookupShardReaderResponse) GetReaderId added in v0.2.0 

func (x *LookupShardReaderResponse) GetReaderId() string

func (*LookupShardReaderResponse) GetServerNode added in v0.2.0 

func (x *LookupShardReaderResponse) GetServerNode() *ServerNode

func (*LookupShardReaderResponse) ProtoMessage added in v0.2.0 

func (*LookupShardReaderResponse) ProtoMessage()

func (*LookupShardReaderResponse) ProtoReflect added in v0.2.0 

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

func (*LookupShardReaderResponse) Reset added in v0.2.0 

func (x *LookupShardReaderResponse) Reset()

func (*LookupShardReaderResponse) String added in v0.2.0 

func (x *LookupShardReaderResponse) String() string

type LookupShardRequest added in v0.2.0 

type LookupShardRequest struct {
	ShardId uint64 `protobuf:"varint,1,opt,name=shardId,proto3" json:"shardId,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupShardRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use LookupShardRequest.ProtoReflect.Descriptor instead.

func (*LookupShardRequest) GetShardId added in v0.2.0 

func (x *LookupShardRequest) GetShardId() uint64

func (*LookupShardRequest) ProtoMessage added in v0.2.0 

func (*LookupShardRequest) ProtoMessage()

func (*LookupShardRequest) ProtoReflect added in v0.2.0 

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

func (*LookupShardRequest) Reset added in v0.2.0 

func (x *LookupShardRequest) Reset()

func (*LookupShardRequest) String added in v0.2.0 

func (x *LookupShardRequest) String() string

type LookupShardResponse added in v0.2.0 

type LookupShardResponse struct {
	ShardId    uint64      `protobuf:"varint,1,opt,name=shardId,proto3" json:"shardId,omitempty"`
	ServerNode *ServerNode `protobuf:"bytes,2,opt,name=serverNode,proto3" json:"serverNode,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupShardResponse) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use LookupShardResponse.ProtoReflect.Descriptor instead.

func (*LookupShardResponse) GetServerNode added in v0.2.0 

func (x *LookupShardResponse) GetServerNode() *ServerNode

func (*LookupShardResponse) GetShardId added in v0.2.0 

func (x *LookupShardResponse) GetShardId() uint64

func (*LookupShardResponse) ProtoMessage added in v0.2.0 

func (*LookupShardResponse) ProtoMessage()

func (*LookupShardResponse) ProtoReflect added in v0.2.0 

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

func (*LookupShardResponse) Reset added in v0.2.0 

func (x *LookupShardResponse) Reset()

func (*LookupShardResponse) String added in v0.2.0 

func (x *LookupShardResponse) String() string

type LookupSubscriptionRequest 

type LookupSubscriptionRequest struct {
	SubscriptionId string `protobuf:"bytes,1,opt,name=subscriptionId,proto3" json:"subscriptionId,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use LookupSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*LookupSubscriptionRequest) GetSubscriptionId 

func (x *LookupSubscriptionRequest) GetSubscriptionId() string

func (*LookupSubscriptionRequest) ProtoMessage 

func (*LookupSubscriptionRequest) ProtoMessage()

func (*LookupSubscriptionRequest) ProtoReflect 

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

func (*LookupSubscriptionRequest) Reset 

func (x *LookupSubscriptionRequest) Reset()

func (*LookupSubscriptionRequest) String 

func (x *LookupSubscriptionRequest) String() string

type LookupSubscriptionResponse 

type LookupSubscriptionResponse struct {
	SubscriptionId string      `protobuf:"bytes,1,opt,name=subscriptionId,proto3" json:"subscriptionId,omitempty"`
	ServerNode     *ServerNode `protobuf:"bytes,2,opt,name=serverNode,proto3" json:"serverNode,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupSubscriptionResponse) Descriptor deprecated 

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

Deprecated: Use LookupSubscriptionResponse.ProtoReflect.Descriptor instead.

func (*LookupSubscriptionResponse) GetServerNode 

func (x *LookupSubscriptionResponse) GetServerNode() *ServerNode

func (*LookupSubscriptionResponse) GetSubscriptionId 

func (x *LookupSubscriptionResponse) GetSubscriptionId() string

func (*LookupSubscriptionResponse) ProtoMessage 

func (*LookupSubscriptionResponse) ProtoMessage()

func (*LookupSubscriptionResponse) ProtoReflect 

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

func (*LookupSubscriptionResponse) Reset 

func (x *LookupSubscriptionResponse) Reset()

func (*LookupSubscriptionResponse) String 

func (x *LookupSubscriptionResponse) String() string

type NodeState 

type NodeState int32
const (
	NodeState_Starting    NodeState = 0
	NodeState_Running     NodeState = 1
	NodeState_Unavailable NodeState = 2
	NodeState_Dead        NodeState = 3
)

func (NodeState) Descriptor 

func (NodeState) Descriptor() protoreflect.EnumDescriptor

func (NodeState) Enum 

func (x NodeState) Enum() *NodeState

func (NodeState) EnumDescriptor deprecated 

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

Deprecated: Use NodeState.Descriptor instead.

func (NodeState) Number 

func (x NodeState) Number() protoreflect.EnumNumber

func (NodeState) String 

func (x NodeState) String() string

func (NodeState) Type 

func (NodeState) Type() protoreflect.EnumType

type ParseSqlRequest added in v0.3.2 

type ParseSqlRequest struct {
	Sql string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
	// contains filtered or unexported fields
}

func (*ParseSqlRequest) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use ParseSqlRequest.ProtoReflect.Descriptor instead.

func (*ParseSqlRequest) GetSql added in v0.3.2 

func (x *ParseSqlRequest) GetSql() string

func (*ParseSqlRequest) ProtoMessage added in v0.3.2 

func (*ParseSqlRequest) ProtoMessage()

func (*ParseSqlRequest) ProtoReflect added in v0.3.2 

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

func (*ParseSqlRequest) Reset added in v0.3.2 

func (x *ParseSqlRequest) Reset()

func (*ParseSqlRequest) String added in v0.3.2 

func (x *ParseSqlRequest) String() string

type ParseSqlResponse added in v0.3.2 

type ParseSqlResponse struct {

	// Types that are assignable to Sql:
	//
	//	*ParseSqlResponse_EvqSql
	Sql isParseSqlResponse_Sql `protobuf_oneof:"sql"`
	// contains filtered or unexported fields
}

func (*ParseSqlResponse) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use ParseSqlResponse.ProtoReflect.Descriptor instead.

func (*ParseSqlResponse) GetEvqSql added in v0.3.2 

func (x *ParseSqlResponse) GetEvqSql() *ExecuteViewQuerySql

func (*ParseSqlResponse) GetSql added in v0.3.2 

func (m *ParseSqlResponse) GetSql() isParseSqlResponse_Sql

func (*ParseSqlResponse) ProtoMessage added in v0.3.2 

func (*ParseSqlResponse) ProtoMessage()

func (*ParseSqlResponse) ProtoReflect added in v0.3.2 

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

func (*ParseSqlResponse) Reset added in v0.3.2 

func (x *ParseSqlResponse) Reset()

func (*ParseSqlResponse) String added in v0.3.2 

func (x *ParseSqlResponse) String() string

type ParseSqlResponse_EvqSql added in v0.3.2 

type ParseSqlResponse_EvqSql struct {
	EvqSql *ExecuteViewQuerySql `protobuf:"bytes,1,opt,name=evqSql,proto3,oneof"`
}

type PauseConnectorRequest added in v0.2.0 

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

func (*PauseConnectorRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use PauseConnectorRequest.ProtoReflect.Descriptor instead.

func (*PauseConnectorRequest) GetName added in v0.2.0 

func (x *PauseConnectorRequest) GetName() string

func (*PauseConnectorRequest) ProtoMessage added in v0.2.0 

func (*PauseConnectorRequest) ProtoMessage()

func (*PauseConnectorRequest) ProtoReflect added in v0.2.0 

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

func (*PauseConnectorRequest) Reset added in v0.2.0 

func (x *PauseConnectorRequest) Reset()

func (*PauseConnectorRequest) String added in v0.2.0 

func (x *PauseConnectorRequest) String() string

type PauseQueryRequest added in v0.3.2 

type PauseQueryRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*PauseQueryRequest) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use PauseQueryRequest.ProtoReflect.Descriptor instead.

func (*PauseQueryRequest) GetId added in v0.3.2 

func (x *PauseQueryRequest) GetId() string

func (*PauseQueryRequest) ProtoMessage added in v0.3.2 

func (*PauseQueryRequest) ProtoMessage()

func (*PauseQueryRequest) ProtoReflect added in v0.3.2 

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

func (*PauseQueryRequest) Reset added in v0.3.2 

func (x *PauseQueryRequest) Reset()

func (*PauseQueryRequest) String added in v0.3.2 

func (x *PauseQueryRequest) String() string

type PerStreamTimeSeriesStatsAllRequest 

type PerStreamTimeSeriesStatsAllRequest struct {
	Method    string             `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Intervals *StatsIntervalVals `protobuf:"bytes,2,opt,name=intervals,proto3" json:"intervals,omitempty"`
	// contains filtered or unexported fields
}

func (*PerStreamTimeSeriesStatsAllRequest) Descriptor deprecated 

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

Deprecated: Use PerStreamTimeSeriesStatsAllRequest.ProtoReflect.Descriptor instead.

func (*PerStreamTimeSeriesStatsAllRequest) GetIntervals 

func (x *PerStreamTimeSeriesStatsAllRequest) GetIntervals() *StatsIntervalVals

func (*PerStreamTimeSeriesStatsAllRequest) GetMethod 

func (x *PerStreamTimeSeriesStatsAllRequest) GetMethod() string

func (*PerStreamTimeSeriesStatsAllRequest) ProtoMessage 

func (*PerStreamTimeSeriesStatsAllRequest) ProtoMessage()

func (*PerStreamTimeSeriesStatsAllRequest) ProtoReflect 

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

func (*PerStreamTimeSeriesStatsAllRequest) Reset 

func (x *PerStreamTimeSeriesStatsAllRequest) Reset()

func (*PerStreamTimeSeriesStatsAllRequest) String 

func (x *PerStreamTimeSeriesStatsAllRequest) String() string

type PerStreamTimeSeriesStatsAllResponse 

type PerStreamTimeSeriesStatsAllResponse struct {
	Stats map[string]*StatsDoubleVals `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PerStreamTimeSeriesStatsAllResponse) Descriptor deprecated 

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

Deprecated: Use PerStreamTimeSeriesStatsAllResponse.ProtoReflect.Descriptor instead.

func (*PerStreamTimeSeriesStatsAllResponse) GetStats 

func (x *PerStreamTimeSeriesStatsAllResponse) GetStats() map[string]*StatsDoubleVals

func (*PerStreamTimeSeriesStatsAllResponse) ProtoMessage 

func (*PerStreamTimeSeriesStatsAllResponse) ProtoMessage()

func (*PerStreamTimeSeriesStatsAllResponse) ProtoReflect 

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

func (*PerStreamTimeSeriesStatsAllResponse) Reset 

func (x *PerStreamTimeSeriesStatsAllResponse) Reset()

func (*PerStreamTimeSeriesStatsAllResponse) String 

func (x *PerStreamTimeSeriesStatsAllResponse) String() string

type PerStreamTimeSeriesStatsRequest 

type PerStreamTimeSeriesStatsRequest struct {
	Method     string             `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	StreamName string             `protobuf:"bytes,2,opt,name=streamName,proto3" json:"streamName,omitempty"`
	Intervals  *StatsIntervalVals `protobuf:"bytes,3,opt,name=intervals,proto3" json:"intervals,omitempty"`
	// contains filtered or unexported fields
}

func (*PerStreamTimeSeriesStatsRequest) Descriptor deprecated 

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

Deprecated: Use PerStreamTimeSeriesStatsRequest.ProtoReflect.Descriptor instead.

func (*PerStreamTimeSeriesStatsRequest) GetIntervals 

func (x *PerStreamTimeSeriesStatsRequest) GetIntervals() *StatsIntervalVals

func (*PerStreamTimeSeriesStatsRequest) GetMethod 

func (x *PerStreamTimeSeriesStatsRequest) GetMethod() string

func (*PerStreamTimeSeriesStatsRequest) GetStreamName 

func (x *PerStreamTimeSeriesStatsRequest) GetStreamName() string

func (*PerStreamTimeSeriesStatsRequest) ProtoMessage 

func (*PerStreamTimeSeriesStatsRequest) ProtoMessage()

func (*PerStreamTimeSeriesStatsRequest) ProtoReflect 

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

func (*PerStreamTimeSeriesStatsRequest) Reset 

func (x *PerStreamTimeSeriesStatsRequest) Reset()

func (*PerStreamTimeSeriesStatsRequest) String 

func (x *PerStreamTimeSeriesStatsRequest) String() string

type PerStreamTimeSeriesStatsResponse 

type PerStreamTimeSeriesStatsResponse struct {
	Stats *StatsDoubleVals `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"`
	// contains filtered or unexported fields
}

func (*PerStreamTimeSeriesStatsResponse) Descriptor deprecated 

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

Deprecated: Use PerStreamTimeSeriesStatsResponse.ProtoReflect.Descriptor instead.

func (*PerStreamTimeSeriesStatsResponse) GetStats 

func (x *PerStreamTimeSeriesStatsResponse) GetStats() *StatsDoubleVals

func (*PerStreamTimeSeriesStatsResponse) ProtoMessage 

func (*PerStreamTimeSeriesStatsResponse) ProtoMessage()

func (*PerStreamTimeSeriesStatsResponse) ProtoReflect 

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

func (*PerStreamTimeSeriesStatsResponse) Reset 

func (x *PerStreamTimeSeriesStatsResponse) Reset()

func (*PerStreamTimeSeriesStatsResponse) String 

func (x *PerStreamTimeSeriesStatsResponse) String() string

type Query 

type Query struct {
	Id          string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Status      TaskStatusPB `protobuf:"varint,2,opt,name=status,proto3,enum=hstream.server.TaskStatusPB" json:"status,omitempty"`
	CreatedTime int64        `protobuf:"varint,3,opt,name=createdTime,proto3" json:"createdTime,omitempty"`
	QueryText   string       `protobuf:"bytes,4,opt,name=queryText,proto3" json:"queryText,omitempty"`
	Sources     []string     `protobuf:"bytes,5,rep,name=sources,proto3" json:"sources,omitempty"`
	// type:
	//
	//	CreateStreamAs: resultName is result stream name
	//	CreateViewAs: resultName is result view name
	ResultName string    `protobuf:"bytes,6,opt,name=resultName,proto3" json:"resultName,omitempty"`
	Type       QueryType `protobuf:"varint,7,opt,name=type,proto3,enum=hstream.server.QueryType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*Query) Descriptor deprecated 

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

Deprecated: Use Query.ProtoReflect.Descriptor instead.

func (*Query) GetCreatedTime 

func (x *Query) GetCreatedTime() int64

func (*Query) GetId 

func (x *Query) GetId() string

func (*Query) GetQueryText 

func (x *Query) GetQueryText() string

func (*Query) GetResultName added in v0.3.2 

func (x *Query) GetResultName() string

func (*Query) GetSources added in v0.3.2 

func (x *Query) GetSources() []string

func (*Query) GetStatus 

func (x *Query) GetStatus() TaskStatusPB

func (*Query) GetType added in v0.3.2 

func (x *Query) GetType() QueryType

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) ProtoReflect 

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

func (*Query) Reset 

func (x *Query) Reset()

func (*Query) String 

func (x *Query) String() string

type QueryStats added in v0.3.2 

type QueryStats int32
const (
	QueryStats_TotalInputRecords  QueryStats = 0
	QueryStats_TotalOutputRecords QueryStats = 1
	QueryStats_TotalExecuteErrors QueryStats = 2
)

func (QueryStats) Descriptor added in v0.3.2 

func (QueryStats) Descriptor() protoreflect.EnumDescriptor

func (QueryStats) Enum added in v0.3.2 

func (x QueryStats) Enum() *QueryStats

func (QueryStats) EnumDescriptor deprecated added in v0.3.2 

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

Deprecated: Use QueryStats.Descriptor instead.

func (QueryStats) Number added in v0.3.2 

func (x QueryStats) Number() protoreflect.EnumNumber

func (QueryStats) String added in v0.3.2 

func (x QueryStats) String() string

func (QueryStats) Type added in v0.3.2 

func (QueryStats) Type() protoreflect.EnumType

type QueryType added in v0.3.2 

type QueryType int32
const (
	QueryType_CreateStreamAs QueryType = 0
	QueryType_CreateViewAs   QueryType = 1
)

func (QueryType) Descriptor added in v0.3.2 

func (QueryType) Descriptor() protoreflect.EnumDescriptor

func (QueryType) Enum added in v0.3.2 

func (x QueryType) Enum() *QueryType

func (QueryType) EnumDescriptor deprecated added in v0.3.2 

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

Deprecated: Use QueryType.Descriptor instead.

func (QueryType) Number added in v0.3.2 

func (x QueryType) Number() protoreflect.EnumNumber

func (QueryType) String added in v0.3.2 

func (x QueryType) String() string

func (QueryType) Type added in v0.3.2 

func (QueryType) Type() protoreflect.EnumType

type ReadShardRequest added in v0.2.0 

type ReadShardRequest struct {
	ReaderId   string `protobuf:"bytes,1,opt,name=readerId,proto3" json:"readerId,omitempty"`
	MaxRecords uint32 `protobuf:"varint,2,opt,name=maxRecords,proto3" json:"maxRecords,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadShardRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use ReadShardRequest.ProtoReflect.Descriptor instead.

func (*ReadShardRequest) GetMaxRecords added in v0.2.0 

func (x *ReadShardRequest) GetMaxRecords() uint32

func (*ReadShardRequest) GetReaderId added in v0.2.0 

func (x *ReadShardRequest) GetReaderId() string

func (*ReadShardRequest) ProtoMessage added in v0.2.0 

func (*ReadShardRequest) ProtoMessage()

func (*ReadShardRequest) ProtoReflect added in v0.2.0 

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

func (*ReadShardRequest) Reset added in v0.2.0 

func (x *ReadShardRequest) Reset()

func (*ReadShardRequest) String added in v0.2.0 

func (x *ReadShardRequest) String() string

type ReadShardResponse added in v0.2.0 

type ReadShardResponse struct {
	ReceivedRecords []*ReceivedRecord `protobuf:"bytes,1,rep,name=receivedRecords,proto3" json:"receivedRecords,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadShardResponse) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use ReadShardResponse.ProtoReflect.Descriptor instead.

func (*ReadShardResponse) GetReceivedRecords added in v0.2.0 

func (x *ReadShardResponse) GetReceivedRecords() []*ReceivedRecord

func (*ReadShardResponse) ProtoMessage added in v0.2.0 

func (*ReadShardResponse) ProtoMessage()

func (*ReadShardResponse) ProtoReflect added in v0.2.0 

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

func (*ReadShardResponse) Reset added in v0.2.0 

func (x *ReadShardResponse) Reset()

func (*ReadShardResponse) String added in v0.2.0 

func (x *ReadShardResponse) String() string

type ReadShardStreamRequest added in v0.3.2 

type ReadShardStreamRequest struct {
	ReaderId    string       `protobuf:"bytes,1,opt,name=readerId,proto3" json:"readerId,omitempty"`
	ShardId     uint64       `protobuf:"varint,2,opt,name=shardId,proto3" json:"shardId,omitempty"`
	ShardOffset *ShardOffset `protobuf:"bytes,3,opt,name=shardOffset,proto3" json:"shardOffset,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadShardStreamRequest) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use ReadShardStreamRequest.ProtoReflect.Descriptor instead.

func (*ReadShardStreamRequest) GetReaderId added in v0.3.2 

func (x *ReadShardStreamRequest) GetReaderId() string

func (*ReadShardStreamRequest) GetShardId added in v0.3.2 

func (x *ReadShardStreamRequest) GetShardId() uint64

func (*ReadShardStreamRequest) GetShardOffset added in v0.3.2 

func (x *ReadShardStreamRequest) GetShardOffset() *ShardOffset

func (*ReadShardStreamRequest) ProtoMessage added in v0.3.2 

func (*ReadShardStreamRequest) ProtoMessage()

func (*ReadShardStreamRequest) ProtoReflect added in v0.3.2 

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

func (*ReadShardStreamRequest) Reset added in v0.3.2 

func (x *ReadShardStreamRequest) Reset()

func (*ReadShardStreamRequest) String added in v0.3.2 

func (x *ReadShardStreamRequest) String() string

type ReadShardStreamResponse added in v0.3.2 

type ReadShardStreamResponse struct {
	ReceivedRecords []*ReceivedRecord `protobuf:"bytes,1,rep,name=receivedRecords,proto3" json:"receivedRecords,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadShardStreamResponse) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use ReadShardStreamResponse.ProtoReflect.Descriptor instead.

func (*ReadShardStreamResponse) GetReceivedRecords added in v0.3.2 

func (x *ReadShardStreamResponse) GetReceivedRecords() []*ReceivedRecord

func (*ReadShardStreamResponse) ProtoMessage added in v0.3.2 

func (*ReadShardStreamResponse) ProtoMessage()

func (*ReadShardStreamResponse) ProtoReflect added in v0.3.2 

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

func (*ReadShardStreamResponse) Reset added in v0.3.2 

func (x *ReadShardStreamResponse) Reset()

func (*ReadShardStreamResponse) String added in v0.3.2 

func (x *ReadShardStreamResponse) String() string

type ReceivedRecord 

type ReceivedRecord struct {
	RecordIds []*RecordId    `protobuf:"bytes,1,rep,name=recordIds,proto3" json:"recordIds,omitempty"`
	Record    *BatchedRecord `protobuf:"bytes,2,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*ReceivedRecord) Descriptor deprecated 

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

Deprecated: Use ReceivedRecord.ProtoReflect.Descriptor instead.

func (*ReceivedRecord) GetRecord 

func (x *ReceivedRecord) GetRecord() *BatchedRecord

func (*ReceivedRecord) GetRecordIds added in v0.3.0 

func (x *ReceivedRecord) GetRecordIds() []*RecordId

func (*ReceivedRecord) ProtoMessage 

func (*ReceivedRecord) ProtoMessage()

func (*ReceivedRecord) ProtoReflect 

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

func (*ReceivedRecord) Reset 

func (x *ReceivedRecord) Reset()

func (*ReceivedRecord) String 

func (x *ReceivedRecord) String() string

type RecordId 

type RecordId struct {
	ShardId uint64 `protobuf:"varint,1,opt,name=shardId,proto3" json:"shardId,omitempty"`
	// LSN of the total batch records
	BatchId uint64 `protobuf:"varint,2,opt,name=batchId,proto3" json:"batchId,omitempty"`
	// Offset of each record in the batch
	BatchIndex uint32 `protobuf:"varint,3,opt,name=batchIndex,proto3" json:"batchIndex,omitempty"`
	// contains filtered or unexported fields
}

func (*RecordId) Descriptor deprecated 

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

Deprecated: Use RecordId.ProtoReflect.Descriptor instead.

func (*RecordId) GetBatchId 

func (x *RecordId) GetBatchId() uint64

func (*RecordId) GetBatchIndex 

func (x *RecordId) GetBatchIndex() uint32

func (*RecordId) GetShardId 

func (x *RecordId) GetShardId() uint64

func (*RecordId) ProtoMessage 

func (*RecordId) ProtoMessage()

func (*RecordId) ProtoReflect 

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

func (*RecordId) Reset 

func (x *RecordId) Reset()

func (*RecordId) String 

func (x *RecordId) String() string

type ResourceType added in v0.3.1 

type ResourceType int32
const (
	ResourceType_ResStream       ResourceType = 0
	ResourceType_ResSubscription ResourceType = 1
	ResourceType_ResShard        ResourceType = 2
	ResourceType_ResShardReader  ResourceType = 3
	ResourceType_ResConnector    ResourceType = 4
	ResourceType_ResQuery        ResourceType = 5
	ResourceType_ResView         ResourceType = 6
)

func (ResourceType) Descriptor added in v0.3.1 

func (ResourceType) Descriptor() protoreflect.EnumDescriptor

func (ResourceType) Enum added in v0.3.1 

func (x ResourceType) Enum() *ResourceType

func (ResourceType) EnumDescriptor deprecated added in v0.3.1 

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

Deprecated: Use ResourceType.Descriptor instead.

func (ResourceType) Number added in v0.3.1 

func (x ResourceType) Number() protoreflect.EnumNumber

func (ResourceType) String added in v0.3.1 

func (x ResourceType) String() string

func (ResourceType) Type added in v0.3.1 

func (ResourceType) Type() protoreflect.EnumType

type ResumeConnectorRequest added in v0.2.0 

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

func (*ResumeConnectorRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use ResumeConnectorRequest.ProtoReflect.Descriptor instead.

func (*ResumeConnectorRequest) GetName added in v0.2.0 

func (x *ResumeConnectorRequest) GetName() string

func (*ResumeConnectorRequest) ProtoMessage added in v0.2.0 

func (*ResumeConnectorRequest) ProtoMessage()

func (*ResumeConnectorRequest) ProtoReflect added in v0.2.0 

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

func (*ResumeConnectorRequest) Reset added in v0.2.0 

func (x *ResumeConnectorRequest) Reset()

func (*ResumeConnectorRequest) String added in v0.2.0 

func (x *ResumeConnectorRequest) String() string

type ResumeQueryRequest added in v0.3.2 

type ResumeQueryRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ResumeQueryRequest) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use ResumeQueryRequest.ProtoReflect.Descriptor instead.

func (*ResumeQueryRequest) GetId added in v0.3.2 

func (x *ResumeQueryRequest) GetId() string

func (*ResumeQueryRequest) ProtoMessage added in v0.3.2 

func (*ResumeQueryRequest) ProtoMessage()

func (*ResumeQueryRequest) ProtoReflect added in v0.3.2 

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

func (*ResumeQueryRequest) Reset added in v0.3.2 

func (x *ResumeQueryRequest) Reset()

func (*ResumeQueryRequest) String added in v0.3.2 

func (x *ResumeQueryRequest) String() string

type ServerNode 

type ServerNode struct {
	Id   uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Port uint32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerNode) Descriptor deprecated 

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

Deprecated: Use ServerNode.ProtoReflect.Descriptor instead.

func (*ServerNode) GetHost 

func (x *ServerNode) GetHost() string

func (*ServerNode) GetId 

func (x *ServerNode) GetId() uint32

func (*ServerNode) GetPort 

func (x *ServerNode) GetPort() uint32

func (*ServerNode) ProtoMessage 

func (*ServerNode) ProtoMessage()

func (*ServerNode) ProtoReflect 

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

func (*ServerNode) Reset 

func (x *ServerNode) Reset()

func (*ServerNode) String 

func (x *ServerNode) String() string

type ServerNodeStatus 

type ServerNodeStatus struct {
	Node  *ServerNode `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	State NodeState   `protobuf:"varint,2,opt,name=state,proto3,enum=hstream.server.NodeState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerNodeStatus) Descriptor deprecated 

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

Deprecated: Use ServerNodeStatus.ProtoReflect.Descriptor instead.

func (*ServerNodeStatus) GetNode 

func (x *ServerNodeStatus) GetNode() *ServerNode

func (*ServerNodeStatus) GetState 

func (x *ServerNodeStatus) GetState() NodeState

func (*ServerNodeStatus) ProtoMessage 

func (*ServerNodeStatus) ProtoMessage()

func (*ServerNodeStatus) ProtoReflect 

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

func (*ServerNodeStatus) Reset 

func (x *ServerNodeStatus) Reset()

func (*ServerNodeStatus) String 

func (x *ServerNodeStatus) String() string

type Shard added in v0.2.0 

type Shard struct {
	StreamName        string `protobuf:"bytes,1,opt,name=streamName,proto3" json:"streamName,omitempty"`
	ShardId           uint64 `protobuf:"varint,2,opt,name=shardId,proto3" json:"shardId,omitempty"`
	StartHashRangeKey string `protobuf:"bytes,3,opt,name=startHashRangeKey,proto3" json:"startHashRangeKey,omitempty"`
	EndHashRangeKey   string `protobuf:"bytes,4,opt,name=endHashRangeKey,proto3" json:"endHashRangeKey,omitempty"`
	Epoch             uint64 `protobuf:"varint,5,opt,name=epoch,proto3" json:"epoch,omitempty"`
	IsActive          bool   `protobuf:"varint,6,opt,name=isActive,proto3" json:"isActive,omitempty"`
	// contains filtered or unexported fields
}

func (*Shard) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use Shard.ProtoReflect.Descriptor instead.

func (*Shard) GetEndHashRangeKey added in v0.2.0 

func (x *Shard) GetEndHashRangeKey() string

func (*Shard) GetEpoch added in v0.2.0 

func (x *Shard) GetEpoch() uint64

func (*Shard) GetIsActive added in v0.2.0 

func (x *Shard) GetIsActive() bool

func (*Shard) GetShardId added in v0.2.0 

func (x *Shard) GetShardId() uint64

func (*Shard) GetStartHashRangeKey added in v0.2.0 

func (x *Shard) GetStartHashRangeKey() string

func (*Shard) GetStreamName added in v0.2.0 

func (x *Shard) GetStreamName() string

func (*Shard) ProtoMessage added in v0.2.0 

func (*Shard) ProtoMessage()

func (*Shard) ProtoReflect added in v0.2.0 

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

func (*Shard) Reset added in v0.2.0 

func (x *Shard) Reset()

func (*Shard) String added in v0.2.0 

func (x *Shard) String() string

type ShardOffset added in v0.2.0 

type ShardOffset struct {

	// Types that are assignable to Offset:
	//
	//	*ShardOffset_SpecialOffset
	//	*ShardOffset_RecordOffset
	//	*ShardOffset_TimestampOffset
	Offset isShardOffset_Offset `protobuf_oneof:"offset"`
	// contains filtered or unexported fields
}

func (*ShardOffset) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use ShardOffset.ProtoReflect.Descriptor instead.

func (*ShardOffset) GetOffset added in v0.2.0 

func (m *ShardOffset) GetOffset() isShardOffset_Offset

func (*ShardOffset) GetRecordOffset added in v0.2.0 

func (x *ShardOffset) GetRecordOffset() *RecordId

func (*ShardOffset) GetSpecialOffset added in v0.2.0 

func (x *ShardOffset) GetSpecialOffset() SpecialOffset

func (*ShardOffset) GetTimestampOffset added in v0.3.2 

func (x *ShardOffset) GetTimestampOffset() *TimestampOffset

func (*ShardOffset) ProtoMessage added in v0.2.0 

func (*ShardOffset) ProtoMessage()

func (*ShardOffset) ProtoReflect added in v0.2.0 

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

func (*ShardOffset) Reset added in v0.2.0 

func (x *ShardOffset) Reset()

func (*ShardOffset) String added in v0.2.0 

func (x *ShardOffset) String() string

type ShardOffset_RecordOffset added in v0.2.0 

type ShardOffset_RecordOffset struct {
	RecordOffset *RecordId `protobuf:"bytes,2,opt,name=recordOffset,proto3,oneof"`
}

type ShardOffset_SpecialOffset added in v0.2.0 

type ShardOffset_SpecialOffset struct {
	SpecialOffset SpecialOffset `protobuf:"varint,1,opt,name=specialOffset,proto3,enum=hstream.server.SpecialOffset,oneof"`
}

type ShardOffset_TimestampOffset added in v0.3.2 

type ShardOffset_TimestampOffset struct {
	TimestampOffset *TimestampOffset `protobuf:"bytes,3,opt,name=timestampOffset,proto3,oneof"`
}

type SpecialOffset added in v0.2.0 

type SpecialOffset int32
const (
	SpecialOffset_EARLIEST SpecialOffset = 0
	SpecialOffset_LATEST   SpecialOffset = 1
)

func (SpecialOffset) Descriptor added in v0.2.0 

func (SpecialOffset) Descriptor() protoreflect.EnumDescriptor

func (SpecialOffset) Enum added in v0.2.0 

func (x SpecialOffset) Enum() *SpecialOffset

func (SpecialOffset) EnumDescriptor deprecated added in v0.2.0 

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

Deprecated: Use SpecialOffset.Descriptor instead.

func (SpecialOffset) Number added in v0.2.0 

func (x SpecialOffset) Number() protoreflect.EnumNumber

func (SpecialOffset) String added in v0.2.0 

func (x SpecialOffset) String() string

func (SpecialOffset) Type added in v0.2.0 

func (SpecialOffset) Type() protoreflect.EnumType

type StatError added in v0.3.2 

type StatError struct {
	StatType *StatType `protobuf:"bytes,1,opt,name=statType,proto3" json:"statType,omitempty"`
	Message  string    `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*StatError) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use StatError.ProtoReflect.Descriptor instead.

func (*StatError) GetMessage added in v0.3.2 

func (x *StatError) GetMessage() string

func (*StatError) GetStatType added in v0.3.2 

func (x *StatError) GetStatType() *StatType

func (*StatError) ProtoMessage added in v0.3.2 

func (*StatError) ProtoMessage()

func (*StatError) ProtoReflect added in v0.3.2 

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

func (*StatError) Reset added in v0.3.2 

func (x *StatError) Reset()

func (*StatError) String added in v0.3.2 

func (x *StatError) String() string

type StatType added in v0.3.2 

type StatType struct {

	// Types that are assignable to Stat:
	//
	//	*StatType_StreamStat
	//	*StatType_SubStat
	//	*StatType_ConnStat
	//	*StatType_QueryStat
	//	*StatType_ViewStat
	Stat isStatType_Stat `protobuf_oneof:"stat"`
	// contains filtered or unexported fields
}

func (*StatType) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use StatType.ProtoReflect.Descriptor instead.

func (*StatType) GetConnStat added in v0.3.2 

func (x *StatType) GetConnStat() ConnectorStats

func (*StatType) GetQueryStat added in v0.3.2 

func (x *StatType) GetQueryStat() QueryStats

func (*StatType) GetStat added in v0.3.2 

func (m *StatType) GetStat() isStatType_Stat

func (*StatType) GetStreamStat added in v0.3.2 

func (x *StatType) GetStreamStat() StreamStats

func (*StatType) GetSubStat added in v0.3.2 

func (x *StatType) GetSubStat() SubscriptionStats

func (*StatType) GetViewStat added in v0.3.2 

func (x *StatType) GetViewStat() ViewStats

func (*StatType) ProtoMessage added in v0.3.2 

func (*StatType) ProtoMessage()

func (*StatType) ProtoReflect added in v0.3.2 

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

func (*StatType) Reset added in v0.3.2 

func (x *StatType) Reset()

func (*StatType) String added in v0.3.2 

func (x *StatType) String() string

type StatType_ConnStat added in v0.3.2 

type StatType_ConnStat struct {
	ConnStat ConnectorStats `protobuf:"varint,3,opt,name=connStat,proto3,enum=hstream.server.ConnectorStats,oneof"`
}

type StatType_QueryStat added in v0.3.2 

type StatType_QueryStat struct {
	QueryStat QueryStats `protobuf:"varint,4,opt,name=queryStat,proto3,enum=hstream.server.QueryStats,oneof"`
}

type StatType_StreamStat added in v0.3.2 

type StatType_StreamStat struct {
	StreamStat StreamStats `protobuf:"varint,1,opt,name=streamStat,proto3,enum=hstream.server.StreamStats,oneof"`
}

type StatType_SubStat added in v0.3.2 

type StatType_SubStat struct {
	SubStat SubscriptionStats `protobuf:"varint,2,opt,name=subStat,proto3,enum=hstream.server.SubscriptionStats,oneof"`
}

type StatType_ViewStat added in v0.3.2 

type StatType_ViewStat struct {
	ViewStat ViewStats `protobuf:"varint,5,opt,name=viewStat,proto3,enum=hstream.server.ViewStats,oneof"`
}

type StatValue added in v0.3.2 

type StatValue struct {
	StatType   *StatType        `protobuf:"bytes,1,opt,name=statType,proto3" json:"statType,omitempty"`
	StatValues map[string]int64 `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StatValue) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use StatValue.ProtoReflect.Descriptor instead.

func (*StatValue) GetStatType added in v0.3.2 

func (x *StatValue) GetStatType() *StatType

func (*StatValue) GetStatValues added in v0.3.2 

func (x *StatValue) GetStatValues() map[string]int64

func (*StatValue) ProtoMessage added in v0.3.2 

func (*StatValue) ProtoMessage()

func (*StatValue) ProtoReflect added in v0.3.2 

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

func (*StatValue) Reset added in v0.3.2 

func (x *StatValue) Reset()

func (*StatValue) String added in v0.3.2 

func (x *StatValue) String() string

type StatsDoubleVals 

type StatsDoubleVals struct {
	Vals []float64 `protobuf:"fixed64,1,rep,packed,name=vals,proto3" json:"vals,omitempty"`
	// contains filtered or unexported fields
}

func (*StatsDoubleVals) Descriptor deprecated 

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

Deprecated: Use StatsDoubleVals.ProtoReflect.Descriptor instead.

func (*StatsDoubleVals) GetVals 

func (x *StatsDoubleVals) GetVals() []float64

func (*StatsDoubleVals) ProtoMessage 

func (*StatsDoubleVals) ProtoMessage()

func (*StatsDoubleVals) ProtoReflect 

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

func (*StatsDoubleVals) Reset 

func (x *StatsDoubleVals) Reset()

func (*StatsDoubleVals) String 

func (x *StatsDoubleVals) String() string

type StatsIntervalVals 

type StatsIntervalVals struct {
	Intervals []int32 `protobuf:"varint,1,rep,packed,name=intervals,proto3" json:"intervals,omitempty"`
	// contains filtered or unexported fields
}

func (*StatsIntervalVals) Descriptor deprecated 

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

Deprecated: Use StatsIntervalVals.ProtoReflect.Descriptor instead.

func (*StatsIntervalVals) GetIntervals 

func (x *StatsIntervalVals) GetIntervals() []int32

func (*StatsIntervalVals) ProtoMessage 

func (*StatsIntervalVals) ProtoMessage()

func (*StatsIntervalVals) ProtoReflect 

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

func (*StatsIntervalVals) Reset 

func (x *StatsIntervalVals) Reset()

func (*StatsIntervalVals) String 

func (x *StatsIntervalVals) String() string

type Stream 

type Stream struct {
	StreamName        string               `protobuf:"bytes,1,opt,name=streamName,proto3" json:"streamName,omitempty"`
	ReplicationFactor uint32               `protobuf:"varint,2,opt,name=replicationFactor,proto3" json:"replicationFactor,omitempty"`
	BacklogDuration   uint32               `protobuf:"varint,3,opt,name=backlogDuration,proto3" json:"backlogDuration,omitempty"`
	ShardCount        uint32               `protobuf:"varint,4,opt,name=shardCount,proto3" json:"shardCount,omitempty"`
	CreationTime      *timestamp.Timestamp `protobuf:"bytes,5,opt,name=creationTime,proto3" json:"creationTime,omitempty"`
	// contains filtered or unexported fields
}

func (*Stream) Descriptor deprecated 

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

Deprecated: Use Stream.ProtoReflect.Descriptor instead.

func (*Stream) GetBacklogDuration 

func (x *Stream) GetBacklogDuration() uint32

func (*Stream) GetCreationTime added in v0.3.1 

func (x *Stream) GetCreationTime() *timestamp.Timestamp

func (*Stream) GetReplicationFactor 

func (x *Stream) GetReplicationFactor() uint32

func (*Stream) GetShardCount added in v0.2.0 

func (x *Stream) GetShardCount() uint32

func (*Stream) GetStreamName 

func (x *Stream) GetStreamName() string

func (*Stream) ProtoMessage 

func (*Stream) ProtoMessage()

func (*Stream) ProtoReflect 

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

func (*Stream) Reset 

func (x *Stream) Reset()

func (*Stream) String 

func (x *Stream) String() string

type StreamStats added in v0.3.1 

type StreamStats int32
const (
	StreamStats_AppendInBytes   StreamStats = 0
	StreamStats_AppendInRecords StreamStats = 1
	StreamStats_AppendTotal     StreamStats = 2
	StreamStats_AppendFailed    StreamStats = 3
)

func (StreamStats) Descriptor added in v0.3.1 

func (StreamStats) Descriptor() protoreflect.EnumDescriptor

func (StreamStats) Enum added in v0.3.1 

func (x StreamStats) Enum() *StreamStats

func (StreamStats) EnumDescriptor deprecated added in v0.3.1 

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

Deprecated: Use StreamStats.Descriptor instead.

func (StreamStats) Number added in v0.3.1 

func (x StreamStats) Number() protoreflect.EnumNumber

func (StreamStats) String added in v0.3.1 

func (x StreamStats) String() string

func (StreamStats) Type added in v0.3.1 

func (StreamStats) Type() protoreflect.EnumType

type StreamingFetchRequest 

type StreamingFetchRequest struct {
	SubscriptionId string      `protobuf:"bytes,1,opt,name=subscriptionId,proto3" json:"subscriptionId,omitempty"`
	ConsumerName   string      `protobuf:"bytes,2,opt,name=consumerName,proto3" json:"consumerName,omitempty"`
	AckIds         []*RecordId `protobuf:"bytes,3,rep,name=ackIds,proto3" json:"ackIds,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamingFetchRequest) Descriptor deprecated 

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

Deprecated: Use StreamingFetchRequest.ProtoReflect.Descriptor instead.

func (*StreamingFetchRequest) GetAckIds 

func (x *StreamingFetchRequest) GetAckIds() []*RecordId

func (*StreamingFetchRequest) GetConsumerName 

func (x *StreamingFetchRequest) GetConsumerName() string

func (*StreamingFetchRequest) GetSubscriptionId 

func (x *StreamingFetchRequest) GetSubscriptionId() string

func (*StreamingFetchRequest) ProtoMessage 

func (*StreamingFetchRequest) ProtoMessage()

func (*StreamingFetchRequest) ProtoReflect 

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

func (*StreamingFetchRequest) Reset 

func (x *StreamingFetchRequest) Reset()

func (*StreamingFetchRequest) String 

func (x *StreamingFetchRequest) String() string

type StreamingFetchResponse 

type StreamingFetchResponse struct {
	ReceivedRecords *ReceivedRecord `protobuf:"bytes,1,opt,name=receivedRecords,proto3" json:"receivedRecords,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamingFetchResponse) Descriptor deprecated 

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

Deprecated: Use StreamingFetchResponse.ProtoReflect.Descriptor instead.

func (*StreamingFetchResponse) GetReceivedRecords 

func (x *StreamingFetchResponse) GetReceivedRecords() *ReceivedRecord

func (*StreamingFetchResponse) ProtoMessage 

func (*StreamingFetchResponse) ProtoMessage()

func (*StreamingFetchResponse) ProtoReflect 

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

func (*StreamingFetchResponse) Reset 

func (x *StreamingFetchResponse) Reset()

func (*StreamingFetchResponse) String 

func (x *StreamingFetchResponse) String() string

type Subscription 

type Subscription struct {
	SubscriptionId    string               `protobuf:"bytes,1,opt,name=subscriptionId,proto3" json:"subscriptionId,omitempty"`
	StreamName        string               `protobuf:"bytes,2,opt,name=streamName,proto3" json:"streamName,omitempty"`
	AckTimeoutSeconds int32                `protobuf:"varint,3,opt,name=ackTimeoutSeconds,proto3" json:"ackTimeoutSeconds,omitempty"`
	MaxUnackedRecords int32                `protobuf:"varint,4,opt,name=maxUnackedRecords,proto3" json:"maxUnackedRecords,omitempty"`
	Offset            SpecialOffset        `protobuf:"varint,5,opt,name=offset,proto3,enum=hstream.server.SpecialOffset" json:"offset,omitempty"`
	CreationTime      *timestamp.Timestamp `protobuf:"bytes,6,opt,name=creationTime,proto3" json:"creationTime,omitempty"`
	// contains filtered or unexported fields
}

func (*Subscription) Descriptor deprecated 

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

Deprecated: Use Subscription.ProtoReflect.Descriptor instead.

func (*Subscription) GetAckTimeoutSeconds 

func (x *Subscription) GetAckTimeoutSeconds() int32

func (*Subscription) GetCreationTime added in v0.3.1 

func (x *Subscription) GetCreationTime() *timestamp.Timestamp

func (*Subscription) GetMaxUnackedRecords added in v0.1.1 

func (x *Subscription) GetMaxUnackedRecords() int32

func (*Subscription) GetOffset added in v0.2.0 

func (x *Subscription) GetOffset() SpecialOffset

func (*Subscription) GetStreamName 

func (x *Subscription) GetStreamName() string

func (*Subscription) GetSubscriptionId 

func (x *Subscription) GetSubscriptionId() string

func (*Subscription) ProtoMessage 

func (*Subscription) ProtoMessage()

func (*Subscription) ProtoReflect 

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

func (*Subscription) Reset 

func (x *Subscription) Reset()

func (*Subscription) String 

func (x *Subscription) String() string

type SubscriptionOffset added in v0.3.1 

type SubscriptionOffset struct {
	ShardId uint64 `protobuf:"varint,1,opt,name=shardId,proto3" json:"shardId,omitempty"`
	BatchId uint64 `protobuf:"varint,2,opt,name=batchId,proto3" json:"batchId,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionOffset) Descriptor deprecated added in v0.3.1 

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

Deprecated: Use SubscriptionOffset.ProtoReflect.Descriptor instead.

func (*SubscriptionOffset) GetBatchId added in v0.3.1 

func (x *SubscriptionOffset) GetBatchId() uint64

func (*SubscriptionOffset) GetShardId added in v0.3.1 

func (x *SubscriptionOffset) GetShardId() uint64

func (*SubscriptionOffset) ProtoMessage added in v0.3.1 

func (*SubscriptionOffset) ProtoMessage()

func (*SubscriptionOffset) ProtoReflect added in v0.3.1 

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

func (*SubscriptionOffset) Reset added in v0.3.1 

func (x *SubscriptionOffset) Reset()

func (*SubscriptionOffset) String added in v0.3.1 

func (x *SubscriptionOffset) String() string

type SubscriptionStats added in v0.3.1 

type SubscriptionStats int32
const (
	SubscriptionStats_SendOutBytes         SubscriptionStats = 0
	SubscriptionStats_SendOutRecords       SubscriptionStats = 1
	SubscriptionStats_SendOutRecordsFailed SubscriptionStats = 2
	SubscriptionStats_ResendRecords        SubscriptionStats = 3
	SubscriptionStats_ResendRecordsFailed  SubscriptionStats = 4
	SubscriptionStats_ReceivedAcks         SubscriptionStats = 5
	SubscriptionStats_RequestMessages      SubscriptionStats = 6
	SubscriptionStats_ResponseMessages     SubscriptionStats = 7
)

func (SubscriptionStats) Descriptor added in v0.3.1 

func (SubscriptionStats) Descriptor() protoreflect.EnumDescriptor

func (SubscriptionStats) Enum added in v0.3.1 

func (x SubscriptionStats) Enum() *SubscriptionStats

func (SubscriptionStats) EnumDescriptor deprecated added in v0.3.1 

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

Deprecated: Use SubscriptionStats.Descriptor instead.

func (SubscriptionStats) Number added in v0.3.1 

func (x SubscriptionStats) Number() protoreflect.EnumNumber

func (SubscriptionStats) String added in v0.3.1 

func (x SubscriptionStats) String() string

func (SubscriptionStats) Type added in v0.3.1 

func (SubscriptionStats) Type() protoreflect.EnumType

type TaskStatusPB 

type TaskStatusPB int32
const (
	TaskStatusPB_TASK_CREATING   TaskStatusPB = 0
	TaskStatusPB_TASK_RUNNING    TaskStatusPB = 1
	TaskStatusPB_TASK_ABORTED    TaskStatusPB = 2
	TaskStatusPB_TASK_PAUSED     TaskStatusPB = 3
	TaskStatusPB_TASK_RESUMING   TaskStatusPB = 4
	TaskStatusPB_TASK_TERMINATED TaskStatusPB = 5
	TaskStatusPB_TASK_UNKNOWN    TaskStatusPB = 6
)

func (TaskStatusPB) Descriptor 

func (TaskStatusPB) Descriptor() protoreflect.EnumDescriptor

func (TaskStatusPB) Enum 

func (x TaskStatusPB) Enum() *TaskStatusPB

func (TaskStatusPB) EnumDescriptor deprecated 

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

Deprecated: Use TaskStatusPB.Descriptor instead.

func (TaskStatusPB) Number 

func (x TaskStatusPB) Number() protoreflect.EnumNumber

func (TaskStatusPB) String 

func (x TaskStatusPB) String() string

func (TaskStatusPB) Type 

func (TaskStatusPB) Type() protoreflect.EnumType

type TerminateQueryRequest added in v0.3.2 

type TerminateQueryRequest struct {
	QueryId string `protobuf:"bytes,1,opt,name=queryId,proto3" json:"queryId,omitempty"`
	// contains filtered or unexported fields
}

func (*TerminateQueryRequest) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use TerminateQueryRequest.ProtoReflect.Descriptor instead.

func (*TerminateQueryRequest) GetQueryId added in v0.3.2 

func (x *TerminateQueryRequest) GetQueryId() string

func (*TerminateQueryRequest) ProtoMessage added in v0.3.2 

func (*TerminateQueryRequest) ProtoMessage()

func (*TerminateQueryRequest) ProtoReflect added in v0.3.2 

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

func (*TerminateQueryRequest) Reset added in v0.3.2 

func (x *TerminateQueryRequest) Reset()

func (*TerminateQueryRequest) String added in v0.3.2 

func (x *TerminateQueryRequest) String() string

type TimestampOffset added in v0.3.2 

type TimestampOffset struct {
	TimestampInMs  int64 `protobuf:"varint,1,opt,name=timestampInMs,proto3" json:"timestampInMs,omitempty"`
	StrictAccuracy bool  `protobuf:"varint,2,opt,name=strictAccuracy,proto3" json:"strictAccuracy,omitempty"`
	// contains filtered or unexported fields
}

func (*TimestampOffset) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use TimestampOffset.ProtoReflect.Descriptor instead.

func (*TimestampOffset) GetStrictAccuracy added in v0.3.2 

func (x *TimestampOffset) GetStrictAccuracy() bool

func (*TimestampOffset) GetTimestampInMs added in v0.3.2 

func (x *TimestampOffset) GetTimestampInMs() int64

func (*TimestampOffset) ProtoMessage added in v0.3.2 

func (*TimestampOffset) ProtoMessage()

func (*TimestampOffset) ProtoReflect added in v0.3.2 

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

func (*TimestampOffset) Reset added in v0.3.2 

func (x *TimestampOffset) Reset()

func (*TimestampOffset) String added in v0.3.2 

func (x *TimestampOffset) String() string

type UnimplementedHStreamApiServer 

type UnimplementedHStreamApiServer struct {
}

UnimplementedHStreamApiServer must be embedded to have forward compatible implementations.

func (UnimplementedHStreamApiServer) Append 

func (UnimplementedHStreamApiServer) Append(context.Context, *AppendRequest) (*AppendResponse, error)

func (UnimplementedHStreamApiServer) CheckSubscriptionExist 

func (UnimplementedHStreamApiServer) CheckSubscriptionExist(context.Context, *CheckSubscriptionExistRequest) (*CheckSubscriptionExistResponse, error)

func (UnimplementedHStreamApiServer) CreateConnector added in v0.1.5 

func (UnimplementedHStreamApiServer) CreateConnector(context.Context, *CreateConnectorRequest) (*Connector, error)

func (UnimplementedHStreamApiServer) CreateQuery 

func (UnimplementedHStreamApiServer) CreateQuery(context.Context, *CreateQueryRequest) (*Query, error)

func (UnimplementedHStreamApiServer) CreateQueryWithNamespace added in v0.3.2 

func (UnimplementedHStreamApiServer) CreateQueryWithNamespace(context.Context, *CreateQueryWithNamespaceRequest) (*Query, error)

func (UnimplementedHStreamApiServer) CreateShardReader added in v0.2.0 

func (UnimplementedHStreamApiServer) CreateShardReader(context.Context, *CreateShardReaderRequest) (*CreateShardReaderResponse, error)

func (UnimplementedHStreamApiServer) CreateStream 

func (UnimplementedHStreamApiServer) CreateStream(context.Context, *Stream) (*Stream, error)

func (UnimplementedHStreamApiServer) CreateSubscription 

func (UnimplementedHStreamApiServer) CreateSubscription(context.Context, *Subscription) (*Subscription, error)

func (UnimplementedHStreamApiServer) DeleteConnector 

func (UnimplementedHStreamApiServer) DeleteConnector(context.Context, *DeleteConnectorRequest) (*empty.Empty, error)

func (UnimplementedHStreamApiServer) DeleteQuery 

func (UnimplementedHStreamApiServer) DeleteQuery(context.Context, *DeleteQueryRequest) (*empty.Empty, error)

func (UnimplementedHStreamApiServer) DeleteShardReader added in v0.2.0 

func (UnimplementedHStreamApiServer) DeleteShardReader(context.Context, *DeleteShardReaderRequest) (*empty.Empty, error)

func (UnimplementedHStreamApiServer) DeleteStream 

func (UnimplementedHStreamApiServer) DeleteStream(context.Context, *DeleteStreamRequest) (*empty.Empty, error)

func (UnimplementedHStreamApiServer) DeleteSubscription 

func (UnimplementedHStreamApiServer) DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*empty.Empty, error)

func (UnimplementedHStreamApiServer) DeleteView 

func (UnimplementedHStreamApiServer) DeleteView(context.Context, *DeleteViewRequest) (*empty.Empty, error)

func (UnimplementedHStreamApiServer) DescribeCluster 

func (UnimplementedHStreamApiServer) DescribeCluster(context.Context, *empty.Empty) (*DescribeClusterResponse, error)

func (UnimplementedHStreamApiServer) Echo 

func (UnimplementedHStreamApiServer) Echo(context.Context, *EchoRequest) (*EchoResponse, error)

func (UnimplementedHStreamApiServer) ExecuteQuery 

func (UnimplementedHStreamApiServer) ExecuteQuery(context.Context, *CommandQuery) (*CommandQueryResponse, error)

func (UnimplementedHStreamApiServer) ExecuteViewQuery added in v0.3.2 

func (UnimplementedHStreamApiServer) ExecuteViewQuery(context.Context, *ExecuteViewQueryRequest) (*ExecuteViewQueryResponse, error)

func (UnimplementedHStreamApiServer) ExecuteViewQueryWithNamespace added in v0.3.2 

func (UnimplementedHStreamApiServer) ExecuteViewQueryWithNamespace(context.Context, *ExecuteViewQueryWithNamespaceRequest) (*ExecuteViewQueryResponse, error)

func (UnimplementedHStreamApiServer) GetConnector 

func (UnimplementedHStreamApiServer) GetConnector(context.Context, *GetConnectorRequest) (*Connector, error)

func (UnimplementedHStreamApiServer) GetConnectorLogs added in v0.3.2 

func (UnimplementedHStreamApiServer) GetConnectorLogs(context.Context, *GetConnectorLogsRequest) (*GetConnectorLogsResponse, error)

func (UnimplementedHStreamApiServer) GetConnectorSpec added in v0.3.2 

func (UnimplementedHStreamApiServer) GetConnectorSpec(context.Context, *GetConnectorSpecRequest) (*GetConnectorSpecResponse, error)

func (UnimplementedHStreamApiServer) GetQuery 

func (UnimplementedHStreamApiServer) GetQuery(context.Context, *GetQueryRequest) (*Query, error)

func (UnimplementedHStreamApiServer) GetStats added in v0.3.2 

func (UnimplementedHStreamApiServer) GetStats(context.Context, *GetStatsRequest) (*GetStatsResponse, error)

func (UnimplementedHStreamApiServer) GetStream added in v0.3.1 

func (UnimplementedHStreamApiServer) GetStream(context.Context, *GetStreamRequest) (*GetStreamResponse, error)

func (UnimplementedHStreamApiServer) GetSubscription added in v0.3.1 

func (UnimplementedHStreamApiServer) GetSubscription(context.Context, *GetSubscriptionRequest) (*GetSubscriptionResponse, error)

func (UnimplementedHStreamApiServer) GetView 

func (UnimplementedHStreamApiServer) GetView(context.Context, *GetViewRequest) (*View, error)

func (UnimplementedHStreamApiServer) ListConnectors 

func (UnimplementedHStreamApiServer) ListConnectors(context.Context, *ListConnectorsRequest) (*ListConnectorsResponse, error)

func (UnimplementedHStreamApiServer) ListConsumers added in v0.3.1 

func (UnimplementedHStreamApiServer) ListConsumers(context.Context, *ListConsumersRequest) (*ListConsumersResponse, error)

func (UnimplementedHStreamApiServer) ListQueries 

func (UnimplementedHStreamApiServer) ListQueries(context.Context, *ListQueriesRequest) (*ListQueriesResponse, error)

func (UnimplementedHStreamApiServer) ListShardReaders added in v0.3.1 

func (UnimplementedHStreamApiServer) ListShardReaders(context.Context, *ListShardReadersRequest) (*ListShardReadersResponse, error)

func (UnimplementedHStreamApiServer) ListShards added in v0.2.0 

func (UnimplementedHStreamApiServer) ListShards(context.Context, *ListShardsRequest) (*ListShardsResponse, error)

func (UnimplementedHStreamApiServer) ListStreams 

func (UnimplementedHStreamApiServer) ListStreams(context.Context, *ListStreamsRequest) (*ListStreamsResponse, error)

func (UnimplementedHStreamApiServer) ListStreamsWithPrefix added in v0.3.1 

func (UnimplementedHStreamApiServer) ListStreamsWithPrefix(context.Context, *ListStreamsWithPrefixRequest) (*ListStreamsResponse, error)

func (UnimplementedHStreamApiServer) ListSubscriptions 

func (UnimplementedHStreamApiServer) ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)

func (UnimplementedHStreamApiServer) ListSubscriptionsWithPrefix added in v0.3.1 

func (UnimplementedHStreamApiServer) ListSubscriptionsWithPrefix(context.Context, *ListSubscriptionsWithPrefixRequest) (*ListSubscriptionsResponse, error)

func (UnimplementedHStreamApiServer) ListViews 

func (UnimplementedHStreamApiServer) ListViews(context.Context, *ListViewsRequest) (*ListViewsResponse, error)

func (UnimplementedHStreamApiServer) LookupResource added in v0.3.1 

func (UnimplementedHStreamApiServer) LookupResource(context.Context, *LookupResourceRequest) (*ServerNode, error)

func (UnimplementedHStreamApiServer) LookupShard added in v0.2.0 

func (UnimplementedHStreamApiServer) LookupShard(context.Context, *LookupShardRequest) (*LookupShardResponse, error)

func (UnimplementedHStreamApiServer) LookupShardReader added in v0.2.0 

func (UnimplementedHStreamApiServer) LookupShardReader(context.Context, *LookupShardReaderRequest) (*LookupShardReaderResponse, error)

func (UnimplementedHStreamApiServer) LookupSubscription 

func (UnimplementedHStreamApiServer) LookupSubscription(context.Context, *LookupSubscriptionRequest) (*LookupSubscriptionResponse, error)

func (UnimplementedHStreamApiServer) ParseSql added in v0.3.2 

func (UnimplementedHStreamApiServer) ParseSql(context.Context, *ParseSqlRequest) (*ParseSqlResponse, error)

func (UnimplementedHStreamApiServer) PauseConnector added in v0.2.0 

func (UnimplementedHStreamApiServer) PauseConnector(context.Context, *PauseConnectorRequest) (*empty.Empty, error)

func (UnimplementedHStreamApiServer) PauseQuery added in v0.3.2 

func (UnimplementedHStreamApiServer) PauseQuery(context.Context, *PauseQueryRequest) (*empty.Empty, error)

func (UnimplementedHStreamApiServer) PerStreamTimeSeriesStats 

func (UnimplementedHStreamApiServer) PerStreamTimeSeriesStats(context.Context, *PerStreamTimeSeriesStatsRequest) (*PerStreamTimeSeriesStatsResponse, error)

func (UnimplementedHStreamApiServer) PerStreamTimeSeriesStatsAll 

func (UnimplementedHStreamApiServer) PerStreamTimeSeriesStatsAll(context.Context, *PerStreamTimeSeriesStatsAllRequest) (*PerStreamTimeSeriesStatsAllResponse, error)

func (UnimplementedHStreamApiServer) ReadShard added in v0.2.0 

func (UnimplementedHStreamApiServer) ReadShard(context.Context, *ReadShardRequest) (*ReadShardResponse, error)

func (UnimplementedHStreamApiServer) ReadShardStream added in v0.3.2 

func (UnimplementedHStreamApiServer) ReadShardStream(*ReadShardStreamRequest, HStreamApi_ReadShardStreamServer) error

func (UnimplementedHStreamApiServer) ResumeConnector added in v0.2.0 

func (UnimplementedHStreamApiServer) ResumeConnector(context.Context, *ResumeConnectorRequest) (*empty.Empty, error)

func (UnimplementedHStreamApiServer) ResumeQuery added in v0.3.2 

func (UnimplementedHStreamApiServer) ResumeQuery(context.Context, *ResumeQueryRequest) (*empty.Empty, error)

func (UnimplementedHStreamApiServer) SendAdminCommand 

func (UnimplementedHStreamApiServer) SendAdminCommand(context.Context, *AdminCommandRequest) (*AdminCommandResponse, error)

func (UnimplementedHStreamApiServer) StreamingFetch 

func (UnimplementedHStreamApiServer) StreamingFetch(HStreamApi_StreamingFetchServer) error

func (UnimplementedHStreamApiServer) TerminateQuery added in v0.3.2 

func (UnimplementedHStreamApiServer) TerminateQuery(context.Context, *TerminateQueryRequest) (*empty.Empty, error)

type UnsafeHStreamApiServer added in v0.1.4 

type UnsafeHStreamApiServer interface {
	// contains filtered or unexported methods
}

UnsafeHStreamApiServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HStreamApiServer will result in compilation errors.

type View 

type View struct {
	ViewId      string       `protobuf:"bytes,1,opt,name=viewId,proto3" json:"viewId,omitempty"`
	Status      TaskStatusPB `protobuf:"varint,2,opt,name=status,proto3,enum=hstream.server.TaskStatusPB" json:"status,omitempty"`
	CreatedTime int64        `protobuf:"varint,3,opt,name=createdTime,proto3" json:"createdTime,omitempty"`
	Sql         string       `protobuf:"bytes,4,opt,name=sql,proto3" json:"sql,omitempty"`
	Schema      []string     `protobuf:"bytes,5,rep,name=schema,proto3" json:"schema,omitempty"`
	QueryName   string       `protobuf:"bytes,6,opt,name=queryName,proto3" json:"queryName,omitempty"`
	// contains filtered or unexported fields
}

func (*View) Descriptor deprecated 

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

Deprecated: Use View.ProtoReflect.Descriptor instead.

func (*View) GetCreatedTime 

func (x *View) GetCreatedTime() int64

func (*View) GetQueryName added in v0.3.2 

func (x *View) GetQueryName() string

func (*View) GetSchema 

func (x *View) GetSchema() []string

func (*View) GetSql 

func (x *View) GetSql() string

func (*View) GetStatus 

func (x *View) GetStatus() TaskStatusPB

func (*View) GetViewId 

func (x *View) GetViewId() string

func (*View) ProtoMessage 

func (*View) ProtoMessage()

func (*View) ProtoReflect 

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

func (*View) Reset 

func (x *View) Reset()

func (*View) String 

func (x *View) String() string

type ViewStats added in v0.3.2 

type ViewStats int32
const (
	ViewStats_TotalExecuteQueries ViewStats = 0
)

func (ViewStats) Descriptor added in v0.3.2 

func (ViewStats) Descriptor() protoreflect.EnumDescriptor

func (ViewStats) Enum added in v0.3.2 

func (x ViewStats) Enum() *ViewStats

func (ViewStats) EnumDescriptor deprecated added in v0.3.2 

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

Deprecated: Use ViewStats.Descriptor instead.

func (ViewStats) Number added in v0.3.2 

func (x ViewStats) Number() protoreflect.EnumNumber

func (ViewStats) String added in v0.3.2 

func (x ViewStats) String() string

func (ViewStats) Type added in v0.3.2 

func (ViewStats) Type() protoreflect.EnumType

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.