consolev1alpha1

package
v0.4.3 Latest Latest
Warning

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

 Go to latest Published: Apr 22, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ConsoleService_ListMessages_FullMethodName   = "/redpanda.api.console.v1alpha1.ConsoleService/ListMessages"
	ConsoleService_PublishMessage_FullMethodName = "/redpanda.api.console.v1alpha1.ConsoleService/PublishMessage"
)

Variables

View Source 
var (
	CompressionType_name = map[int32]string{
		0: "COMPRESSION_TYPE_UNSPECIFIED",
		1: "COMPRESSION_TYPE_UNCOMPRESSED",
		2: "COMPRESSION_TYPE_GZIP",
		3: "COMPRESSION_TYPE_SNAPPY",
		4: "COMPRESSION_TYPE_LZ4",
		5: "COMPRESSION_TYPE_ZSTD",
	}
	CompressionType_value = map[string]int32{
		"COMPRESSION_TYPE_UNSPECIFIED":  0,
		"COMPRESSION_TYPE_UNCOMPRESSED": 1,
		"COMPRESSION_TYPE_GZIP":         2,
		"COMPRESSION_TYPE_SNAPPY":       3,
		"COMPRESSION_TYPE_LZ4":          4,
		"COMPRESSION_TYPE_ZSTD":         5,
	}
)

Enum value maps for CompressionType.

View Source 
var (
	PayloadEncoding_name = map[int32]string{
		0:  "PAYLOAD_ENCODING_UNSPECIFIED",
		1:  "PAYLOAD_ENCODING_NULL",
		2:  "PAYLOAD_ENCODING_AVRO",
		3:  "PAYLOAD_ENCODING_PROTOBUF",
		4:  "PAYLOAD_ENCODING_PROTOBUF_SCHEMA",
		5:  "PAYLOAD_ENCODING_JSON",
		6:  "PAYLOAD_ENCODING_JSON_SCHEMA",
		7:  "PAYLOAD_ENCODING_XML",
		8:  "PAYLOAD_ENCODING_TEXT",
		9:  "PAYLOAD_ENCODING_UTF8",
		10: "PAYLOAD_ENCODING_MESSAGE_PACK",
		11: "PAYLOAD_ENCODING_SMILE",
		12: "PAYLOAD_ENCODING_BINARY",
		13: "PAYLOAD_ENCODING_UINT",
		14: "PAYLOAD_ENCODING_CONSUMER_OFFSETS",
	}
	PayloadEncoding_value = map[string]int32{
		"PAYLOAD_ENCODING_UNSPECIFIED":      0,
		"PAYLOAD_ENCODING_NULL":             1,
		"PAYLOAD_ENCODING_AVRO":             2,
		"PAYLOAD_ENCODING_PROTOBUF":         3,
		"PAYLOAD_ENCODING_PROTOBUF_SCHEMA":  4,
		"PAYLOAD_ENCODING_JSON":             5,
		"PAYLOAD_ENCODING_JSON_SCHEMA":      6,
		"PAYLOAD_ENCODING_XML":              7,
		"PAYLOAD_ENCODING_TEXT":             8,
		"PAYLOAD_ENCODING_UTF8":             9,
		"PAYLOAD_ENCODING_MESSAGE_PACK":     10,
		"PAYLOAD_ENCODING_SMILE":            11,
		"PAYLOAD_ENCODING_BINARY":           12,
		"PAYLOAD_ENCODING_UINT":             13,
		"PAYLOAD_ENCODING_CONSUMER_OFFSETS": 14,
	}
)

Enum value maps for PayloadEncoding.

View Source 
var ConsoleService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "redpanda.api.console.v1alpha1.ConsoleService",
	HandlerType: (*ConsoleServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PublishMessage",
			Handler:    _ConsoleService_PublishMessage_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ListMessages",
			Handler:       _ConsoleService_ListMessages_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "redpanda/api/console/v1alpha1/console_service.proto",
}

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

View Source 
var File_redpanda_api_console_v1alpha1_common_proto protoreflect.FileDescriptor
View Source 
var File_redpanda_api_console_v1alpha1_console_service_proto protoreflect.FileDescriptor
View Source 
var File_redpanda_api_console_v1alpha1_list_messages_proto protoreflect.FileDescriptor
View Source 
var File_redpanda_api_console_v1alpha1_publish_messages_proto protoreflect.FileDescriptor

Functions

func RegisterConsoleServiceServer 

func RegisterConsoleServiceServer(s grpc.ServiceRegistrar, srv ConsoleServiceServer)

Types

type CompressionType 

type CompressionType int32
const (
	CompressionType_COMPRESSION_TYPE_UNSPECIFIED  CompressionType = 0
	CompressionType_COMPRESSION_TYPE_UNCOMPRESSED CompressionType = 1
	CompressionType_COMPRESSION_TYPE_GZIP         CompressionType = 2
	CompressionType_COMPRESSION_TYPE_SNAPPY       CompressionType = 3
	CompressionType_COMPRESSION_TYPE_LZ4          CompressionType = 4
	CompressionType_COMPRESSION_TYPE_ZSTD         CompressionType = 5
)

func (CompressionType) Descriptor 

func (CompressionType) Descriptor() protoreflect.EnumDescriptor

func (CompressionType) Enum 

func (x CompressionType) Enum() *CompressionType

func (CompressionType) EnumDescriptor deprecated 

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

Deprecated: Use CompressionType.Descriptor instead.

func (CompressionType) Number 

func (x CompressionType) Number() protoreflect.EnumNumber

func (CompressionType) String 

func (x CompressionType) String() string

func (CompressionType) Type 

func (CompressionType) Type() protoreflect.EnumType

type ConsoleServiceClient 

type ConsoleServiceClient interface {
	// ListMessages lists the messages according to the requested query.
	ListMessages(ctx context.Context, in *ListMessagesRequest, opts ...grpc.CallOption) (ConsoleService_ListMessagesClient, error)
	// PublishMessage publishes message.
	PublishMessage(ctx context.Context, in *PublishMessageRequest, opts ...grpc.CallOption) (*PublishMessageResponse, error)
}

ConsoleServiceClient is the client API for ConsoleService 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 NewConsoleServiceClient 

func NewConsoleServiceClient(cc grpc.ClientConnInterface) ConsoleServiceClient

type ConsoleServiceServer 

type ConsoleServiceServer interface {
	// ListMessages lists the messages according to the requested query.
	ListMessages(*ListMessagesRequest, ConsoleService_ListMessagesServer) error
	// PublishMessage publishes message.
	PublishMessage(context.Context, *PublishMessageRequest) (*PublishMessageResponse, error)
}

ConsoleServiceServer is the server API for ConsoleService service. All implementations should embed UnimplementedConsoleServiceServer for forward compatibility

type ConsoleService_ListMessagesClient 

type ConsoleService_ListMessagesClient interface {
	Recv() (*ListMessagesResponse, error)
	grpc.ClientStream
}

type ConsoleService_ListMessagesServer 

type ConsoleService_ListMessagesServer interface {
	Send(*ListMessagesResponse) error
	grpc.ServerStream
}

type KafkaRecordHeader 

type KafkaRecordHeader struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`     // Header key.
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // Header value.
	// contains filtered or unexported fields
}

KafkaRecordHeader is the record header.

func (*KafkaRecordHeader) Descriptor deprecated 

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

Deprecated: Use KafkaRecordHeader.ProtoReflect.Descriptor instead.

func (*KafkaRecordHeader) GetKey 

func (x *KafkaRecordHeader) GetKey() string

func (*KafkaRecordHeader) GetValue 

func (x *KafkaRecordHeader) GetValue() []byte

func (*KafkaRecordHeader) ProtoMessage 

func (*KafkaRecordHeader) ProtoMessage()

func (*KafkaRecordHeader) ProtoReflect 

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

func (*KafkaRecordHeader) Reset 

func (x *KafkaRecordHeader) Reset()

func (*KafkaRecordHeader) String 

func (x *KafkaRecordHeader) String() string

type KafkaRecordPayload 

type KafkaRecordPayload struct {
	OriginalPayload    []byte                `protobuf:"bytes,1,opt,name=original_payload,json=originalPayload,proto3,oneof" json:"original_payload,omitempty"`          // Original raw binary payload.
	NormalizedPayload  []byte                `protobuf:"bytes,2,opt,name=normalized_payload,json=normalizedPayload,proto3,oneof" json:"normalized_payload,omitempty"`    // Normalized user friendly representation of the payload.
	Encoding           PayloadEncoding       `protobuf:"varint,3,opt,name=encoding,proto3,enum=redpanda.api.console.v1alpha1.PayloadEncoding" json:"encoding,omitempty"` // Payload encoding if we have been able to detect.
	SchemaId           *int32                `protobuf:"varint,4,opt,name=schema_id,json=schemaId,proto3,oneof" json:"schema_id,omitempty"`                              // Optionally, the schema ID used to deserialized the message.
	PayloadSize        int32                 `protobuf:"varint,5,opt,name=payload_size,json=payloadSize,proto3" json:"payload_size,omitempty"`                           // Payload size in bytes.
	IsPayloadTooLarge  bool                  `protobuf:"varint,6,opt,name=is_payload_too_large,json=isPayloadTooLarge,proto3" json:"is_payload_too_large,omitempty"`     // If payload is too large for deserialization.
	TroubleshootReport []*TroubleshootReport `protobuf:"bytes,7,rep,name=troubleshoot_report,json=troubleshootReport,proto3" json:"troubleshoot_report,omitempty"`       // Troubleshooting data for debugging.
	// contains filtered or unexported fields
}

KafkaRecordPayload is record payload representation.

func (*KafkaRecordPayload) Descriptor deprecated 

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

Deprecated: Use KafkaRecordPayload.ProtoReflect.Descriptor instead.

func (*KafkaRecordPayload) GetEncoding 

func (x *KafkaRecordPayload) GetEncoding() PayloadEncoding

func (*KafkaRecordPayload) GetIsPayloadTooLarge 

func (x *KafkaRecordPayload) GetIsPayloadTooLarge() bool

func (*KafkaRecordPayload) GetNormalizedPayload 

func (x *KafkaRecordPayload) GetNormalizedPayload() []byte

func (*KafkaRecordPayload) GetOriginalPayload 

func (x *KafkaRecordPayload) GetOriginalPayload() []byte

func (*KafkaRecordPayload) GetPayloadSize 

func (x *KafkaRecordPayload) GetPayloadSize() int32

func (*KafkaRecordPayload) GetSchemaId 

func (x *KafkaRecordPayload) GetSchemaId() int32

func (*KafkaRecordPayload) GetTroubleshootReport 

func (x *KafkaRecordPayload) GetTroubleshootReport() []*TroubleshootReport

func (*KafkaRecordPayload) ProtoMessage 

func (*KafkaRecordPayload) ProtoMessage()

func (*KafkaRecordPayload) ProtoReflect 

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

func (*KafkaRecordPayload) Reset 

func (x *KafkaRecordPayload) Reset()

func (*KafkaRecordPayload) String 

func (x *KafkaRecordPayload) String() string

type ListMessagesRequest 

type ListMessagesRequest struct {
	Topic                 string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`                                          // Topic name.
	StartOffset           int64  `protobuf:"zigzag64,2,opt,name=start_offset,json=startOffset,proto3" json:"start_offset,omitempty"`        // Start offset. -1 for recent (newest - results), -2 for oldest offset, -3 for newest, -4 for timestamp.
	StartTimestamp        int64  `protobuf:"varint,3,opt,name=start_timestamp,json=startTimestamp,proto3" json:"start_timestamp,omitempty"` // Start offset by unix timestamp in ms (only considered if start offset is set to -4).
	PartitionId           int32  `protobuf:"varint,4,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`          // -1 for all partition ids
	MaxResults            int32  `protobuf:"varint,5,opt,name=max_results,json=maxResults,proto3" json:"max_results,omitempty"`             // Maximum number of results
	FilterInterpreterCode string ``                                                                                                         // Base64 encoded code
	/* 126-byte string literal not displayed */
	Enterprise                []byte `protobuf:"bytes,7,opt,name=enterprise,proto3" json:"enterprise,omitempty"`      // Enterprise may only be set in the Enterprise mode. The JSON deserialization is deferred.
	Troubleshoot              bool   `protobuf:"varint,8,opt,name=troubleshoot,proto3" json:"troubleshoot,omitempty"` // Optionally include troubleshooting data in the response.
	IncludeOriginalRawPayload bool   ``                                                                               // Optionally include original raw payload.
	/* 141-byte string literal not displayed */
	KeyDeserializer *PayloadEncoding `` // Optionally specify key payload deserialization strategy to use.
	/* 165-byte string literal not displayed */
	ValueDeserializer *PayloadEncoding `` // Optionally specify value payload deserialization strategy to use.
	/* 171-byte string literal not displayed */
	IgnoreMaxSizeLimit bool `protobuf:"varint,12,opt,name=ignore_max_size_limit,json=ignoreMaxSizeLimit,proto3" json:"ignore_max_size_limit,omitempty"` // Optionally ignore configured maximum payload size limit.
	// contains filtered or unexported fields
}

ListMessagesRequest is the request for ListMessages call.

func (*ListMessagesRequest) Descriptor deprecated 

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

Deprecated: Use ListMessagesRequest.ProtoReflect.Descriptor instead.

func (*ListMessagesRequest) GetEnterprise 

func (x *ListMessagesRequest) GetEnterprise() []byte

func (*ListMessagesRequest) GetFilterInterpreterCode 

func (x *ListMessagesRequest) GetFilterInterpreterCode() string

func (*ListMessagesRequest) GetIgnoreMaxSizeLimit added in v0.3.0 

func (x *ListMessagesRequest) GetIgnoreMaxSizeLimit() bool

func (*ListMessagesRequest) GetIncludeOriginalRawPayload 

func (x *ListMessagesRequest) GetIncludeOriginalRawPayload() bool

func (*ListMessagesRequest) GetKeyDeserializer 

func (x *ListMessagesRequest) GetKeyDeserializer() PayloadEncoding

func (*ListMessagesRequest) GetMaxResults 

func (x *ListMessagesRequest) GetMaxResults() int32

func (*ListMessagesRequest) GetPartitionId 

func (x *ListMessagesRequest) GetPartitionId() int32

func (*ListMessagesRequest) GetStartOffset 

func (x *ListMessagesRequest) GetStartOffset() int64

func (*ListMessagesRequest) GetStartTimestamp 

func (x *ListMessagesRequest) GetStartTimestamp() int64

func (*ListMessagesRequest) GetTopic 

func (x *ListMessagesRequest) GetTopic() string

func (*ListMessagesRequest) GetTroubleshoot 

func (x *ListMessagesRequest) GetTroubleshoot() bool

func (*ListMessagesRequest) GetValueDeserializer 

func (x *ListMessagesRequest) GetValueDeserializer() PayloadEncoding

func (*ListMessagesRequest) ProtoMessage 

func (*ListMessagesRequest) ProtoMessage()

func (*ListMessagesRequest) ProtoReflect 

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

func (*ListMessagesRequest) Reset 

func (x *ListMessagesRequest) Reset()

func (*ListMessagesRequest) String 

func (x *ListMessagesRequest) String() string

type ListMessagesResponse 

type ListMessagesResponse struct {

	// The control message as we consume messages.
	//
	// Types that are assignable to ControlMessage:
	//
	//	*ListMessagesResponse_Data
	//	*ListMessagesResponse_Phase
	//	*ListMessagesResponse_Progress
	//	*ListMessagesResponse_Done
	//	*ListMessagesResponse_Error
	ControlMessage isListMessagesResponse_ControlMessage `protobuf_oneof:"control_message"`
	// contains filtered or unexported fields
}

ListMessagesResponse is the response for ListMessages call.

func (*ListMessagesResponse) Descriptor deprecated 

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

Deprecated: Use ListMessagesResponse.ProtoReflect.Descriptor instead.

func (*ListMessagesResponse) GetControlMessage 

func (m *ListMessagesResponse) GetControlMessage() isListMessagesResponse_ControlMessage

func (*ListMessagesResponse) GetData 

func (x *ListMessagesResponse) GetData() *ListMessagesResponse_DataMessage

func (*ListMessagesResponse) GetDone 

func (x *ListMessagesResponse) GetDone() *ListMessagesResponse_StreamCompletedMessage

func (*ListMessagesResponse) GetError 

func (x *ListMessagesResponse) GetError() *ListMessagesResponse_ErrorMessage

func (*ListMessagesResponse) GetPhase 

func (x *ListMessagesResponse) GetPhase() *ListMessagesResponse_PhaseMessage

func (*ListMessagesResponse) GetProgress 

func (x *ListMessagesResponse) GetProgress() *ListMessagesResponse_ProgressMessage

func (*ListMessagesResponse) ProtoMessage 

func (*ListMessagesResponse) ProtoMessage()

func (*ListMessagesResponse) ProtoReflect 

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

func (*ListMessagesResponse) Reset 

func (x *ListMessagesResponse) Reset()

func (*ListMessagesResponse) String 

func (x *ListMessagesResponse) String() string

type ListMessagesResponse_Data 

type ListMessagesResponse_Data struct {
	Data *ListMessagesResponse_DataMessage `protobuf:"bytes,1,opt,name=data,proto3,oneof"`
}

type ListMessagesResponse_DataMessage 

type ListMessagesResponse_DataMessage struct {
	PartitionId     int32                `protobuf:"varint,1,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	Offset          int64                `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Timestamp       int64                `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Compression     CompressionType      `` /* 127-byte string literal not displayed */
	IsTransactional bool                 `protobuf:"varint,5,opt,name=is_transactional,json=isTransactional,proto3" json:"is_transactional,omitempty"`
	Headers         []*KafkaRecordHeader `protobuf:"bytes,6,rep,name=headers,proto3" json:"headers,omitempty"` // Kafka record headers.
	Key             *KafkaRecordPayload  `protobuf:"bytes,7,opt,name=key,proto3" json:"key,omitempty"`         // Kafka key of the payload record.
	Value           *KafkaRecordPayload  `protobuf:"bytes,8,opt,name=value,proto3" json:"value,omitempty"`     // Kafka value of the payload record.
	// contains filtered or unexported fields
}

Data control message.

func (*ListMessagesResponse_DataMessage) Descriptor deprecated 

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

Deprecated: Use ListMessagesResponse_DataMessage.ProtoReflect.Descriptor instead.

func (*ListMessagesResponse_DataMessage) GetCompression 

func (x *ListMessagesResponse_DataMessage) GetCompression() CompressionType

func (*ListMessagesResponse_DataMessage) GetHeaders 

func (x *ListMessagesResponse_DataMessage) GetHeaders() []*KafkaRecordHeader

func (*ListMessagesResponse_DataMessage) GetIsTransactional 

func (x *ListMessagesResponse_DataMessage) GetIsTransactional() bool

func (*ListMessagesResponse_DataMessage) GetKey 

func (x *ListMessagesResponse_DataMessage) GetKey() *KafkaRecordPayload

func (*ListMessagesResponse_DataMessage) GetOffset 

func (x *ListMessagesResponse_DataMessage) GetOffset() int64

func (*ListMessagesResponse_DataMessage) GetPartitionId 

func (x *ListMessagesResponse_DataMessage) GetPartitionId() int32

func (*ListMessagesResponse_DataMessage) GetTimestamp 

func (x *ListMessagesResponse_DataMessage) GetTimestamp() int64

func (*ListMessagesResponse_DataMessage) GetValue 

func (x *ListMessagesResponse_DataMessage) GetValue() *KafkaRecordPayload

func (*ListMessagesResponse_DataMessage) ProtoMessage 

func (*ListMessagesResponse_DataMessage) ProtoMessage()

func (*ListMessagesResponse_DataMessage) ProtoReflect 

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

func (*ListMessagesResponse_DataMessage) Reset 

func (x *ListMessagesResponse_DataMessage) Reset()

func (*ListMessagesResponse_DataMessage) String 

func (x *ListMessagesResponse_DataMessage) String() string

type ListMessagesResponse_Done 

type ListMessagesResponse_Done struct {
	Done *ListMessagesResponse_StreamCompletedMessage `protobuf:"bytes,4,opt,name=done,proto3,oneof"`
}

type ListMessagesResponse_Error 

type ListMessagesResponse_Error struct {
	Error *ListMessagesResponse_ErrorMessage `protobuf:"bytes,5,opt,name=error,proto3,oneof"`
}

type ListMessagesResponse_ErrorMessage 

type ListMessagesResponse_ErrorMessage struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // The error message.
	// contains filtered or unexported fields
}

Error control message.

func (*ListMessagesResponse_ErrorMessage) Descriptor deprecated 

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

Deprecated: Use ListMessagesResponse_ErrorMessage.ProtoReflect.Descriptor instead.

func (*ListMessagesResponse_ErrorMessage) GetMessage 

func (x *ListMessagesResponse_ErrorMessage) GetMessage() string

func (*ListMessagesResponse_ErrorMessage) ProtoMessage 

func (*ListMessagesResponse_ErrorMessage) ProtoMessage()

func (*ListMessagesResponse_ErrorMessage) ProtoReflect 

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

func (*ListMessagesResponse_ErrorMessage) Reset 

func (x *ListMessagesResponse_ErrorMessage) Reset()

func (*ListMessagesResponse_ErrorMessage) String 

func (x *ListMessagesResponse_ErrorMessage) String() string

type ListMessagesResponse_Phase 

type ListMessagesResponse_Phase struct {
	Phase *ListMessagesResponse_PhaseMessage `protobuf:"bytes,2,opt,name=phase,proto3,oneof"`
}

type ListMessagesResponse_PhaseMessage 

type ListMessagesResponse_PhaseMessage struct {
	Phase string `protobuf:"bytes,1,opt,name=phase,proto3" json:"phase,omitempty"` // The current phase.
	// contains filtered or unexported fields
}

Phase control message.

func (*ListMessagesResponse_PhaseMessage) Descriptor deprecated 

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

Deprecated: Use ListMessagesResponse_PhaseMessage.ProtoReflect.Descriptor instead.

func (*ListMessagesResponse_PhaseMessage) GetPhase 

func (x *ListMessagesResponse_PhaseMessage) GetPhase() string

func (*ListMessagesResponse_PhaseMessage) ProtoMessage 

func (*ListMessagesResponse_PhaseMessage) ProtoMessage()

func (*ListMessagesResponse_PhaseMessage) ProtoReflect 

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

func (*ListMessagesResponse_PhaseMessage) Reset 

func (x *ListMessagesResponse_PhaseMessage) Reset()

func (*ListMessagesResponse_PhaseMessage) String 

func (x *ListMessagesResponse_PhaseMessage) String() string

type ListMessagesResponse_Progress 

type ListMessagesResponse_Progress struct {
	Progress *ListMessagesResponse_ProgressMessage `protobuf:"bytes,3,opt,name=progress,proto3,oneof"`
}

type ListMessagesResponse_ProgressMessage 

type ListMessagesResponse_ProgressMessage struct {
	MessagesConsumed int64 `protobuf:"varint,1,opt,name=messages_consumed,json=messagesConsumed,proto3" json:"messages_consumed,omitempty"` // Currently consumed messages.
	BytesConsumed    int64 `protobuf:"varint,2,opt,name=bytes_consumed,json=bytesConsumed,proto3" json:"bytes_consumed,omitempty"`          // Currently consumed bytes.
	// contains filtered or unexported fields
}

Progress control message.

func (*ListMessagesResponse_ProgressMessage) Descriptor deprecated 

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

Deprecated: Use ListMessagesResponse_ProgressMessage.ProtoReflect.Descriptor instead.

func (*ListMessagesResponse_ProgressMessage) GetBytesConsumed 

func (x *ListMessagesResponse_ProgressMessage) GetBytesConsumed() int64

func (*ListMessagesResponse_ProgressMessage) GetMessagesConsumed 

func (x *ListMessagesResponse_ProgressMessage) GetMessagesConsumed() int64

func (*ListMessagesResponse_ProgressMessage) ProtoMessage 

func (*ListMessagesResponse_ProgressMessage) ProtoMessage()

func (*ListMessagesResponse_ProgressMessage) ProtoReflect 

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

func (*ListMessagesResponse_ProgressMessage) Reset 

func (x *ListMessagesResponse_ProgressMessage) Reset()

func (*ListMessagesResponse_ProgressMessage) String 

func (x *ListMessagesResponse_ProgressMessage) String() string

type ListMessagesResponse_StreamCompletedMessage 

type ListMessagesResponse_StreamCompletedMessage struct {
	ElapsedMs        int64 `protobuf:"varint,1,opt,name=elapsed_ms,json=elapsedMs,proto3" json:"elapsed_ms,omitempty"`                      // Total elapsed time in milliseconds.
	IsCancelled      bool  `protobuf:"varint,2,opt,name=is_cancelled,json=isCancelled,proto3" json:"is_cancelled,omitempty"`                // Whether the call was cancelled.
	MessagesConsumed int64 `protobuf:"varint,3,opt,name=messages_consumed,json=messagesConsumed,proto3" json:"messages_consumed,omitempty"` // Total consumed messages.
	BytesConsumed    int64 `protobuf:"varint,4,opt,name=bytes_consumed,json=bytesConsumed,proto3" json:"bytes_consumed,omitempty"`          // Total consumed bytes.
	// contains filtered or unexported fields
}

Stream completed control message.

func (*ListMessagesResponse_StreamCompletedMessage) Descriptor deprecated 

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

Deprecated: Use ListMessagesResponse_StreamCompletedMessage.ProtoReflect.Descriptor instead.

func (*ListMessagesResponse_StreamCompletedMessage) GetBytesConsumed 

func (x *ListMessagesResponse_StreamCompletedMessage) GetBytesConsumed() int64

func (*ListMessagesResponse_StreamCompletedMessage) GetElapsedMs 

func (x *ListMessagesResponse_StreamCompletedMessage) GetElapsedMs() int64

func (*ListMessagesResponse_StreamCompletedMessage) GetIsCancelled 

func (x *ListMessagesResponse_StreamCompletedMessage) GetIsCancelled() bool

func (*ListMessagesResponse_StreamCompletedMessage) GetMessagesConsumed 

func (x *ListMessagesResponse_StreamCompletedMessage) GetMessagesConsumed() int64

func (*ListMessagesResponse_StreamCompletedMessage) ProtoMessage 

func (*ListMessagesResponse_StreamCompletedMessage) ProtoMessage()

func (*ListMessagesResponse_StreamCompletedMessage) ProtoReflect 

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

func (*ListMessagesResponse_StreamCompletedMessage) Reset 

func (x *ListMessagesResponse_StreamCompletedMessage) Reset()

func (*ListMessagesResponse_StreamCompletedMessage) String 

func (x *ListMessagesResponse_StreamCompletedMessage) String() string

type PayloadEncoding 

type PayloadEncoding int32
const (
	PayloadEncoding_PAYLOAD_ENCODING_UNSPECIFIED      PayloadEncoding = 0
	PayloadEncoding_PAYLOAD_ENCODING_NULL             PayloadEncoding = 1
	PayloadEncoding_PAYLOAD_ENCODING_AVRO             PayloadEncoding = 2
	PayloadEncoding_PAYLOAD_ENCODING_PROTOBUF         PayloadEncoding = 3
	PayloadEncoding_PAYLOAD_ENCODING_PROTOBUF_SCHEMA  PayloadEncoding = 4
	PayloadEncoding_PAYLOAD_ENCODING_JSON             PayloadEncoding = 5
	PayloadEncoding_PAYLOAD_ENCODING_JSON_SCHEMA      PayloadEncoding = 6
	PayloadEncoding_PAYLOAD_ENCODING_XML              PayloadEncoding = 7
	PayloadEncoding_PAYLOAD_ENCODING_TEXT             PayloadEncoding = 8
	PayloadEncoding_PAYLOAD_ENCODING_UTF8             PayloadEncoding = 9
	PayloadEncoding_PAYLOAD_ENCODING_MESSAGE_PACK     PayloadEncoding = 10
	PayloadEncoding_PAYLOAD_ENCODING_SMILE            PayloadEncoding = 11
	PayloadEncoding_PAYLOAD_ENCODING_BINARY           PayloadEncoding = 12
	PayloadEncoding_PAYLOAD_ENCODING_UINT             PayloadEncoding = 13
	PayloadEncoding_PAYLOAD_ENCODING_CONSUMER_OFFSETS PayloadEncoding = 14
)

func (PayloadEncoding) Descriptor 

func (PayloadEncoding) Descriptor() protoreflect.EnumDescriptor

func (PayloadEncoding) Enum 

func (x PayloadEncoding) Enum() *PayloadEncoding

func (PayloadEncoding) EnumDescriptor deprecated 

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

Deprecated: Use PayloadEncoding.Descriptor instead.

func (PayloadEncoding) Number 

func (x PayloadEncoding) Number() protoreflect.EnumNumber

func (PayloadEncoding) String 

func (x PayloadEncoding) String() string

func (PayloadEncoding) Type 

func (PayloadEncoding) Type() protoreflect.EnumType

type PublishMessagePayloadOptions 

type PublishMessagePayloadOptions struct {
	Encoding PayloadEncoding `protobuf:"varint,1,opt,name=encoding,proto3,enum=redpanda.api.console.v1alpha1.PayloadEncoding" json:"encoding,omitempty"` // Payload encoding to use.
	Data     []byte          `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`                                                             // Data.
	SchemaId *int32          `protobuf:"varint,9,opt,name=schema_id,json=schemaId,proto3,oneof" json:"schema_id,omitempty"`                              // Optional schema ID.
	Index    *int32          `protobuf:"varint,10,opt,name=index,proto3,oneof" json:"index,omitempty"`                                                   // Optional index. Useful for Protobuf messages.
	// contains filtered or unexported fields
}

func (*PublishMessagePayloadOptions) Descriptor deprecated 

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

Deprecated: Use PublishMessagePayloadOptions.ProtoReflect.Descriptor instead.

func (*PublishMessagePayloadOptions) GetData 

func (x *PublishMessagePayloadOptions) GetData() []byte

func (*PublishMessagePayloadOptions) GetEncoding 

func (x *PublishMessagePayloadOptions) GetEncoding() PayloadEncoding

func (*PublishMessagePayloadOptions) GetIndex 

func (x *PublishMessagePayloadOptions) GetIndex() int32

func (*PublishMessagePayloadOptions) GetSchemaId 

func (x *PublishMessagePayloadOptions) GetSchemaId() int32

func (*PublishMessagePayloadOptions) ProtoMessage 

func (*PublishMessagePayloadOptions) ProtoMessage()

func (*PublishMessagePayloadOptions) ProtoReflect 

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

func (*PublishMessagePayloadOptions) Reset 

func (x *PublishMessagePayloadOptions) Reset()

func (*PublishMessagePayloadOptions) String 

func (x *PublishMessagePayloadOptions) String() string

type PublishMessageRequest 

type PublishMessageRequest struct {
	Topic       string          `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`                                 // The topics to publish to.
	PartitionId int32           `protobuf:"varint,2,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"` // -1 for automatic partition assignment.
	Compression CompressionType ``                                                                                                // The compression to be used.
	/* 127-byte string literal not displayed */
	UseTransactions bool                          `protobuf:"varint,4,opt,name=use_transactions,json=useTransactions,proto3" json:"use_transactions,omitempty"` // Use transactions.
	Headers         []*KafkaRecordHeader          `protobuf:"bytes,5,rep,name=headers,proto3" json:"headers,omitempty"`                                         // Kafka record headers.
	Key             *PublishMessagePayloadOptions `protobuf:"bytes,6,opt,name=key,proto3" json:"key,omitempty"`
	Value           *PublishMessagePayloadOptions `protobuf:"bytes,7,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

PublishMessageRequest is the request for PublishMessage call.

func (*PublishMessageRequest) Descriptor deprecated 

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

Deprecated: Use PublishMessageRequest.ProtoReflect.Descriptor instead.

func (*PublishMessageRequest) GetCompression 

func (x *PublishMessageRequest) GetCompression() CompressionType

func (*PublishMessageRequest) GetHeaders 

func (x *PublishMessageRequest) GetHeaders() []*KafkaRecordHeader

func (*PublishMessageRequest) GetKey 

func (x *PublishMessageRequest) GetKey() *PublishMessagePayloadOptions

func (*PublishMessageRequest) GetPartitionId 

func (x *PublishMessageRequest) GetPartitionId() int32

func (*PublishMessageRequest) GetTopic 

func (x *PublishMessageRequest) GetTopic() string

func (*PublishMessageRequest) GetUseTransactions 

func (x *PublishMessageRequest) GetUseTransactions() bool

func (*PublishMessageRequest) GetValue 

func (x *PublishMessageRequest) GetValue() *PublishMessagePayloadOptions

func (*PublishMessageRequest) ProtoMessage 

func (*PublishMessageRequest) ProtoMessage()

func (*PublishMessageRequest) ProtoReflect 

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

func (*PublishMessageRequest) Reset 

func (x *PublishMessageRequest) Reset()

func (*PublishMessageRequest) String 

func (x *PublishMessageRequest) String() string

type PublishMessageResponse 

type PublishMessageResponse struct {
	Topic       string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	PartitionId int32  `protobuf:"varint,2,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	Offset      int64  `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

PublishMessageResponse is the response for PublishMessage call.

func (*PublishMessageResponse) Descriptor deprecated 

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

Deprecated: Use PublishMessageResponse.ProtoReflect.Descriptor instead.

func (*PublishMessageResponse) GetOffset 

func (x *PublishMessageResponse) GetOffset() int64

func (*PublishMessageResponse) GetPartitionId 

func (x *PublishMessageResponse) GetPartitionId() int32

func (*PublishMessageResponse) GetTopic 

func (x *PublishMessageResponse) GetTopic() string

func (*PublishMessageResponse) ProtoMessage 

func (*PublishMessageResponse) ProtoMessage()

func (*PublishMessageResponse) ProtoReflect 

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

func (*PublishMessageResponse) Reset 

func (x *PublishMessageResponse) Reset()

func (*PublishMessageResponse) String 

func (x *PublishMessageResponse) String() string

type TroubleshootReport 

type TroubleshootReport struct {
	SerdeName string `protobuf:"bytes,1,opt,name=serde_name,json=serdeName,proto3" json:"serde_name,omitempty"`
	Message   string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*TroubleshootReport) Descriptor deprecated 

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

Deprecated: Use TroubleshootReport.ProtoReflect.Descriptor instead.

func (*TroubleshootReport) GetMessage 

func (x *TroubleshootReport) GetMessage() string

func (*TroubleshootReport) GetSerdeName 

func (x *TroubleshootReport) GetSerdeName() string

func (*TroubleshootReport) ProtoMessage 

func (*TroubleshootReport) ProtoMessage()

func (*TroubleshootReport) ProtoReflect 

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

func (*TroubleshootReport) Reset 

func (x *TroubleshootReport) Reset()

func (*TroubleshootReport) String 

func (x *TroubleshootReport) String() string

type UnimplementedConsoleServiceServer 

type UnimplementedConsoleServiceServer struct {
}

UnimplementedConsoleServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedConsoleServiceServer) ListMessages 

func (UnimplementedConsoleServiceServer) ListMessages(*ListMessagesRequest, ConsoleService_ListMessagesServer) error

func (UnimplementedConsoleServiceServer) PublishMessage 

func (UnimplementedConsoleServiceServer) PublishMessage(context.Context, *PublishMessageRequest) (*PublishMessageResponse, error)

type UnsafeConsoleServiceServer 

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

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

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.