server

package
v1.0.2 Latest Latest
Warning

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

 Go to latest Published: Dec 23, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ProvisioningStatusRequest_ProvisioningStatus_Model_name = map[int32]string{
		0: "DOMAIN",
		1: "POOL",
		2: "MEMBER",
		3: "MONITOR",
		4: "DATACENTER",
		5: "GEOGRAPHIC_MAP",
	}
	ProvisioningStatusRequest_ProvisioningStatus_Model_value = map[string]int32{
		"DOMAIN":         0,
		"POOL":           1,
		"MEMBER":         2,
		"MONITOR":        3,
		"DATACENTER":     4,
		"GEOGRAPHIC_MAP": 5,
	}
)

Enum value maps for ProvisioningStatusRequest_ProvisioningStatus_Model.

View Source 
var (
	ProvisioningStatusRequest_ProvisioningStatus_StatusType_name = map[int32]string{
		0: "ACTIVE",
		1: "PENDING_CREATE",
		2: "PENDING_UPDATE",
		3: "PENDING_DELETE",
		4: "DELETED",
		5: "ERROR",
	}
	ProvisioningStatusRequest_ProvisioningStatus_StatusType_value = map[string]int32{
		"ACTIVE":         0,
		"PENDING_CREATE": 1,
		"PENDING_UPDATE": 2,
		"PENDING_DELETE": 3,
		"DELETED":        4,
		"ERROR":          5,
	}
)

Enum value maps for ProvisioningStatusRequest_ProvisioningStatus_StatusType.

View Source 
var (
	MemberStatusRequest_MemberStatus_StatusType_name = map[int32]string{
		0: "ONLINE",
		1: "OFFLINE",
		2: "NO_MONITOR",
		3: "UNKNOWN",
	}
	MemberStatusRequest_MemberStatus_StatusType_value = map[string]int32{
		"ONLINE":     0,
		"OFFLINE":    1,
		"NO_MONITOR": 2,
		"UNKNOWN":    3,
	}
)

Enum value maps for MemberStatusRequest_MemberStatus_StatusType.

View Source 
var File_internal_rpc_server_rpc_server_proto protoreflect.FileDescriptor

Functions

func RegisterRPCServerServer added in v1.0.0 

func RegisterRPCServerServer(s *stormrpc.Server, srv RPCServerServer)

Types

type DatacenterMetaRequest 

type DatacenterMetaRequest struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Meta int32  `protobuf:"varint,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*DatacenterMetaRequest) Descriptor deprecated 

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

Deprecated: Use DatacenterMetaRequest.ProtoReflect.Descriptor instead.

func (*DatacenterMetaRequest) GetId 

func (x *DatacenterMetaRequest) GetId() string

func (*DatacenterMetaRequest) GetMeta 

func (x *DatacenterMetaRequest) GetMeta() int32

func (*DatacenterMetaRequest) ProtoMessage 

func (*DatacenterMetaRequest) ProtoMessage()

func (*DatacenterMetaRequest) ProtoReflect 

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

func (*DatacenterMetaRequest) Reset 

func (x *DatacenterMetaRequest) Reset()

func (*DatacenterMetaRequest) String 

func (x *DatacenterMetaRequest) String() string

type DatacentersResponse 

type DatacentersResponse struct {
	Response []*rpcmodels.Datacenter `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*DatacentersResponse) Descriptor deprecated 

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

Deprecated: Use DatacentersResponse.ProtoReflect.Descriptor instead.

func (*DatacentersResponse) GetResponse 

func (x *DatacentersResponse) GetResponse() []*rpcmodels.Datacenter

func (*DatacentersResponse) ProtoMessage 

func (*DatacentersResponse) ProtoMessage()

func (*DatacentersResponse) ProtoReflect 

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

func (*DatacentersResponse) Reset 

func (x *DatacentersResponse) Reset()

func (*DatacentersResponse) String 

func (x *DatacentersResponse) String() string

type DomainsResponse 

type DomainsResponse struct {
	Response []*rpcmodels.Domain `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*DomainsResponse) Descriptor deprecated 

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

Deprecated: Use DomainsResponse.ProtoReflect.Descriptor instead.

func (*DomainsResponse) GetResponse 

func (x *DomainsResponse) GetResponse() []*rpcmodels.Domain

func (*DomainsResponse) ProtoMessage 

func (*DomainsResponse) ProtoMessage()

func (*DomainsResponse) ProtoReflect 

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

func (*DomainsResponse) Reset 

func (x *DomainsResponse) Reset()

func (*DomainsResponse) String 

func (x *DomainsResponse) String() string

type GeomapsResponse 

type GeomapsResponse struct {
	Response []*rpcmodels.Geomap `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*GeomapsResponse) Descriptor deprecated 

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

Deprecated: Use GeomapsResponse.ProtoReflect.Descriptor instead.

func (*GeomapsResponse) GetResponse 

func (x *GeomapsResponse) GetResponse() []*rpcmodels.Geomap

func (*GeomapsResponse) ProtoMessage 

func (*GeomapsResponse) ProtoMessage()

func (*GeomapsResponse) ProtoReflect 

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

func (*GeomapsResponse) Reset 

func (x *GeomapsResponse) Reset()

func (*GeomapsResponse) String 

func (x *GeomapsResponse) String() string

type MemberStatusRequest 

type MemberStatusRequest struct {
	MemberStatus []*MemberStatusRequest_MemberStatus `protobuf:"bytes,1,rep,name=member_status,json=memberStatus,proto3" json:"member_status,omitempty"`
	// contains filtered or unexported fields
}

func (*MemberStatusRequest) Descriptor deprecated 

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

Deprecated: Use MemberStatusRequest.ProtoReflect.Descriptor instead.

func (*MemberStatusRequest) GetMemberStatus 

func (x *MemberStatusRequest) GetMemberStatus() []*MemberStatusRequest_MemberStatus

func (*MemberStatusRequest) ProtoMessage 

func (*MemberStatusRequest) ProtoMessage()

func (*MemberStatusRequest) ProtoReflect 

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

func (*MemberStatusRequest) Reset 

func (x *MemberStatusRequest) Reset()

func (*MemberStatusRequest) String 

func (x *MemberStatusRequest) String() string

type MemberStatusRequest_MemberStatus 

type MemberStatusRequest_MemberStatus struct {
	Id     string                                      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Status MemberStatusRequest_MemberStatus_StatusType `protobuf:"varint,2,opt,name=status,proto3,enum=MemberStatusRequest_MemberStatus_StatusType" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*MemberStatusRequest_MemberStatus) Descriptor deprecated 

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

Deprecated: Use MemberStatusRequest_MemberStatus.ProtoReflect.Descriptor instead.

func (*MemberStatusRequest_MemberStatus) GetId 

func (x *MemberStatusRequest_MemberStatus) GetId() string

func (*MemberStatusRequest_MemberStatus) GetStatus 

func (x *MemberStatusRequest_MemberStatus) GetStatus() MemberStatusRequest_MemberStatus_StatusType

func (*MemberStatusRequest_MemberStatus) ProtoMessage 

func (*MemberStatusRequest_MemberStatus) ProtoMessage()

func (*MemberStatusRequest_MemberStatus) ProtoReflect 

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

func (*MemberStatusRequest_MemberStatus) Reset 

func (x *MemberStatusRequest_MemberStatus) Reset()

func (*MemberStatusRequest_MemberStatus) String 

func (x *MemberStatusRequest_MemberStatus) String() string

type MemberStatusRequest_MemberStatus_StatusType 

type MemberStatusRequest_MemberStatus_StatusType int32
const (
	MemberStatusRequest_MemberStatus_ONLINE     MemberStatusRequest_MemberStatus_StatusType = 0
	MemberStatusRequest_MemberStatus_OFFLINE    MemberStatusRequest_MemberStatus_StatusType = 1
	MemberStatusRequest_MemberStatus_NO_MONITOR MemberStatusRequest_MemberStatus_StatusType = 2
	MemberStatusRequest_MemberStatus_UNKNOWN    MemberStatusRequest_MemberStatus_StatusType = 3
)

func (MemberStatusRequest_MemberStatus_StatusType) Descriptor 

func (MemberStatusRequest_MemberStatus_StatusType) Descriptor() protoreflect.EnumDescriptor

func (MemberStatusRequest_MemberStatus_StatusType) Enum 

func (x MemberStatusRequest_MemberStatus_StatusType) Enum() *MemberStatusRequest_MemberStatus_StatusType

func (MemberStatusRequest_MemberStatus_StatusType) EnumDescriptor deprecated 

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

Deprecated: Use MemberStatusRequest_MemberStatus_StatusType.Descriptor instead.

func (MemberStatusRequest_MemberStatus_StatusType) Number 

func (x MemberStatusRequest_MemberStatus_StatusType) Number() protoreflect.EnumNumber

func (MemberStatusRequest_MemberStatus_StatusType) String 

func (x MemberStatusRequest_MemberStatus_StatusType) String() string

func (MemberStatusRequest_MemberStatus_StatusType) Type 

func (MemberStatusRequest_MemberStatus_StatusType) Type() protoreflect.EnumType

type MemberStatusResponse 

type MemberStatusResponse struct {
	MemberStatusResult []*StatusResult `protobuf:"bytes,1,rep,name=member_status_result,json=memberStatusResult,proto3" json:"member_status_result,omitempty"`
	// contains filtered or unexported fields
}

func (*MemberStatusResponse) Descriptor deprecated 

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

Deprecated: Use MemberStatusResponse.ProtoReflect.Descriptor instead.

func (*MemberStatusResponse) GetMemberStatusResult 

func (x *MemberStatusResponse) GetMemberStatusResult() []*StatusResult

func (*MemberStatusResponse) ProtoMessage 

func (*MemberStatusResponse) ProtoMessage()

func (*MemberStatusResponse) ProtoReflect 

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

func (*MemberStatusResponse) Reset 

func (x *MemberStatusResponse) Reset()

func (*MemberStatusResponse) String 

func (x *MemberStatusResponse) String() string

type MembersResponse 

type MembersResponse struct {
	Response []*rpcmodels.Member `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*MembersResponse) Descriptor deprecated 

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

Deprecated: Use MembersResponse.ProtoReflect.Descriptor instead.

func (*MembersResponse) GetResponse 

func (x *MembersResponse) GetResponse() []*rpcmodels.Member

func (*MembersResponse) ProtoMessage 

func (*MembersResponse) ProtoMessage()

func (*MembersResponse) ProtoReflect 

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

func (*MembersResponse) Reset 

func (x *MembersResponse) Reset()

func (*MembersResponse) String 

func (x *MembersResponse) String() string

type MonitorsResponse 

type MonitorsResponse struct {
	Response []*rpcmodels.Monitor `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*MonitorsResponse) Descriptor deprecated 

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

Deprecated: Use MonitorsResponse.ProtoReflect.Descriptor instead.

func (*MonitorsResponse) GetResponse 

func (x *MonitorsResponse) GetResponse() []*rpcmodels.Monitor

func (*MonitorsResponse) ProtoMessage 

func (*MonitorsResponse) ProtoMessage()

func (*MonitorsResponse) ProtoReflect 

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

func (*MonitorsResponse) Reset 

func (x *MonitorsResponse) Reset()

func (*MonitorsResponse) String 

func (x *MonitorsResponse) String() string

type PoolsResponse 

type PoolsResponse struct {
	Response []*rpcmodels.Pool `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*PoolsResponse) Descriptor deprecated 

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

Deprecated: Use PoolsResponse.ProtoReflect.Descriptor instead.

func (*PoolsResponse) GetResponse 

func (x *PoolsResponse) GetResponse() []*rpcmodels.Pool

func (*PoolsResponse) ProtoMessage 

func (*PoolsResponse) ProtoMessage()

func (*PoolsResponse) ProtoReflect 

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

func (*PoolsResponse) Reset 

func (x *PoolsResponse) Reset()

func (*PoolsResponse) String 

func (x *PoolsResponse) String() string

type ProvisioningStatusRequest 

type ProvisioningStatusRequest struct {
	ProvisioningStatus []*ProvisioningStatusRequest_ProvisioningStatus `protobuf:"bytes,1,rep,name=provisioning_status,json=provisioningStatus,proto3" json:"provisioning_status,omitempty"`
	// contains filtered or unexported fields
}

func (*ProvisioningStatusRequest) Descriptor deprecated 

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

Deprecated: Use ProvisioningStatusRequest.ProtoReflect.Descriptor instead.

func (*ProvisioningStatusRequest) GetProvisioningStatus 

func (x *ProvisioningStatusRequest) GetProvisioningStatus() []*ProvisioningStatusRequest_ProvisioningStatus

func (*ProvisioningStatusRequest) ProtoMessage 

func (*ProvisioningStatusRequest) ProtoMessage()

func (*ProvisioningStatusRequest) ProtoReflect 

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

func (*ProvisioningStatusRequest) Reset 

func (x *ProvisioningStatusRequest) Reset()

func (*ProvisioningStatusRequest) String 

func (x *ProvisioningStatusRequest) String() string

type ProvisioningStatusRequest_ProvisioningStatus 

type ProvisioningStatusRequest_ProvisioningStatus struct {
	Id     string                                                  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Model  ProvisioningStatusRequest_ProvisioningStatus_Model      `protobuf:"varint,2,opt,name=model,proto3,enum=ProvisioningStatusRequest_ProvisioningStatus_Model" json:"model,omitempty"`
	Status ProvisioningStatusRequest_ProvisioningStatus_StatusType `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ProvisioningStatusRequest_ProvisioningStatus) Descriptor deprecated 

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

Deprecated: Use ProvisioningStatusRequest_ProvisioningStatus.ProtoReflect.Descriptor instead.

func (*ProvisioningStatusRequest_ProvisioningStatus) GetId 

func (x *ProvisioningStatusRequest_ProvisioningStatus) GetId() string

func (*ProvisioningStatusRequest_ProvisioningStatus) GetModel 

func (x *ProvisioningStatusRequest_ProvisioningStatus) GetModel() ProvisioningStatusRequest_ProvisioningStatus_Model

func (*ProvisioningStatusRequest_ProvisioningStatus) GetStatus 

func (x *ProvisioningStatusRequest_ProvisioningStatus) GetStatus() ProvisioningStatusRequest_ProvisioningStatus_StatusType

func (*ProvisioningStatusRequest_ProvisioningStatus) ProtoMessage 

func (*ProvisioningStatusRequest_ProvisioningStatus) ProtoMessage()

func (*ProvisioningStatusRequest_ProvisioningStatus) ProtoReflect 

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

func (*ProvisioningStatusRequest_ProvisioningStatus) Reset 

func (x *ProvisioningStatusRequest_ProvisioningStatus) Reset()

func (*ProvisioningStatusRequest_ProvisioningStatus) String 

func (x *ProvisioningStatusRequest_ProvisioningStatus) String() string

type ProvisioningStatusRequest_ProvisioningStatus_Model 

type ProvisioningStatusRequest_ProvisioningStatus_Model int32
const (
	ProvisioningStatusRequest_ProvisioningStatus_DOMAIN         ProvisioningStatusRequest_ProvisioningStatus_Model = 0
	ProvisioningStatusRequest_ProvisioningStatus_POOL           ProvisioningStatusRequest_ProvisioningStatus_Model = 1
	ProvisioningStatusRequest_ProvisioningStatus_MEMBER         ProvisioningStatusRequest_ProvisioningStatus_Model = 2
	ProvisioningStatusRequest_ProvisioningStatus_MONITOR        ProvisioningStatusRequest_ProvisioningStatus_Model = 3
	ProvisioningStatusRequest_ProvisioningStatus_DATACENTER     ProvisioningStatusRequest_ProvisioningStatus_Model = 4
	ProvisioningStatusRequest_ProvisioningStatus_GEOGRAPHIC_MAP ProvisioningStatusRequest_ProvisioningStatus_Model = 5
)

func (ProvisioningStatusRequest_ProvisioningStatus_Model) Descriptor 

func (ProvisioningStatusRequest_ProvisioningStatus_Model) Descriptor() protoreflect.EnumDescriptor

func (ProvisioningStatusRequest_ProvisioningStatus_Model) Enum 

func (x ProvisioningStatusRequest_ProvisioningStatus_Model) Enum() *ProvisioningStatusRequest_ProvisioningStatus_Model

func (ProvisioningStatusRequest_ProvisioningStatus_Model) EnumDescriptor deprecated 

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

Deprecated: Use ProvisioningStatusRequest_ProvisioningStatus_Model.Descriptor instead.

func (ProvisioningStatusRequest_ProvisioningStatus_Model) Number 

func (x ProvisioningStatusRequest_ProvisioningStatus_Model) Number() protoreflect.EnumNumber

func (ProvisioningStatusRequest_ProvisioningStatus_Model) String 

func (x ProvisioningStatusRequest_ProvisioningStatus_Model) String() string

func (ProvisioningStatusRequest_ProvisioningStatus_Model) Type 

func (ProvisioningStatusRequest_ProvisioningStatus_Model) Type() protoreflect.EnumType

type ProvisioningStatusRequest_ProvisioningStatus_StatusType 

type ProvisioningStatusRequest_ProvisioningStatus_StatusType int32
const (
	ProvisioningStatusRequest_ProvisioningStatus_ACTIVE         ProvisioningStatusRequest_ProvisioningStatus_StatusType = 0
	ProvisioningStatusRequest_ProvisioningStatus_PENDING_CREATE ProvisioningStatusRequest_ProvisioningStatus_StatusType = 1
	ProvisioningStatusRequest_ProvisioningStatus_PENDING_UPDATE ProvisioningStatusRequest_ProvisioningStatus_StatusType = 2
	ProvisioningStatusRequest_ProvisioningStatus_PENDING_DELETE ProvisioningStatusRequest_ProvisioningStatus_StatusType = 3
	ProvisioningStatusRequest_ProvisioningStatus_DELETED        ProvisioningStatusRequest_ProvisioningStatus_StatusType = 4
	ProvisioningStatusRequest_ProvisioningStatus_ERROR          ProvisioningStatusRequest_ProvisioningStatus_StatusType = 5
)

func (ProvisioningStatusRequest_ProvisioningStatus_StatusType) Descriptor 

func (ProvisioningStatusRequest_ProvisioningStatus_StatusType) Descriptor() protoreflect.EnumDescriptor

func (ProvisioningStatusRequest_ProvisioningStatus_StatusType) Enum 

func (x ProvisioningStatusRequest_ProvisioningStatus_StatusType) Enum() *ProvisioningStatusRequest_ProvisioningStatus_StatusType

func (ProvisioningStatusRequest_ProvisioningStatus_StatusType) EnumDescriptor deprecated 

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

Deprecated: Use ProvisioningStatusRequest_ProvisioningStatus_StatusType.Descriptor instead.

func (ProvisioningStatusRequest_ProvisioningStatus_StatusType) Number 

func (x ProvisioningStatusRequest_ProvisioningStatus_StatusType) Number() protoreflect.EnumNumber

func (ProvisioningStatusRequest_ProvisioningStatus_StatusType) String 

func (x ProvisioningStatusRequest_ProvisioningStatus_StatusType) String() string

func (ProvisioningStatusRequest_ProvisioningStatus_StatusType) Type 

func (ProvisioningStatusRequest_ProvisioningStatus_StatusType) Type() protoreflect.EnumType

type ProvisioningStatusResponse 

type ProvisioningStatusResponse struct {
	ProvisioningStatusResult []*StatusResult `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ProvisioningStatusResponse) Descriptor deprecated 

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

Deprecated: Use ProvisioningStatusResponse.ProtoReflect.Descriptor instead.

func (*ProvisioningStatusResponse) GetProvisioningStatusResult 

func (x *ProvisioningStatusResponse) GetProvisioningStatusResult() []*StatusResult

func (*ProvisioningStatusResponse) ProtoMessage 

func (*ProvisioningStatusResponse) ProtoMessage()

func (*ProvisioningStatusResponse) ProtoReflect 

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

func (*ProvisioningStatusResponse) Reset 

func (x *ProvisioningStatusResponse) Reset()

func (*ProvisioningStatusResponse) String 

func (x *ProvisioningStatusResponse) String() string

type RPCHandler 

type RPCHandler struct {
	DB *sqlx.DB
}

func (*RPCHandler) GetDatacenters 

func (u *RPCHandler) GetDatacenters(ctx context.Context, request *SearchRequest) (*DatacentersResponse, error)

func (*RPCHandler) GetDomains 

func (u *RPCHandler) GetDomains(ctx context.Context, request *SearchRequest) (*DomainsResponse, error)

func (*RPCHandler) GetGeomaps 

func (u *RPCHandler) GetGeomaps(ctx context.Context, request *SearchRequest) (*GeomapsResponse, error)

func (*RPCHandler) GetMembers 

func (u *RPCHandler) GetMembers(ctx context.Context, request *SearchRequest) (*MembersResponse, error)

func (*RPCHandler) GetMonitors 

func (u *RPCHandler) GetMonitors(ctx context.Context, request *SearchRequest) (*MonitorsResponse, error)

func (*RPCHandler) GetPools 

func (u *RPCHandler) GetPools(ctx context.Context, request *SearchRequest) (*PoolsResponse, error)

func (*RPCHandler) QueryxWithIds 

func (u *RPCHandler) QueryxWithIds(sql string, request *SearchRequest) (*sqlx.Rows, error)

QueryxWithIds run sql query if optional WHERE condition based on IDs

func (*RPCHandler) UpdateDatacenterMeta 

func (u *RPCHandler) UpdateDatacenterMeta(ctx context.Context, req *DatacenterMetaRequest) (*rpcmodels.Datacenter, error)

func (*RPCHandler) UpdateMemberStatus 

func (u *RPCHandler) UpdateMemberStatus(ctx context.Context, req *MemberStatusRequest) (*MemberStatusResponse, error)

UpdateMemberStatus Updates member status according to the requests, also updates dependend pool and domain status.

func (*RPCHandler) UpdateProvisioningStatus 

func (u *RPCHandler) UpdateProvisioningStatus(ctx context.Context, req *ProvisioningStatusRequest) (*ProvisioningStatusResponse, error)

type RPCServerClient added in v1.0.0 

type RPCServerClient interface {
	UpdateProvisioningStatus(ctx context.Context, in *ProvisioningStatusRequest, opts ...stormrpc.CallOption) (*ProvisioningStatusResponse, error)
	UpdateMemberStatus(ctx context.Context, in *MemberStatusRequest, opts ...stormrpc.CallOption) (*MemberStatusResponse, error)
	GetDomains(ctx context.Context, in *SearchRequest, opts ...stormrpc.CallOption) (*DomainsResponse, error)
	GetPools(ctx context.Context, in *SearchRequest, opts ...stormrpc.CallOption) (*PoolsResponse, error)
	GetMonitors(ctx context.Context, in *SearchRequest, opts ...stormrpc.CallOption) (*MonitorsResponse, error)
	GetDatacenters(ctx context.Context, in *SearchRequest, opts ...stormrpc.CallOption) (*DatacentersResponse, error)
	GetMembers(ctx context.Context, in *SearchRequest, opts ...stormrpc.CallOption) (*MembersResponse, error)
	GetGeomaps(ctx context.Context, in *SearchRequest, opts ...stormrpc.CallOption) (*GeomapsResponse, error)
	UpdateDatacenterMeta(ctx context.Context, in *DatacenterMetaRequest, opts ...stormrpc.CallOption) (*rpcmodels.Datacenter, error)
}

RPCServerClient is the client API for RPCServer service.

func NewRPCServerClient added in v1.0.0 

func NewRPCServerClient(c *stormrpc.Client) RPCServerClient

type RPCServerServer added in v1.0.0 

type RPCServerServer interface {
	UpdateProvisioningStatus(context.Context, *ProvisioningStatusRequest) (*ProvisioningStatusResponse, error)
	UpdateMemberStatus(context.Context, *MemberStatusRequest) (*MemberStatusResponse, error)
	GetDomains(context.Context, *SearchRequest) (*DomainsResponse, error)
	GetPools(context.Context, *SearchRequest) (*PoolsResponse, error)
	GetMonitors(context.Context, *SearchRequest) (*MonitorsResponse, error)
	GetDatacenters(context.Context, *SearchRequest) (*DatacentersResponse, error)
	GetMembers(context.Context, *SearchRequest) (*MembersResponse, error)
	GetGeomaps(context.Context, *SearchRequest) (*GeomapsResponse, error)
	UpdateDatacenterMeta(context.Context, *DatacenterMetaRequest) (*rpcmodels.Datacenter, error)
}

RPCServerServer is the server API for RPCServer service.

type SearchRequest 

type SearchRequest struct {
	Provider       string   `protobuf:"bytes,1,opt,name=provider,proto3" json:"provider,omitempty"`
	FullyPopulated bool     `protobuf:"varint,2,opt,name=fully_populated,json=fullyPopulated,proto3" json:"fully_populated,omitempty"`
	PageNumber     int32    `protobuf:"varint,3,opt,name=page_number,json=pageNumber,proto3" json:"page_number,omitempty"`
	ResultPerPage  int32    `protobuf:"varint,4,opt,name=result_per_page,json=resultPerPage,proto3" json:"result_per_page,omitempty"`
	Pending        bool     `protobuf:"varint,5,opt,name=pending,proto3" json:"pending,omitempty"`
	Ids            []string `protobuf:"bytes,6,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchRequest) Descriptor deprecated 

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

Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.

func (*SearchRequest) GetFullyPopulated 

func (x *SearchRequest) GetFullyPopulated() bool

func (*SearchRequest) GetIds 

func (x *SearchRequest) GetIds() []string

func (*SearchRequest) GetPageNumber 

func (x *SearchRequest) GetPageNumber() int32

func (*SearchRequest) GetPending 

func (x *SearchRequest) GetPending() bool

func (*SearchRequest) GetProvider 

func (x *SearchRequest) GetProvider() string

func (*SearchRequest) GetResultPerPage 

func (x *SearchRequest) GetResultPerPage() int32

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) ProtoReflect 

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

func (*SearchRequest) Reset 

func (x *SearchRequest) Reset()

func (*SearchRequest) String 

func (x *SearchRequest) String() string

type StatusResult 

type StatusResult struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Success bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResult) Descriptor deprecated 

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

Deprecated: Use StatusResult.ProtoReflect.Descriptor instead.

func (*StatusResult) GetId 

func (x *StatusResult) GetId() string

func (*StatusResult) GetSuccess 

func (x *StatusResult) GetSuccess() bool

func (*StatusResult) ProtoMessage 

func (*StatusResult) ProtoMessage()

func (*StatusResult) ProtoReflect 

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

func (*StatusResult) Reset 

func (x *StatusResult) Reset()

func (*StatusResult) String 

func (x *StatusResult) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.