plugin

package
v0.0.0-...-ae3c806 Latest Latest
Warning

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

Go to latest
Published: May 1, 2024 License: Apache-2.0 Imports: 10 Imported by: 1

Documentation

Index

Constants

View Source
const (
	DataSource_Init_FullMethodName   = "/spaceone.api.monitoring.plugin.DataSource/init"
	DataSource_Verify_FullMethodName = "/spaceone.api.monitoring.plugin.DataSource/verify"
)
View Source
const (
	Metric_List_FullMethodName    = "/spaceone.api.monitoring.plugin.Metric/list"
	Metric_GetData_FullMethodName = "/spaceone.api.monitoring.plugin.Metric/get_data"
)
View Source
const (
	Webhook_Init_FullMethodName   = "/spaceone.api.monitoring.plugin.Webhook/init"
	Webhook_Verify_FullMethodName = "/spaceone.api.monitoring.plugin.Webhook/verify"
)
View Source
const (
	Event_Parse_FullMethodName = "/spaceone.api.monitoring.plugin.Event/parse"
)
View Source
const (
	Log_List_FullMethodName = "/spaceone.api.monitoring.plugin.Log/list"
)

Variables

View Source
var (
	EventInfo_Severity_name = map[int32]string{
		0: "NONE",
		1: "CRITICAL",
		2: "ERROR",
		3: "WARNING",
		4: "INFO",
		5: "NOT_AVAILABLE",
	}
	EventInfo_Severity_value = map[string]int32{
		"NONE":          0,
		"CRITICAL":      1,
		"ERROR":         2,
		"WARNING":       3,
		"INFO":          4,
		"NOT_AVAILABLE": 5,
	}
)

Enum value maps for EventInfo_Severity.

View Source
var DataSource_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spaceone.api.monitoring.plugin.DataSource",
	HandlerType: (*DataSourceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "init",
			Handler:    _DataSource_Init_Handler,
		},
		{
			MethodName: "verify",
			Handler:    _DataSource_Verify_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "spaceone/api/monitoring/plugin/data_source.proto",
}

DataSource_ServiceDesc is the grpc.ServiceDesc for DataSource 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 Event_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spaceone.api.monitoring.plugin.Event",
	HandlerType: (*EventServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "parse",
			Handler:    _Event_Parse_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "spaceone/api/monitoring/plugin/event.proto",
}

Event_ServiceDesc is the grpc.ServiceDesc for Event 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_spaceone_api_monitoring_plugin_data_source_proto protoreflect.FileDescriptor
View Source
var File_spaceone_api_monitoring_plugin_event_proto protoreflect.FileDescriptor
View Source
var File_spaceone_api_monitoring_plugin_log_proto protoreflect.FileDescriptor
View Source
var File_spaceone_api_monitoring_plugin_metric_proto protoreflect.FileDescriptor
View Source
var File_spaceone_api_monitoring_plugin_webhook_proto protoreflect.FileDescriptor
View Source
var Log_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spaceone.api.monitoring.plugin.Log",
	HandlerType: (*LogServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "list",
			Handler:       _Log_List_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "spaceone/api/monitoring/plugin/log.proto",
}

Log_ServiceDesc is the grpc.ServiceDesc for Log 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 Metric_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spaceone.api.monitoring.plugin.Metric",
	HandlerType: (*MetricServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "list",
			Handler:    _Metric_List_Handler,
		},
		{
			MethodName: "get_data",
			Handler:    _Metric_GetData_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "spaceone/api/monitoring/plugin/metric.proto",
}

Metric_ServiceDesc is the grpc.ServiceDesc for Metric 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 Webhook_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spaceone.api.monitoring.plugin.Webhook",
	HandlerType: (*WebhookServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "init",
			Handler:    _Webhook_Init_Handler,
		},
		{
			MethodName: "verify",
			Handler:    _Webhook_Verify_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "spaceone/api/monitoring/plugin/webhook.proto",
}

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

Functions

func RegisterDataSourceServer

func RegisterDataSourceServer(s grpc.ServiceRegistrar, srv DataSourceServer)

func RegisterEventServer

func RegisterEventServer(s grpc.ServiceRegistrar, srv EventServer)

func RegisterLogServer

func RegisterLogServer(s grpc.ServiceRegistrar, srv LogServer)

func RegisterMetricServer

func RegisterMetricServer(s grpc.ServiceRegistrar, srv MetricServer)

func RegisterWebhookServer

func RegisterWebhookServer(s grpc.ServiceRegistrar, srv WebhookServer)

Types

type DataSourceClient

type DataSourceClient interface {
	// Initializes a specific DataSource. During initialization, the DataSource information to be passed to the DataSource user is delivered as `metadata`. DataSource information includes its name and version.
	Init(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*PluginInfo, error)
	// Verifies a specific DataSource. You must specify the parameter `secret_data`, encrypted account data of the DataSource to validate.
	Verify(ctx context.Context, in *PluginVerifyRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

DataSourceClient is the client API for DataSource 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 NewDataSourceClient

func NewDataSourceClient(cc grpc.ClientConnInterface) DataSourceClient

type DataSourceServer

type DataSourceServer interface {
	// Initializes a specific DataSource. During initialization, the DataSource information to be passed to the DataSource user is delivered as `metadata`. DataSource information includes its name and version.
	Init(context.Context, *InitRequest) (*PluginInfo, error)
	// Verifies a specific DataSource. You must specify the parameter `secret_data`, encrypted account data of the DataSource to validate.
	Verify(context.Context, *PluginVerifyRequest) (*empty.Empty, error)
	// contains filtered or unexported methods
}

DataSourceServer is the server API for DataSource service. All implementations must embed UnimplementedDataSourceServer for forward compatibility

type EventClient

type EventClient interface {
	// Parses a specific Event resource and transforms the resource from external data collected to data available in Cloudforet internally. The `parse` method standardizes all different data from external monitoring systems.
	Parse(ctx context.Context, in *ParseRequest, opts ...grpc.CallOption) (*EventsInfo, error)
}

EventClient is the client API for Event 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 NewEventClient

func NewEventClient(cc grpc.ClientConnInterface) EventClient

type EventInfo

type EventInfo struct {
	EventKey       string             `protobuf:"bytes,1,opt,name=event_key,json=eventKey,proto3" json:"event_key,omitempty"`
	EventType      string             `protobuf:"bytes,2,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	Title          string             `protobuf:"bytes,3,opt,name=title,proto3" json:"title,omitempty"`
	Description    string             `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Severity       EventInfo_Severity `protobuf:"varint,5,opt,name=severity,proto3,enum=spaceone.api.monitoring.plugin.EventInfo_Severity" json:"severity,omitempty"`
	Resource       *_struct.Struct    `protobuf:"bytes,6,opt,name=resource,proto3" json:"resource,omitempty"`
	Rule           string             `protobuf:"bytes,7,opt,name=rule,proto3" json:"rule,omitempty"`
	OccurredAt     string             `protobuf:"bytes,8,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
	AdditionalInfo *_struct.Struct    `protobuf:"bytes,9,opt,name=additional_info,json=additionalInfo,proto3" json:"additional_info,omitempty"`
	ImageUrl       string             `protobuf:"bytes,10,opt,name=image_url,json=imageUrl,proto3" json:"image_url,omitempty"`
	Provider       string             `protobuf:"bytes,11,opt,name=provider,proto3" json:"provider,omitempty"`
	Account        string             `protobuf:"bytes,12,opt,name=account,proto3" json:"account,omitempty"`
	// contains filtered or unexported fields
}

func (*EventInfo) Descriptor deprecated

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

Deprecated: Use EventInfo.ProtoReflect.Descriptor instead.

func (*EventInfo) GetAccount

func (x *EventInfo) GetAccount() string

func (*EventInfo) GetAdditionalInfo

func (x *EventInfo) GetAdditionalInfo() *_struct.Struct

func (*EventInfo) GetDescription

func (x *EventInfo) GetDescription() string

func (*EventInfo) GetEventKey

func (x *EventInfo) GetEventKey() string

func (*EventInfo) GetEventType

func (x *EventInfo) GetEventType() string

func (*EventInfo) GetImageUrl

func (x *EventInfo) GetImageUrl() string

func (*EventInfo) GetOccurredAt

func (x *EventInfo) GetOccurredAt() string

func (*EventInfo) GetProvider

func (x *EventInfo) GetProvider() string

func (*EventInfo) GetResource

func (x *EventInfo) GetResource() *_struct.Struct

func (*EventInfo) GetRule

func (x *EventInfo) GetRule() string

func (*EventInfo) GetSeverity

func (x *EventInfo) GetSeverity() EventInfo_Severity

func (*EventInfo) GetTitle

func (x *EventInfo) GetTitle() string

func (*EventInfo) ProtoMessage

func (*EventInfo) ProtoMessage()

func (*EventInfo) ProtoReflect

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

func (*EventInfo) Reset

func (x *EventInfo) Reset()

func (*EventInfo) String

func (x *EventInfo) String() string

type EventInfo_Severity

type EventInfo_Severity int32
const (
	EventInfo_NONE          EventInfo_Severity = 0
	EventInfo_CRITICAL      EventInfo_Severity = 1
	EventInfo_ERROR         EventInfo_Severity = 2
	EventInfo_WARNING       EventInfo_Severity = 3
	EventInfo_INFO          EventInfo_Severity = 4
	EventInfo_NOT_AVAILABLE EventInfo_Severity = 5
)

func (EventInfo_Severity) Descriptor

func (EventInfo_Severity) Enum

func (EventInfo_Severity) EnumDescriptor deprecated

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

Deprecated: Use EventInfo_Severity.Descriptor instead.

func (EventInfo_Severity) Number

func (EventInfo_Severity) String

func (x EventInfo_Severity) String() string

func (EventInfo_Severity) Type

type EventServer

type EventServer interface {
	// Parses a specific Event resource and transforms the resource from external data collected to data available in Cloudforet internally. The `parse` method standardizes all different data from external monitoring systems.
	Parse(context.Context, *ParseRequest) (*EventsInfo, error)
	// contains filtered or unexported methods
}

EventServer is the server API for Event service. All implementations must embed UnimplementedEventServer for forward compatibility

type EventsInfo

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

func (*EventsInfo) Descriptor deprecated

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

Deprecated: Use EventsInfo.ProtoReflect.Descriptor instead.

func (*EventsInfo) GetResults

func (x *EventsInfo) GetResults() []*EventInfo

func (*EventsInfo) ProtoMessage

func (*EventsInfo) ProtoMessage()

func (*EventsInfo) ProtoReflect

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

func (*EventsInfo) Reset

func (x *EventsInfo) Reset()

func (*EventsInfo) String

func (x *EventsInfo) String() string

type InitRequest

type InitRequest struct {
	Options *_struct.Struct `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*InitRequest) Descriptor deprecated

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

Deprecated: Use InitRequest.ProtoReflect.Descriptor instead.

func (*InitRequest) GetOptions

func (x *InitRequest) GetOptions() *_struct.Struct

func (*InitRequest) ProtoMessage

func (*InitRequest) ProtoMessage()

func (*InitRequest) ProtoReflect

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

func (*InitRequest) Reset

func (x *InitRequest) Reset()

func (*InitRequest) String

func (x *InitRequest) String() string

type LogClient

type LogClient interface {
	List(ctx context.Context, in *LogRequest, opts ...grpc.CallOption) (Log_ListClient, error)
}

LogClient is the client API for Log 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 NewLogClient

func NewLogClient(cc grpc.ClientConnInterface) LogClient

type LogRequest

type LogRequest struct {
	Options    *_struct.Struct `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	SecretData *_struct.Struct `protobuf:"bytes,2,opt,name=secret_data,json=secretData,proto3" json:"secret_data,omitempty"`
	// +optional
	Schema string          `protobuf:"bytes,3,opt,name=schema,proto3" json:"schema,omitempty"`
	Query  *_struct.Struct `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
	// +optional
	Keyword string `protobuf:"bytes,5,opt,name=keyword,proto3" json:"keyword,omitempty"`
	Start   string `protobuf:"bytes,10,opt,name=start,proto3" json:"start,omitempty"`
	End     string `protobuf:"bytes,11,opt,name=end,proto3" json:"end,omitempty"`
	// +optional
	Sort *Sort `protobuf:"bytes,12,opt,name=sort,proto3" json:"sort,omitempty"`
	// +optional
	Limit int32 `protobuf:"varint,13,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*LogRequest) Descriptor deprecated

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

Deprecated: Use LogRequest.ProtoReflect.Descriptor instead.

func (*LogRequest) GetEnd

func (x *LogRequest) GetEnd() string

func (*LogRequest) GetKeyword

func (x *LogRequest) GetKeyword() string

func (*LogRequest) GetLimit

func (x *LogRequest) GetLimit() int32

func (*LogRequest) GetOptions

func (x *LogRequest) GetOptions() *_struct.Struct

func (*LogRequest) GetQuery

func (x *LogRequest) GetQuery() *_struct.Struct

func (*LogRequest) GetSchema

func (x *LogRequest) GetSchema() string

func (*LogRequest) GetSecretData

func (x *LogRequest) GetSecretData() *_struct.Struct

func (*LogRequest) GetSort

func (x *LogRequest) GetSort() *Sort

func (*LogRequest) GetStart

func (x *LogRequest) GetStart() string

func (*LogRequest) ProtoMessage

func (*LogRequest) ProtoMessage()

func (*LogRequest) ProtoReflect

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

func (*LogRequest) Reset

func (x *LogRequest) Reset()

func (*LogRequest) String

func (x *LogRequest) String() string

type LogServer

type LogServer interface {
	List(*LogRequest, Log_ListServer) error
	// contains filtered or unexported methods
}

LogServer is the server API for Log service. All implementations must embed UnimplementedLogServer for forward compatibility

type Log_ListClient

type Log_ListClient interface {
	Recv() (*LogsDataInfo, error)
	grpc.ClientStream
}

type Log_ListServer

type Log_ListServer interface {
	Send(*LogsDataInfo) error
	grpc.ServerStream
}

type LogsDataInfo

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

func (*LogsDataInfo) Descriptor deprecated

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

Deprecated: Use LogsDataInfo.ProtoReflect.Descriptor instead.

func (*LogsDataInfo) GetResults

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

func (*LogsDataInfo) ProtoMessage

func (*LogsDataInfo) ProtoMessage()

func (*LogsDataInfo) ProtoReflect

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

func (*LogsDataInfo) Reset

func (x *LogsDataInfo) Reset()

func (*LogsDataInfo) String

func (x *LogsDataInfo) String() string

type MetricClient

type MetricClient interface {
	// Gets a list of all Metrics from a specific cloud service. You can use the method to list up the Metrics to collect before using the `get_data` method to collect the Metrics.
	List(ctx context.Context, in *MetricRequest, opts ...grpc.CallOption) (*MetricsInfo, error)
	// Gets a Metric from a specific cloud service resource `instance`. By specifying the time period to collect the Metric, the Metric data value of the `instance` during the period is returned.
	GetData(ctx context.Context, in *MetricDataRequest, opts ...grpc.CallOption) (*MetricDataInfo, error)
}

MetricClient is the client API for Metric 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 NewMetricClient

func NewMetricClient(cc grpc.ClientConnInterface) MetricClient

type MetricDataInfo

type MetricDataInfo struct {
	Labels *_struct.ListValue `protobuf:"bytes,1,opt,name=labels,proto3" json:"labels,omitempty"`
	Values *_struct.Struct    `protobuf:"bytes,2,opt,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricDataInfo) Descriptor deprecated

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

Deprecated: Use MetricDataInfo.ProtoReflect.Descriptor instead.

func (*MetricDataInfo) GetLabels

func (x *MetricDataInfo) GetLabels() *_struct.ListValue

func (*MetricDataInfo) GetValues

func (x *MetricDataInfo) GetValues() *_struct.Struct

func (*MetricDataInfo) ProtoMessage

func (*MetricDataInfo) ProtoMessage()

func (*MetricDataInfo) ProtoReflect

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

func (*MetricDataInfo) Reset

func (x *MetricDataInfo) Reset()

func (*MetricDataInfo) String

func (x *MetricDataInfo) String() string

type MetricDataRequest

type MetricDataRequest struct {
	Options     *_struct.Struct `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	SecretData  *_struct.Struct `protobuf:"bytes,2,opt,name=secret_data,json=secretData,proto3" json:"secret_data,omitempty"`
	MetricQuery *_struct.Struct `protobuf:"bytes,3,opt,name=metric_query,json=metricQuery,proto3" json:"metric_query,omitempty"`
	// metric identifier in case of requested metric info is not a single.
	Metric string `protobuf:"bytes,4,opt,name=metric,proto3" json:"metric,omitempty"`
	Start  string `protobuf:"bytes,5,opt,name=start,proto3" json:"start,omitempty"`
	End    string `protobuf:"bytes,6,opt,name=end,proto3" json:"end,omitempty"`
	// +optional
	Period int32 `protobuf:"varint,7,opt,name=period,proto3" json:"period,omitempty"`
	// +optional
	Stat string `protobuf:"bytes,8,opt,name=stat,proto3" json:"stat,omitempty"`
	// +optional
	Schema string `protobuf:"bytes,9,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricDataRequest) Descriptor deprecated

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

Deprecated: Use MetricDataRequest.ProtoReflect.Descriptor instead.

func (*MetricDataRequest) GetEnd

func (x *MetricDataRequest) GetEnd() string

func (*MetricDataRequest) GetMetric

func (x *MetricDataRequest) GetMetric() string

func (*MetricDataRequest) GetMetricQuery

func (x *MetricDataRequest) GetMetricQuery() *_struct.Struct

func (*MetricDataRequest) GetOptions

func (x *MetricDataRequest) GetOptions() *_struct.Struct

func (*MetricDataRequest) GetPeriod

func (x *MetricDataRequest) GetPeriod() int32

func (*MetricDataRequest) GetSchema

func (x *MetricDataRequest) GetSchema() string

func (*MetricDataRequest) GetSecretData

func (x *MetricDataRequest) GetSecretData() *_struct.Struct

func (*MetricDataRequest) GetStart

func (x *MetricDataRequest) GetStart() string

func (*MetricDataRequest) GetStat

func (x *MetricDataRequest) GetStat() string

func (*MetricDataRequest) ProtoMessage

func (*MetricDataRequest) ProtoMessage()

func (*MetricDataRequest) ProtoReflect

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

func (*MetricDataRequest) Reset

func (x *MetricDataRequest) Reset()

func (*MetricDataRequest) String

func (x *MetricDataRequest) String() string

type MetricInfo

type MetricInfo struct {
	Key         string          `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Name        string          `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Group       string          `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
	Unit        *_struct.Struct `protobuf:"bytes,4,opt,name=unit,proto3" json:"unit,omitempty"`
	MetricQuery *_struct.Struct `protobuf:"bytes,5,opt,name=metric_query,json=metricQuery,proto3" json:"metric_query,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricInfo) Descriptor deprecated

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

Deprecated: Use MetricInfo.ProtoReflect.Descriptor instead.

func (*MetricInfo) GetGroup

func (x *MetricInfo) GetGroup() string

func (*MetricInfo) GetKey

func (x *MetricInfo) GetKey() string

func (*MetricInfo) GetMetricQuery

func (x *MetricInfo) GetMetricQuery() *_struct.Struct

func (*MetricInfo) GetName

func (x *MetricInfo) GetName() string

func (*MetricInfo) GetUnit

func (x *MetricInfo) GetUnit() *_struct.Struct

func (*MetricInfo) ProtoMessage

func (*MetricInfo) ProtoMessage()

func (*MetricInfo) ProtoReflect

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

func (*MetricInfo) Reset

func (x *MetricInfo) Reset()

func (*MetricInfo) String

func (x *MetricInfo) String() string

type MetricRequest

type MetricRequest struct {
	Options    *_struct.Struct `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	SecretData *_struct.Struct `protobuf:"bytes,2,opt,name=secret_data,json=secretData,proto3" json:"secret_data,omitempty"`
	Query      *_struct.Struct `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	// +optional
	Schema string `protobuf:"bytes,4,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricRequest) Descriptor deprecated

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

Deprecated: Use MetricRequest.ProtoReflect.Descriptor instead.

func (*MetricRequest) GetOptions

func (x *MetricRequest) GetOptions() *_struct.Struct

func (*MetricRequest) GetQuery

func (x *MetricRequest) GetQuery() *_struct.Struct

func (*MetricRequest) GetSchema

func (x *MetricRequest) GetSchema() string

func (*MetricRequest) GetSecretData

func (x *MetricRequest) GetSecretData() *_struct.Struct

func (*MetricRequest) ProtoMessage

func (*MetricRequest) ProtoMessage()

func (*MetricRequest) ProtoReflect

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

func (*MetricRequest) Reset

func (x *MetricRequest) Reset()

func (*MetricRequest) String

func (x *MetricRequest) String() string

type MetricServer

type MetricServer interface {
	// Gets a list of all Metrics from a specific cloud service. You can use the method to list up the Metrics to collect before using the `get_data` method to collect the Metrics.
	List(context.Context, *MetricRequest) (*MetricsInfo, error)
	// Gets a Metric from a specific cloud service resource `instance`. By specifying the time period to collect the Metric, the Metric data value of the `instance` during the period is returned.
	GetData(context.Context, *MetricDataRequest) (*MetricDataInfo, error)
	// contains filtered or unexported methods
}

MetricServer is the server API for Metric service. All implementations must embed UnimplementedMetricServer for forward compatibility

type MetricsInfo

type MetricsInfo struct {
	Metrics []*MetricInfo `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsInfo) Descriptor deprecated

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

Deprecated: Use MetricsInfo.ProtoReflect.Descriptor instead.

func (*MetricsInfo) GetMetrics

func (x *MetricsInfo) GetMetrics() []*MetricInfo

func (*MetricsInfo) ProtoMessage

func (*MetricsInfo) ProtoMessage()

func (*MetricsInfo) ProtoReflect

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

func (*MetricsInfo) Reset

func (x *MetricsInfo) Reset()

func (*MetricsInfo) String

func (x *MetricsInfo) String() string

type ParseRequest

type ParseRequest struct {
	Options *_struct.Struct `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// // Unpredictable data format that comes from Webhook
	Data *_struct.Struct `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ParseRequest) Descriptor deprecated

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

Deprecated: Use ParseRequest.ProtoReflect.Descriptor instead.

func (*ParseRequest) GetData

func (x *ParseRequest) GetData() *_struct.Struct

func (*ParseRequest) GetOptions

func (x *ParseRequest) GetOptions() *_struct.Struct

func (*ParseRequest) ProtoMessage

func (*ParseRequest) ProtoMessage()

func (*ParseRequest) ProtoReflect

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

func (*ParseRequest) Reset

func (x *ParseRequest) Reset()

func (*ParseRequest) String

func (x *ParseRequest) String() string

type PluginInfo

type PluginInfo struct {
	Metadata *_struct.Struct `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*PluginInfo) Descriptor deprecated

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

Deprecated: Use PluginInfo.ProtoReflect.Descriptor instead.

func (*PluginInfo) GetMetadata

func (x *PluginInfo) GetMetadata() *_struct.Struct

func (*PluginInfo) ProtoMessage

func (*PluginInfo) ProtoMessage()

func (*PluginInfo) ProtoReflect

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

func (*PluginInfo) Reset

func (x *PluginInfo) Reset()

func (*PluginInfo) String

func (x *PluginInfo) String() string

type PluginVerifyRequest

type PluginVerifyRequest struct {
	Options    *_struct.Struct `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	SecretData *_struct.Struct `protobuf:"bytes,2,opt,name=secret_data,json=secretData,proto3" json:"secret_data,omitempty"`
	// +optional
	Schema string `protobuf:"bytes,3,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*PluginVerifyRequest) Descriptor deprecated

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

Deprecated: Use PluginVerifyRequest.ProtoReflect.Descriptor instead.

func (*PluginVerifyRequest) GetOptions

func (x *PluginVerifyRequest) GetOptions() *_struct.Struct

func (*PluginVerifyRequest) GetSchema

func (x *PluginVerifyRequest) GetSchema() string

func (*PluginVerifyRequest) GetSecretData

func (x *PluginVerifyRequest) GetSecretData() *_struct.Struct

func (*PluginVerifyRequest) ProtoMessage

func (*PluginVerifyRequest) ProtoMessage()

func (*PluginVerifyRequest) ProtoReflect

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

func (*PluginVerifyRequest) Reset

func (x *PluginVerifyRequest) Reset()

func (*PluginVerifyRequest) String

func (x *PluginVerifyRequest) String() string

type Sort

type Sort struct {
	Key  string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Desc bool   `protobuf:"varint,2,opt,name=desc,proto3" json:"desc,omitempty"`
	// contains filtered or unexported fields
}

func (*Sort) Descriptor deprecated

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

Deprecated: Use Sort.ProtoReflect.Descriptor instead.

func (*Sort) GetDesc

func (x *Sort) GetDesc() bool

func (*Sort) GetKey

func (x *Sort) GetKey() string

func (*Sort) ProtoMessage

func (*Sort) ProtoMessage()

func (*Sort) ProtoReflect

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

func (*Sort) Reset

func (x *Sort) Reset()

func (*Sort) String

func (x *Sort) String() string

type UnimplementedDataSourceServer

type UnimplementedDataSourceServer struct {
}

UnimplementedDataSourceServer must be embedded to have forward compatible implementations.

func (UnimplementedDataSourceServer) Init

func (UnimplementedDataSourceServer) Verify

type UnimplementedEventServer

type UnimplementedEventServer struct {
}

UnimplementedEventServer must be embedded to have forward compatible implementations.

func (UnimplementedEventServer) Parse

type UnimplementedLogServer

type UnimplementedLogServer struct {
}

UnimplementedLogServer must be embedded to have forward compatible implementations.

func (UnimplementedLogServer) List

type UnimplementedMetricServer

type UnimplementedMetricServer struct {
}

UnimplementedMetricServer must be embedded to have forward compatible implementations.

func (UnimplementedMetricServer) GetData

func (UnimplementedMetricServer) List

type UnimplementedWebhookServer

type UnimplementedWebhookServer struct {
}

UnimplementedWebhookServer must be embedded to have forward compatible implementations.

func (UnimplementedWebhookServer) Init

func (UnimplementedWebhookServer) Verify

type UnsafeDataSourceServer

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

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

type UnsafeEventServer

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

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

type UnsafeLogServer

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

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

type UnsafeMetricServer

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

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

type UnsafeWebhookServer

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

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

type WebhookClient

type WebhookClient interface {
	// Verifies a specific Webhook. You must specify the parameter `secret_data`, encrypted account data of the Webhook to validate.
	Init(ctx context.Context, in *WebhookInitRequest, opts ...grpc.CallOption) (*WebhookPluginInfo, error)
	// Initializes a specific Webhook. During initialization, the Webhook information to be passed to the Webhook user is delivered as `metadata`. Webhook information includes its name and version.
	Verify(ctx context.Context, in *WebhookPluginVerifyRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

WebhookClient is the client API for Webhook 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 NewWebhookClient

func NewWebhookClient(cc grpc.ClientConnInterface) WebhookClient

type WebhookInitRequest

type WebhookInitRequest struct {
	Options *_struct.Struct `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*WebhookInitRequest) Descriptor deprecated

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

Deprecated: Use WebhookInitRequest.ProtoReflect.Descriptor instead.

func (*WebhookInitRequest) GetOptions

func (x *WebhookInitRequest) GetOptions() *_struct.Struct

func (*WebhookInitRequest) ProtoMessage

func (*WebhookInitRequest) ProtoMessage()

func (*WebhookInitRequest) ProtoReflect

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

func (*WebhookInitRequest) Reset

func (x *WebhookInitRequest) Reset()

func (*WebhookInitRequest) String

func (x *WebhookInitRequest) String() string

type WebhookPluginInfo

type WebhookPluginInfo struct {
	Metadata *_struct.Struct `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*WebhookPluginInfo) Descriptor deprecated

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

Deprecated: Use WebhookPluginInfo.ProtoReflect.Descriptor instead.

func (*WebhookPluginInfo) GetMetadata

func (x *WebhookPluginInfo) GetMetadata() *_struct.Struct

func (*WebhookPluginInfo) ProtoMessage

func (*WebhookPluginInfo) ProtoMessage()

func (*WebhookPluginInfo) ProtoReflect

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

func (*WebhookPluginInfo) Reset

func (x *WebhookPluginInfo) Reset()

func (*WebhookPluginInfo) String

func (x *WebhookPluginInfo) String() string

type WebhookPluginVerifyRequest

type WebhookPluginVerifyRequest struct {
	Options *_struct.Struct `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*WebhookPluginVerifyRequest) Descriptor deprecated

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

Deprecated: Use WebhookPluginVerifyRequest.ProtoReflect.Descriptor instead.

func (*WebhookPluginVerifyRequest) GetOptions

func (x *WebhookPluginVerifyRequest) GetOptions() *_struct.Struct

func (*WebhookPluginVerifyRequest) ProtoMessage

func (*WebhookPluginVerifyRequest) ProtoMessage()

func (*WebhookPluginVerifyRequest) ProtoReflect

func (*WebhookPluginVerifyRequest) Reset

func (x *WebhookPluginVerifyRequest) Reset()

func (*WebhookPluginVerifyRequest) String

func (x *WebhookPluginVerifyRequest) String() string

type WebhookServer

type WebhookServer interface {
	// Verifies a specific Webhook. You must specify the parameter `secret_data`, encrypted account data of the Webhook to validate.
	Init(context.Context, *WebhookInitRequest) (*WebhookPluginInfo, error)
	// Initializes a specific Webhook. During initialization, the Webhook information to be passed to the Webhook user is delivered as `metadata`. Webhook information includes its name and version.
	Verify(context.Context, *WebhookPluginVerifyRequest) (*empty.Empty, error)
	// contains filtered or unexported methods
}

WebhookServer is the server API for Webhook service. All implementations must embed UnimplementedWebhookServer for forward compatibility

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL