v1

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: 12 Imported by: 1

Documentation

Index

Constants

View Source
const (
	History_Create_FullMethodName = "/spaceone.api.statistics.v1.History/create"
	History_List_FullMethodName   = "/spaceone.api.statistics.v1.History/list"
	History_Stat_FullMethodName   = "/spaceone.api.statistics.v1.History/stat"
)
View Source
const (
	Schedule_Add_FullMethodName     = "/spaceone.api.statistics.v1.Schedule/add"
	Schedule_Update_FullMethodName  = "/spaceone.api.statistics.v1.Schedule/update"
	Schedule_Enable_FullMethodName  = "/spaceone.api.statistics.v1.Schedule/enable"
	Schedule_Disable_FullMethodName = "/spaceone.api.statistics.v1.Schedule/disable"
	Schedule_Delete_FullMethodName  = "/spaceone.api.statistics.v1.Schedule/delete"
	Schedule_Get_FullMethodName     = "/spaceone.api.statistics.v1.Schedule/get"
	Schedule_List_FullMethodName    = "/spaceone.api.statistics.v1.Schedule/list"
	Schedule_Stat_FullMethodName    = "/spaceone.api.statistics.v1.Schedule/stat"
)
View Source
const (
	Resource_Stat_FullMethodName = "/spaceone.api.statistics.v1.Resource/stat"
)

Variables

View Source
var (
	StatAggregateJoin_JoinType_name = map[int32]string{
		0: "LEFT",
		1: "RIGHT",
		2: "OUTER",
		3: "INNER",
	}
	StatAggregateJoin_JoinType_value = map[string]int32{
		"LEFT":  0,
		"RIGHT": 1,
		"OUTER": 2,
		"INNER": 3,
	}
)

Enum value maps for StatAggregateJoin_JoinType.

View Source
var (
	ScheduleInfo_State_name = map[int32]string{
		0: "NONE",
		1: "ENABLED",
		2: "DISABLED",
	}
	ScheduleInfo_State_value = map[string]int32{
		"NONE":     0,
		"ENABLED":  1,
		"DISABLED": 2,
	}
)

Enum value maps for ScheduleInfo_State.

View Source
var File_spaceone_api_statistics_v1_history_proto protoreflect.FileDescriptor
View Source
var File_spaceone_api_statistics_v1_resource_proto protoreflect.FileDescriptor
View Source
var File_spaceone_api_statistics_v1_schedule_proto protoreflect.FileDescriptor
View Source
var History_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spaceone.api.statistics.v1.History",
	HandlerType: (*HistoryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "create",
			Handler:    _History_Create_Handler,
		},
		{
			MethodName: "list",
			Handler:    _History_List_Handler,
		},
		{
			MethodName: "stat",
			Handler:    _History_Stat_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "spaceone/api/statistics/v1/history.proto",
}

History_ServiceDesc is the grpc.ServiceDesc for History 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 Resource_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spaceone.api.statistics.v1.Resource",
	HandlerType: (*ResourceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "stat",
			Handler:    _Resource_Stat_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "spaceone/api/statistics/v1/resource.proto",
}

Resource_ServiceDesc is the grpc.ServiceDesc for Resource 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 Schedule_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spaceone.api.statistics.v1.Schedule",
	HandlerType: (*ScheduleServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "add",
			Handler:    _Schedule_Add_Handler,
		},
		{
			MethodName: "update",
			Handler:    _Schedule_Update_Handler,
		},
		{
			MethodName: "enable",
			Handler:    _Schedule_Enable_Handler,
		},
		{
			MethodName: "disable",
			Handler:    _Schedule_Disable_Handler,
		},
		{
			MethodName: "delete",
			Handler:    _Schedule_Delete_Handler,
		},
		{
			MethodName: "get",
			Handler:    _Schedule_Get_Handler,
		},
		{
			MethodName: "list",
			Handler:    _Schedule_List_Handler,
		},
		{
			MethodName: "stat",
			Handler:    _Schedule_Stat_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "spaceone/api/statistics/v1/schedule.proto",
}

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

Functions

func RegisterHistoryServer

func RegisterHistoryServer(s grpc.ServiceRegistrar, srv HistoryServer)

func RegisterResourceServer

func RegisterResourceServer(s grpc.ServiceRegistrar, srv ResourceServer)

func RegisterScheduleServer

func RegisterScheduleServer(s grpc.ServiceRegistrar, srv ScheduleServer)

Types

type AddScheduleRequest

type AddScheduleRequest struct {
	Topic    string          `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Options  *_struct.Struct `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	Schedule *Scheduled      `protobuf:"bytes,3,opt,name=schedule,proto3" json:"schedule,omitempty"`
	// +optional
	Tags *_struct.Struct `protobuf:"bytes,4,opt,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*AddScheduleRequest) Descriptor deprecated

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

Deprecated: Use AddScheduleRequest.ProtoReflect.Descriptor instead.

func (*AddScheduleRequest) GetOptions

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

func (*AddScheduleRequest) GetSchedule

func (x *AddScheduleRequest) GetSchedule() *Scheduled

func (*AddScheduleRequest) GetTags

func (x *AddScheduleRequest) GetTags() *_struct.Struct

func (*AddScheduleRequest) GetTopic

func (x *AddScheduleRequest) GetTopic() string

func (*AddScheduleRequest) ProtoMessage

func (*AddScheduleRequest) ProtoMessage()

func (*AddScheduleRequest) ProtoReflect

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

func (*AddScheduleRequest) Reset

func (x *AddScheduleRequest) Reset()

func (*AddScheduleRequest) String

func (x *AddScheduleRequest) String() string

type CreateHistoryRequest

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

func (*CreateHistoryRequest) Descriptor deprecated

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

Deprecated: Use CreateHistoryRequest.ProtoReflect.Descriptor instead.

func (*CreateHistoryRequest) GetScheduleId

func (x *CreateHistoryRequest) GetScheduleId() string

func (*CreateHistoryRequest) ProtoMessage

func (*CreateHistoryRequest) ProtoMessage()

func (*CreateHistoryRequest) ProtoReflect

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

func (*CreateHistoryRequest) Reset

func (x *CreateHistoryRequest) Reset()

func (*CreateHistoryRequest) String

func (x *CreateHistoryRequest) String() string

type HistoryClient

type HistoryClient interface {
	// Creates a new History. Gets a Schedule as an input and creates a History as an output. You can use this method to manually run a specific Schedule.
	Create(ctx context.Context, in *CreateHistoryRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Gets a list of all Histories. You can use a query to get a filtered list of Histories.
	List(ctx context.Context, in *QueryHistoryRequest, opts ...grpc.CallOption) (*HistoryInfo, error)
	Stat(ctx context.Context, in *HistoryStatRequest, opts ...grpc.CallOption) (*_struct.Struct, error)
}

HistoryClient is the client API for History 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 NewHistoryClient

func NewHistoryClient(cc grpc.ClientConnInterface) HistoryClient

type HistoryInfo

type HistoryInfo struct {
	Results    []*HistoryValueInfo `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	TotalCount int32               `protobuf:"varint,2,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
	// contains filtered or unexported fields
}

func (*HistoryInfo) Descriptor deprecated

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

Deprecated: Use HistoryInfo.ProtoReflect.Descriptor instead.

func (*HistoryInfo) GetResults

func (x *HistoryInfo) GetResults() []*HistoryValueInfo

func (*HistoryInfo) GetTotalCount

func (x *HistoryInfo) GetTotalCount() int32

func (*HistoryInfo) ProtoMessage

func (*HistoryInfo) ProtoMessage()

func (*HistoryInfo) ProtoReflect

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

func (*HistoryInfo) Reset

func (x *HistoryInfo) Reset()

func (*HistoryInfo) String

func (x *HistoryInfo) String() string

type HistoryServer

type HistoryServer interface {
	// Creates a new History. Gets a Schedule as an input and creates a History as an output. You can use this method to manually run a specific Schedule.
	Create(context.Context, *CreateHistoryRequest) (*empty.Empty, error)
	// Gets a list of all Histories. You can use a query to get a filtered list of Histories.
	List(context.Context, *QueryHistoryRequest) (*HistoryInfo, error)
	Stat(context.Context, *HistoryStatRequest) (*_struct.Struct, error)
	// contains filtered or unexported methods
}

HistoryServer is the server API for History service. All implementations must embed UnimplementedHistoryServer for forward compatibility

type HistoryStatRequest

type HistoryStatRequest struct {
	Query *v2.StatisticsQuery `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// +optional
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

func (*HistoryStatRequest) Descriptor deprecated

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

Deprecated: Use HistoryStatRequest.ProtoReflect.Descriptor instead.

func (*HistoryStatRequest) GetQuery

func (x *HistoryStatRequest) GetQuery() *v2.StatisticsQuery

func (*HistoryStatRequest) GetTopic

func (x *HistoryStatRequest) GetTopic() string

func (*HistoryStatRequest) ProtoMessage

func (*HistoryStatRequest) ProtoMessage()

func (*HistoryStatRequest) ProtoReflect

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

func (*HistoryStatRequest) Reset

func (x *HistoryStatRequest) Reset()

func (*HistoryStatRequest) String

func (x *HistoryStatRequest) String() string

type HistoryValueInfo

type HistoryValueInfo struct {
	Topic     string          `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Values    *_struct.Struct `protobuf:"bytes,2,opt,name=values,proto3" json:"values,omitempty"`
	DomainId  string          `protobuf:"bytes,21,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"`
	CreatedAt string          `protobuf:"bytes,31,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*HistoryValueInfo) Descriptor deprecated

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

Deprecated: Use HistoryValueInfo.ProtoReflect.Descriptor instead.

func (*HistoryValueInfo) GetCreatedAt

func (x *HistoryValueInfo) GetCreatedAt() string

func (*HistoryValueInfo) GetDomainId

func (x *HistoryValueInfo) GetDomainId() string

func (*HistoryValueInfo) GetTopic

func (x *HistoryValueInfo) GetTopic() string

func (*HistoryValueInfo) GetValues

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

func (*HistoryValueInfo) ProtoMessage

func (*HistoryValueInfo) ProtoMessage()

func (*HistoryValueInfo) ProtoReflect

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

func (*HistoryValueInfo) Reset

func (x *HistoryValueInfo) Reset()

func (*HistoryValueInfo) String

func (x *HistoryValueInfo) String() string

type QueryHistoryRequest

type QueryHistoryRequest struct {

	// +optional
	Query *v2.Query `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// +optional
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryHistoryRequest) Descriptor deprecated

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

Deprecated: Use QueryHistoryRequest.ProtoReflect.Descriptor instead.

func (*QueryHistoryRequest) GetQuery

func (x *QueryHistoryRequest) GetQuery() *v2.Query

func (*QueryHistoryRequest) GetTopic

func (x *QueryHistoryRequest) GetTopic() string

func (*QueryHistoryRequest) ProtoMessage

func (*QueryHistoryRequest) ProtoMessage()

func (*QueryHistoryRequest) ProtoReflect

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

func (*QueryHistoryRequest) Reset

func (x *QueryHistoryRequest) Reset()

func (*QueryHistoryRequest) String

func (x *QueryHistoryRequest) String() string

type QueryOption

type QueryOption struct {
	Aggregate *StatAggregate `protobuf:"bytes,1,opt,name=aggregate,proto3" json:"aggregate,omitempty"`
	// +optional
	Page *StatPage `protobuf:"bytes,2,opt,name=page,proto3" json:"page,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryOption) Descriptor deprecated

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

Deprecated: Use QueryOption.ProtoReflect.Descriptor instead.

func (*QueryOption) GetAggregate

func (x *QueryOption) GetAggregate() *StatAggregate

func (*QueryOption) GetPage

func (x *QueryOption) GetPage() *StatPage

func (*QueryOption) ProtoMessage

func (*QueryOption) ProtoMessage()

func (*QueryOption) ProtoReflect

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

func (*QueryOption) Reset

func (x *QueryOption) Reset()

func (*QueryOption) String

func (x *QueryOption) String() string

type ResourceClient

type ResourceClient interface {
	// Enables data preprocessing of different services. Although limited, it is possible to create not only basic queries but also data suitable for users' needs, such as joins between two tables created by the query, handling missing values, and sorting.
	Stat(ctx context.Context, in *ResourceStatRequest, opts ...grpc.CallOption) (*_struct.Struct, error)
}

ResourceClient is the client API for Resource 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 NewResourceClient

func NewResourceClient(cc grpc.ClientConnInterface) ResourceClient

type ResourceServer

type ResourceServer interface {
	// Enables data preprocessing of different services. Although limited, it is possible to create not only basic queries but also data suitable for users' needs, such as joins between two tables created by the query, handling missing values, and sorting.
	Stat(context.Context, *ResourceStatRequest) (*_struct.Struct, error)
	// contains filtered or unexported methods
}

ResourceServer is the server API for Resource service. All implementations must embed UnimplementedResourceServer for forward compatibility

type ResourceStatRequest

type ResourceStatRequest struct {
	Aggregate []*StatAggregate `protobuf:"bytes,1,rep,name=aggregate,proto3" json:"aggregate,omitempty"`
	// +optional
	Page *StatPage `protobuf:"bytes,2,opt,name=page,proto3" json:"page,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceStatRequest) Descriptor deprecated

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

Deprecated: Use ResourceStatRequest.ProtoReflect.Descriptor instead.

func (*ResourceStatRequest) GetAggregate

func (x *ResourceStatRequest) GetAggregate() []*StatAggregate

func (*ResourceStatRequest) GetPage

func (x *ResourceStatRequest) GetPage() *StatPage

func (*ResourceStatRequest) ProtoMessage

func (*ResourceStatRequest) ProtoMessage()

func (*ResourceStatRequest) ProtoReflect

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

func (*ResourceStatRequest) Reset

func (x *ResourceStatRequest) Reset()

func (*ResourceStatRequest) String

func (x *ResourceStatRequest) String() string

type ScheduleClient

type ScheduleClient interface {
	// Adds a new Schedule. When creating, `topic` and queries to be used should be specified. The time interval of the Schedule should be also specified to run queries repeatedly. The run set by Schedule starts every hour on the hour.
	Add(ctx context.Context, in *AddScheduleRequest, opts ...grpc.CallOption) (*ScheduleInfo, error)
	// Updates a specific Schedule. You can make changes in Schedule settings, including time intervals.
	Update(ctx context.Context, in *UpdateScheduleRequest, opts ...grpc.CallOption) (*ScheduleInfo, error)
	// Enables a specific Schedule. If a Schedule is enabled, the query usage will be scheduled by the time interval specified.
	Enable(ctx context.Context, in *ScheduleRequest, opts ...grpc.CallOption) (*ScheduleInfo, error)
	// Disables a specific Schedule. If a Schedule is disabled, the query usage will not be scheduled.
	Disable(ctx context.Context, in *ScheduleRequest, opts ...grpc.CallOption) (*ScheduleInfo, error)
	// Deletes a specific Schedule. You must specify the `schedule_id` of the Schedule to delete.
	Delete(ctx context.Context, in *ScheduleRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Gets a specific Schedule. Prints detailed information about the Schedule, including the schedule interval and `state`.
	Get(ctx context.Context, in *ScheduleRequest, opts ...grpc.CallOption) (*ScheduleInfo, error)
	// Gets a list of all Schedules. You can use a query to get a filtered list of Schedules.
	List(ctx context.Context, in *ScheduleQuery, opts ...grpc.CallOption) (*SchedulesInfo, error)
	Stat(ctx context.Context, in *ScheduleStatQuery, opts ...grpc.CallOption) (*_struct.Struct, error)
}

ScheduleClient is the client API for Schedule 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 NewScheduleClient

func NewScheduleClient(cc grpc.ClientConnInterface) ScheduleClient

type ScheduleInfo

type ScheduleInfo struct {
	ScheduleId      string             `protobuf:"bytes,1,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_id,omitempty"`
	Topic           string             `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	State           ScheduleInfo_State `protobuf:"varint,3,opt,name=state,proto3,enum=spaceone.api.statistics.v1.ScheduleInfo_State" json:"state,omitempty"`
	Options         *_struct.Struct    `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	Schedule        *Scheduled         `protobuf:"bytes,5,opt,name=schedule,proto3" json:"schedule,omitempty"`
	Tags            *_struct.Struct    `protobuf:"bytes,6,opt,name=tags,proto3" json:"tags,omitempty"`
	DomainId        string             `protobuf:"bytes,21,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"`
	CreatedAt       string             `protobuf:"bytes,31,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	LastScheduledAt string             `protobuf:"bytes,32,opt,name=last_scheduled_at,json=lastScheduledAt,proto3" json:"last_scheduled_at,omitempty"`
	// contains filtered or unexported fields
}

func (*ScheduleInfo) Descriptor deprecated

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

Deprecated: Use ScheduleInfo.ProtoReflect.Descriptor instead.

func (*ScheduleInfo) GetCreatedAt

func (x *ScheduleInfo) GetCreatedAt() string

func (*ScheduleInfo) GetDomainId

func (x *ScheduleInfo) GetDomainId() string

func (*ScheduleInfo) GetLastScheduledAt

func (x *ScheduleInfo) GetLastScheduledAt() string

func (*ScheduleInfo) GetOptions

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

func (*ScheduleInfo) GetSchedule

func (x *ScheduleInfo) GetSchedule() *Scheduled

func (*ScheduleInfo) GetScheduleId

func (x *ScheduleInfo) GetScheduleId() string

func (*ScheduleInfo) GetState

func (x *ScheduleInfo) GetState() ScheduleInfo_State

func (*ScheduleInfo) GetTags

func (x *ScheduleInfo) GetTags() *_struct.Struct

func (*ScheduleInfo) GetTopic

func (x *ScheduleInfo) GetTopic() string

func (*ScheduleInfo) ProtoMessage

func (*ScheduleInfo) ProtoMessage()

func (*ScheduleInfo) ProtoReflect

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

func (*ScheduleInfo) Reset

func (x *ScheduleInfo) Reset()

func (*ScheduleInfo) String

func (x *ScheduleInfo) String() string

type ScheduleInfo_State

type ScheduleInfo_State int32
const (
	ScheduleInfo_NONE     ScheduleInfo_State = 0
	ScheduleInfo_ENABLED  ScheduleInfo_State = 1
	ScheduleInfo_DISABLED ScheduleInfo_State = 2
)

func (ScheduleInfo_State) Descriptor

func (ScheduleInfo_State) Enum

func (ScheduleInfo_State) EnumDescriptor deprecated

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

Deprecated: Use ScheduleInfo_State.Descriptor instead.

func (ScheduleInfo_State) Number

func (ScheduleInfo_State) String

func (x ScheduleInfo_State) String() string

func (ScheduleInfo_State) Type

type ScheduleQuery

type ScheduleQuery struct {

	// +optional
	Query *v2.Query `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// +optional
	ScheduleId string `protobuf:"bytes,2,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_id,omitempty"`
	// +optional
	Topic string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	// +optional
	State string `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*ScheduleQuery) Descriptor deprecated

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

Deprecated: Use ScheduleQuery.ProtoReflect.Descriptor instead.

func (*ScheduleQuery) GetQuery

func (x *ScheduleQuery) GetQuery() *v2.Query

func (*ScheduleQuery) GetScheduleId

func (x *ScheduleQuery) GetScheduleId() string

func (*ScheduleQuery) GetState

func (x *ScheduleQuery) GetState() string

func (*ScheduleQuery) GetTopic

func (x *ScheduleQuery) GetTopic() string

func (*ScheduleQuery) ProtoMessage

func (*ScheduleQuery) ProtoMessage()

func (*ScheduleQuery) ProtoReflect

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

func (*ScheduleQuery) Reset

func (x *ScheduleQuery) Reset()

func (*ScheduleQuery) String

func (x *ScheduleQuery) String() string

type ScheduleRequest

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

func (*ScheduleRequest) Descriptor deprecated

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

Deprecated: Use ScheduleRequest.ProtoReflect.Descriptor instead.

func (*ScheduleRequest) GetScheduleId

func (x *ScheduleRequest) GetScheduleId() string

func (*ScheduleRequest) ProtoMessage

func (*ScheduleRequest) ProtoMessage()

func (*ScheduleRequest) ProtoReflect

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

func (*ScheduleRequest) Reset

func (x *ScheduleRequest) Reset()

func (*ScheduleRequest) String

func (x *ScheduleRequest) String() string

type ScheduleServer

type ScheduleServer interface {
	// Adds a new Schedule. When creating, `topic` and queries to be used should be specified. The time interval of the Schedule should be also specified to run queries repeatedly. The run set by Schedule starts every hour on the hour.
	Add(context.Context, *AddScheduleRequest) (*ScheduleInfo, error)
	// Updates a specific Schedule. You can make changes in Schedule settings, including time intervals.
	Update(context.Context, *UpdateScheduleRequest) (*ScheduleInfo, error)
	// Enables a specific Schedule. If a Schedule is enabled, the query usage will be scheduled by the time interval specified.
	Enable(context.Context, *ScheduleRequest) (*ScheduleInfo, error)
	// Disables a specific Schedule. If a Schedule is disabled, the query usage will not be scheduled.
	Disable(context.Context, *ScheduleRequest) (*ScheduleInfo, error)
	// Deletes a specific Schedule. You must specify the `schedule_id` of the Schedule to delete.
	Delete(context.Context, *ScheduleRequest) (*empty.Empty, error)
	// Gets a specific Schedule. Prints detailed information about the Schedule, including the schedule interval and `state`.
	Get(context.Context, *ScheduleRequest) (*ScheduleInfo, error)
	// Gets a list of all Schedules. You can use a query to get a filtered list of Schedules.
	List(context.Context, *ScheduleQuery) (*SchedulesInfo, error)
	Stat(context.Context, *ScheduleStatQuery) (*_struct.Struct, error)
	// contains filtered or unexported methods
}

ScheduleServer is the server API for Schedule service. All implementations must embed UnimplementedScheduleServer for forward compatibility

type ScheduleStatQuery

type ScheduleStatQuery struct {
	Query *v2.StatisticsQuery `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

func (*ScheduleStatQuery) Descriptor deprecated

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

Deprecated: Use ScheduleStatQuery.ProtoReflect.Descriptor instead.

func (*ScheduleStatQuery) GetQuery

func (x *ScheduleStatQuery) GetQuery() *v2.StatisticsQuery

func (*ScheduleStatQuery) ProtoMessage

func (*ScheduleStatQuery) ProtoMessage()

func (*ScheduleStatQuery) ProtoReflect

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

func (*ScheduleStatQuery) Reset

func (x *ScheduleStatQuery) Reset()

func (*ScheduleStatQuery) String

func (x *ScheduleStatQuery) String() string

type Scheduled

type Scheduled struct {
	Cron     string  `protobuf:"bytes,1,opt,name=cron,proto3" json:"cron,omitempty"`
	Interval int32   `protobuf:"varint,2,opt,name=interval,proto3" json:"interval,omitempty"`
	Minutes  []int32 `protobuf:"varint,3,rep,packed,name=minutes,proto3" json:"minutes,omitempty"`
	Hours    []int32 `protobuf:"varint,4,rep,packed,name=hours,proto3" json:"hours,omitempty"`
	// contains filtered or unexported fields
}

func (*Scheduled) Descriptor deprecated

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

Deprecated: Use Scheduled.ProtoReflect.Descriptor instead.

func (*Scheduled) GetCron

func (x *Scheduled) GetCron() string

func (*Scheduled) GetHours

func (x *Scheduled) GetHours() []int32

func (*Scheduled) GetInterval

func (x *Scheduled) GetInterval() int32

func (*Scheduled) GetMinutes

func (x *Scheduled) GetMinutes() []int32

func (*Scheduled) ProtoMessage

func (*Scheduled) ProtoMessage()

func (*Scheduled) ProtoReflect

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

func (*Scheduled) Reset

func (x *Scheduled) Reset()

func (*Scheduled) String

func (x *Scheduled) String() string

type SchedulesInfo

type SchedulesInfo struct {
	Results    []*ScheduleInfo `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	TotalCount int32           `protobuf:"varint,2,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
	// contains filtered or unexported fields
}

func (*SchedulesInfo) Descriptor deprecated

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

Deprecated: Use SchedulesInfo.ProtoReflect.Descriptor instead.

func (*SchedulesInfo) GetResults

func (x *SchedulesInfo) GetResults() []*ScheduleInfo

func (*SchedulesInfo) GetTotalCount

func (x *SchedulesInfo) GetTotalCount() int32

func (*SchedulesInfo) ProtoMessage

func (*SchedulesInfo) ProtoMessage()

func (*SchedulesInfo) ProtoReflect

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

func (*SchedulesInfo) Reset

func (x *SchedulesInfo) Reset()

func (*SchedulesInfo) String

func (x *SchedulesInfo) 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 StatAggregate

type StatAggregate struct {

	// Types that are assignable to AggregateAlias:
	//
	//	*StatAggregate_Query
	//	*StatAggregate_Join
	//	*StatAggregate_Concat
	//	*StatAggregate_Sort
	//	*StatAggregate_Formula
	//	*StatAggregate_FillNa
	AggregateAlias isStatAggregate_AggregateAlias `protobuf_oneof:"aggregate_alias"`
	// contains filtered or unexported fields
}

func (*StatAggregate) Descriptor deprecated

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

Deprecated: Use StatAggregate.ProtoReflect.Descriptor instead.

func (*StatAggregate) GetAggregateAlias

func (m *StatAggregate) GetAggregateAlias() isStatAggregate_AggregateAlias

func (*StatAggregate) GetConcat

func (x *StatAggregate) GetConcat() *StatAggregateConcat

func (*StatAggregate) GetFillNa

func (x *StatAggregate) GetFillNa() *StatAggregateFillNA

func (*StatAggregate) GetFormula

func (x *StatAggregate) GetFormula() *StatAggregateFormula

func (*StatAggregate) GetJoin

func (x *StatAggregate) GetJoin() *StatAggregateJoin

func (*StatAggregate) GetQuery

func (x *StatAggregate) GetQuery() *StatAggregateQuery

func (*StatAggregate) GetSort

func (x *StatAggregate) GetSort() *_struct.ListValue

func (*StatAggregate) ProtoMessage

func (*StatAggregate) ProtoMessage()

func (*StatAggregate) ProtoReflect

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

func (*StatAggregate) Reset

func (x *StatAggregate) Reset()

func (*StatAggregate) String

func (x *StatAggregate) String() string

type StatAggregateConcat

type StatAggregateConcat struct {
	ResourceType string              `protobuf:"bytes,1,opt,name=resource_type,json=resourceType,proto3" json:"resource_type,omitempty"`
	Query        *v2.StatisticsQuery `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// +optional
	ExtendData *_struct.Struct `protobuf:"bytes,3,opt,name=extend_data,json=extendData,proto3" json:"extend_data,omitempty"`
	// contains filtered or unexported fields
}

func (*StatAggregateConcat) Descriptor deprecated

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

Deprecated: Use StatAggregateConcat.ProtoReflect.Descriptor instead.

func (*StatAggregateConcat) GetExtendData

func (x *StatAggregateConcat) GetExtendData() *_struct.Struct

func (*StatAggregateConcat) GetQuery

func (x *StatAggregateConcat) GetQuery() *v2.StatisticsQuery

func (*StatAggregateConcat) GetResourceType

func (x *StatAggregateConcat) GetResourceType() string

func (*StatAggregateConcat) ProtoMessage

func (*StatAggregateConcat) ProtoMessage()

func (*StatAggregateConcat) ProtoReflect

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

func (*StatAggregateConcat) Reset

func (x *StatAggregateConcat) Reset()

func (*StatAggregateConcat) String

func (x *StatAggregateConcat) String() string

type StatAggregateFillNA

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

func (*StatAggregateFillNA) Descriptor deprecated

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

Deprecated: Use StatAggregateFillNA.ProtoReflect.Descriptor instead.

func (*StatAggregateFillNA) GetData

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

func (*StatAggregateFillNA) ProtoMessage

func (*StatAggregateFillNA) ProtoMessage()

func (*StatAggregateFillNA) ProtoReflect

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

func (*StatAggregateFillNA) Reset

func (x *StatAggregateFillNA) Reset()

func (*StatAggregateFillNA) String

func (x *StatAggregateFillNA) String() string

type StatAggregateFormula

type StatAggregateFormula struct {

	// Types that are assignable to FormulaAlias:
	//
	//	*StatAggregateFormula_Eval
	//	*StatAggregateFormula_Query
	FormulaAlias isStatAggregateFormula_FormulaAlias `protobuf_oneof:"formula_alias"`
	// contains filtered or unexported fields
}

func (*StatAggregateFormula) Descriptor deprecated

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

Deprecated: Use StatAggregateFormula.ProtoReflect.Descriptor instead.

func (*StatAggregateFormula) GetEval

func (x *StatAggregateFormula) GetEval() string

func (*StatAggregateFormula) GetFormulaAlias

func (m *StatAggregateFormula) GetFormulaAlias() isStatAggregateFormula_FormulaAlias

func (*StatAggregateFormula) GetQuery

func (x *StatAggregateFormula) GetQuery() string

func (*StatAggregateFormula) ProtoMessage

func (*StatAggregateFormula) ProtoMessage()

func (*StatAggregateFormula) ProtoReflect

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

func (*StatAggregateFormula) Reset

func (x *StatAggregateFormula) Reset()

func (*StatAggregateFormula) String

func (x *StatAggregateFormula) String() string

type StatAggregateFormula_Eval

type StatAggregateFormula_Eval struct {
	Eval string `protobuf:"bytes,1,opt,name=eval,proto3,oneof"`
}

type StatAggregateFormula_Query

type StatAggregateFormula_Query struct {
	Query string `protobuf:"bytes,2,opt,name=query,proto3,oneof"`
}

type StatAggregateJoin

type StatAggregateJoin struct {
	ResourceType string              `protobuf:"bytes,1,opt,name=resource_type,json=resourceType,proto3" json:"resource_type,omitempty"`
	Query        *v2.StatisticsQuery `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// +optional
	ExtendData *_struct.Struct `protobuf:"bytes,3,opt,name=extend_data,json=extendData,proto3" json:"extend_data,omitempty"`
	// +optional
	Type StatAggregateJoin_JoinType `protobuf:"varint,4,opt,name=type,proto3,enum=spaceone.api.statistics.v1.StatAggregateJoin_JoinType" json:"type,omitempty"`
	// +optional
	Keys []string `protobuf:"bytes,5,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*StatAggregateJoin) Descriptor deprecated

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

Deprecated: Use StatAggregateJoin.ProtoReflect.Descriptor instead.

func (*StatAggregateJoin) GetExtendData

func (x *StatAggregateJoin) GetExtendData() *_struct.Struct

func (*StatAggregateJoin) GetKeys

func (x *StatAggregateJoin) GetKeys() []string

func (*StatAggregateJoin) GetQuery

func (x *StatAggregateJoin) GetQuery() *v2.StatisticsQuery

func (*StatAggregateJoin) GetResourceType

func (x *StatAggregateJoin) GetResourceType() string

func (*StatAggregateJoin) GetType

func (*StatAggregateJoin) ProtoMessage

func (*StatAggregateJoin) ProtoMessage()

func (*StatAggregateJoin) ProtoReflect

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

func (*StatAggregateJoin) Reset

func (x *StatAggregateJoin) Reset()

func (*StatAggregateJoin) String

func (x *StatAggregateJoin) String() string

type StatAggregateJoin_JoinType

type StatAggregateJoin_JoinType int32
const (
	StatAggregateJoin_LEFT  StatAggregateJoin_JoinType = 0
	StatAggregateJoin_RIGHT StatAggregateJoin_JoinType = 1
	StatAggregateJoin_OUTER StatAggregateJoin_JoinType = 2
	StatAggregateJoin_INNER StatAggregateJoin_JoinType = 3
)

func (StatAggregateJoin_JoinType) Descriptor

func (StatAggregateJoin_JoinType) Enum

func (StatAggregateJoin_JoinType) EnumDescriptor deprecated

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

Deprecated: Use StatAggregateJoin_JoinType.Descriptor instead.

func (StatAggregateJoin_JoinType) Number

func (StatAggregateJoin_JoinType) String

func (StatAggregateJoin_JoinType) Type

type StatAggregateQuery

type StatAggregateQuery struct {
	ResourceType string              `protobuf:"bytes,1,opt,name=resource_type,json=resourceType,proto3" json:"resource_type,omitempty"`
	Query        *v2.StatisticsQuery `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// +optional
	ExtendData *_struct.Struct `protobuf:"bytes,3,opt,name=extend_data,json=extendData,proto3" json:"extend_data,omitempty"`
	// contains filtered or unexported fields
}

func (*StatAggregateQuery) Descriptor deprecated

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

Deprecated: Use StatAggregateQuery.ProtoReflect.Descriptor instead.

func (*StatAggregateQuery) GetExtendData

func (x *StatAggregateQuery) GetExtendData() *_struct.Struct

func (*StatAggregateQuery) GetQuery

func (x *StatAggregateQuery) GetQuery() *v2.StatisticsQuery

func (*StatAggregateQuery) GetResourceType

func (x *StatAggregateQuery) GetResourceType() string

func (*StatAggregateQuery) ProtoMessage

func (*StatAggregateQuery) ProtoMessage()

func (*StatAggregateQuery) ProtoReflect

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

func (*StatAggregateQuery) Reset

func (x *StatAggregateQuery) Reset()

func (*StatAggregateQuery) String

func (x *StatAggregateQuery) String() string

type StatAggregate_Concat

type StatAggregate_Concat struct {
	Concat *StatAggregateConcat `protobuf:"bytes,3,opt,name=concat,proto3,oneof"`
}

type StatAggregate_FillNa

type StatAggregate_FillNa struct {
	FillNa *StatAggregateFillNA `protobuf:"bytes,6,opt,name=fill_na,json=fillNa,proto3,oneof"`
}

type StatAggregate_Formula

type StatAggregate_Formula struct {
	Formula *StatAggregateFormula `protobuf:"bytes,5,opt,name=formula,proto3,oneof"`
}

type StatAggregate_Join

type StatAggregate_Join struct {
	Join *StatAggregateJoin `protobuf:"bytes,2,opt,name=join,proto3,oneof"`
}

type StatAggregate_Query

type StatAggregate_Query struct {
	Query *StatAggregateQuery `protobuf:"bytes,1,opt,name=query,proto3,oneof"`
}

type StatAggregate_Sort

type StatAggregate_Sort struct {
	Sort *_struct.ListValue `protobuf:"bytes,4,opt,name=sort,proto3,oneof"`
}

type StatPage

type StatPage struct {

	// +optional
	Start uint32 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*StatPage) Descriptor deprecated

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

Deprecated: Use StatPage.ProtoReflect.Descriptor instead.

func (*StatPage) GetLimit

func (x *StatPage) GetLimit() uint32

func (*StatPage) GetStart

func (x *StatPage) GetStart() uint32

func (*StatPage) ProtoMessage

func (*StatPage) ProtoMessage()

func (*StatPage) ProtoReflect

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

func (*StatPage) Reset

func (x *StatPage) Reset()

func (*StatPage) String

func (x *StatPage) String() string

type UnimplementedHistoryServer

type UnimplementedHistoryServer struct {
}

UnimplementedHistoryServer must be embedded to have forward compatible implementations.

func (UnimplementedHistoryServer) Create

func (UnimplementedHistoryServer) List

func (UnimplementedHistoryServer) Stat

type UnimplementedResourceServer

type UnimplementedResourceServer struct {
}

UnimplementedResourceServer must be embedded to have forward compatible implementations.

func (UnimplementedResourceServer) Stat

type UnimplementedScheduleServer

type UnimplementedScheduleServer struct {
}

UnimplementedScheduleServer must be embedded to have forward compatible implementations.

func (UnimplementedScheduleServer) Add

func (UnimplementedScheduleServer) Delete

func (UnimplementedScheduleServer) Disable

func (UnimplementedScheduleServer) Enable

func (UnimplementedScheduleServer) Get

func (UnimplementedScheduleServer) List

func (UnimplementedScheduleServer) Stat

func (UnimplementedScheduleServer) Update

type UnsafeHistoryServer

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

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

type UnsafeResourceServer

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

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

type UnsafeScheduleServer

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

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

type UpdateScheduleRequest

type UpdateScheduleRequest struct {
	ScheduleId string `protobuf:"bytes,1,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_id,omitempty"`
	// +optional
	Schedule *Scheduled `protobuf:"bytes,2,opt,name=schedule,proto3" json:"schedule,omitempty"`
	// +optional
	Tags *_struct.Struct `protobuf:"bytes,3,opt,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateScheduleRequest) Descriptor deprecated

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

Deprecated: Use UpdateScheduleRequest.ProtoReflect.Descriptor instead.

func (*UpdateScheduleRequest) GetSchedule

func (x *UpdateScheduleRequest) GetSchedule() *Scheduled

func (*UpdateScheduleRequest) GetScheduleId

func (x *UpdateScheduleRequest) GetScheduleId() string

func (*UpdateScheduleRequest) GetTags

func (x *UpdateScheduleRequest) GetTags() *_struct.Struct

func (*UpdateScheduleRequest) ProtoMessage

func (*UpdateScheduleRequest) ProtoMessage()

func (*UpdateScheduleRequest) ProtoReflect

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

func (*UpdateScheduleRequest) Reset

func (x *UpdateScheduleRequest) Reset()

func (*UpdateScheduleRequest) String

func (x *UpdateScheduleRequest) String() string

Jump to

Keyboard shortcuts

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