pb

package
v2.24.2 Latest Latest
Warning

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

 Go to latest Published: Sep 12, 2024 License: Apache-2.0 Imports: 28 Imported by: 0

README

Protocol Documentation

Table of Contents

Top

snippet-service/pb/service.proto

AppliedConfiguration
Field Type Label Description
id string
device_id string @gotags: bson:"deviceId"
configuration_id AppliedConfiguration.LinkedTo @gotags: bson:"configurationId"
on_demand bool
condition_id AppliedConfiguration.LinkedTo @gotags: bson:"conditionId"
resources AppliedConfiguration.Resource repeated
owner string
timestamp int64 Unix timestamp in ns when the applied device configuration has been created/updated

AppliedConfiguration.LinkedTo
Field Type Label Description
id string
version uint64

AppliedConfiguration.Resource
Field Type Label Description
href string
correlation_id string Reused from invoke command or generated. Can be used to retrieve corresponding pending command.

@gotags: bson:"correlationId" | | status | AppliedConfiguration.Resource.Status | | | | resource_updated | resourceaggregate.pb.ResourceUpdated | | @gotags: bson:"resourceUpdated,omitempty" | | valid_until | int64 | | Unix nanoseconds timestamp for resource in PENDING status, until which the pending update is valid

@gotags: bson:"validUntil,omitempty" |

Condition

driven by resource change event

Field Type Label Description
id string Condition ID
version uint64 Condition version
name string User-friendly condition name
enabled bool Condition is enabled/disabled
configuration_id string ID of the configuration to be applied when the condition is satisfied
device_id_filter string repeated list of device IDs to which the condition applies
resource_type_filter string repeated
resource_href_filter string repeated list of resource hrefs to which the condition applies
jq_expression_filter string
api_access_token string Token used to update resources in the configuration
owner string Condition owner
timestamp int64 Unix timestamp in ns when the condition has been created/updated

Configuration
Field Type Label Description
id string Configuration ID
version uint64 Configuration version
name string User-friendly configuration name
resources Configuration.Resource repeated List of resource updates to be applied
owner string Configuration owner
timestamp int64 Unix timestamp in ns when the configuration has been created/updated

Configuration.Resource
Field Type Label Description
href string href of the resource
content resourceaggregate.pb.Content content update of the resource
time_to_live int64 optional update command time to live, 0 is infinite

DeleteAppliedConfigurationsRequest
Field Type Label Description
id_filter string repeated

DeleteAppliedConfigurationsResponse
Field Type Label Description
success bool

DeleteConditionsRequest
Field Type Label Description
id_filter IDFilter repeated
http_id_filter string repeated Deprecated. Format: {id}/{version}, e.g., "ae424c58-e517-4494-6de7-583536c48213/all" or "ae424c58-e517-4494-6de7-583536c48213/latest" or "ae424c58-e517-4494-6de7-583536c48213/1234"

DeleteConditionsResponse
Field Type Label Description
success bool

DeleteConfigurationsRequest
Field Type Label Description
id_filter IDFilter repeated
http_id_filter string repeated Deprecated. Format: {id}/{version}, e.g., "ae424c58-e517-4494-6de7-583536c48213/all" or "ae424c58-e517-4494-6de7-583536c48213/latest" or "ae424c58-e517-4494-6de7-583536c48213/1234"

DeleteConfigurationsResponse
Field Type Label Description
success bool

GetAppliedConfigurationsRequest
Field Type Label Description
id_filter string repeated
device_id_filter string repeated
configuration_id_filter IDFilter repeated
http_configuration_id_filter string repeated Deprecated. Format: {id}/{version}, e.g., "ae424c58-e517-4494-6de7-583536c48213/all" or "ae424c58-e517-4494-6de7-583536c48213/latest" or "ae424c58-e517-4494-6de7-583536c48213/1234"
condition_id_filter IDFilter repeated
http_condition_id_filter string repeated Deprecated. Format: {id}/{version}, e.g., "ae424c58-e517-4494-6de7-583536c48213/all" or "ae424c58-e517-4494-6de7-583536c48213/latest" or "ae424c58-e517-4494-6de7-583536c48213/1234"

GetConditionsRequest
Field Type Label Description
id_filter IDFilter repeated
configuration_id_filter string repeated returns latest conditions for given configurationId
http_id_filter string repeated Deprecated. Format: {id}/{version}, e.g., "ae424c58-e517-4494-6de7-583536c48213/all" or "ae424c58-e517-4494-6de7-583536c48213/latest" or "ae424c58-e517-4494-6de7-583536c48213/1234"

GetConfigurationsRequest
Field Type Label Description
id_filter IDFilter repeated
http_id_filter string repeated Deprecated. Format: {id}/{version}, e.g., "ae424c58-e517-4494-6de7-583536c48213/all" or "ae424c58-e517-4494-6de7-583536c48213/latest" or "ae424c58-e517-4494-6de7-583536c48213/1234"

IDFilter
Field Type Label Description
id string
value uint64
all bool
latest bool

InvokeConfigurationRequest
Field Type Label Description
configuration_id string applies latest configuration
device_id string
force bool force update even if the configuration has already been applied to device
correlation_id string propagated down to the resource update command

InvokeConfigurationResponse
Field Type Label Description
applied_configuration_id string

AppliedConfiguration.Resource.Status
Name Number Description
UNSPECIFIED 0
QUEUED 1
PENDING 2
DONE 3 If done look to resource_updated if update resource failed for resource aggregate.
TIMEOUT 4

SnippetService
Method Name Request Type Response Type Description
CreateCondition Condition Condition
GetConditions GetConditionsRequest Condition stream
DeleteConditions DeleteConditionsRequest DeleteConditionsResponse
UpdateCondition Condition Condition For update the condition whole condition is required and the version must be incremented.
CreateConfiguration Configuration Configuration
GetConfigurations GetConfigurationsRequest Configuration stream
DeleteConfigurations DeleteConfigurationsRequest DeleteConfigurationsResponse
UpdateConfiguration Configuration Configuration For update the configuration whole configuration is required and the version must be incremented.
InvokeConfiguration InvokeConfigurationRequest InvokeConfigurationResponse streaming process of update configuration to invoker
GetAppliedConfigurations GetAppliedConfigurationsRequest AppliedConfiguration stream
DeleteAppliedConfigurations DeleteAppliedConfigurationsRequest DeleteAppliedConfigurationsResponse

Scalar Value Types

.proto Type Notes C++ Java Python Go C# PHP Ruby
double double double float float64 double float Float
float float float float float32 float float Float
int32 Uses variable-length encoding. Inefficient for encoding negative numbers – if your field is likely to have negative values, use sint32 instead. int32 int int int32 int integer Bignum or Fixnum (as required)
int64 Uses variable-length encoding. Inefficient for encoding negative numbers – if your field is likely to have negative values, use sint64 instead. int64 long int/long int64 long integer/string Bignum
uint32 Uses variable-length encoding. uint32 int int/long uint32 uint integer Bignum or Fixnum (as required)
uint64 Uses variable-length encoding. uint64 long int/long uint64 ulong integer/string Bignum or Fixnum (as required)
sint32 Uses variable-length encoding. Signed int value. These more efficiently encode negative numbers than regular int32s. int32 int int int32 int integer Bignum or Fixnum (as required)
sint64 Uses variable-length encoding. Signed int value. These more efficiently encode negative numbers than regular int64s. int64 long int/long int64 long integer/string Bignum
fixed32 Always four bytes. More efficient than uint32 if values are often greater than 2^28. uint32 int int uint32 uint integer Bignum or Fixnum (as required)
fixed64 Always eight bytes. More efficient than uint64 if values are often greater than 2^56. uint64 long int/long uint64 ulong integer/string Bignum
sfixed32 Always four bytes. int32 int int int32 int integer Bignum or Fixnum (as required)
sfixed64 Always eight bytes. int64 long int/long int64 long integer/string Bignum
bool bool boolean boolean bool bool boolean TrueClass/FalseClass
string A string must always contain UTF-8 encoded or 7-bit ASCII text. string String str/unicode string string string String (UTF-8)
bytes May contain any arbitrary sequence of bytes. string ByteString str []byte ByteString string String (ASCII-8BIT)

Documentation

Overview

Package pb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	SnippetService_CreateCondition_FullMethodName             = "/snippetservice.pb.SnippetService/CreateCondition"
	SnippetService_GetConditions_FullMethodName               = "/snippetservice.pb.SnippetService/GetConditions"
	SnippetService_DeleteConditions_FullMethodName            = "/snippetservice.pb.SnippetService/DeleteConditions"
	SnippetService_UpdateCondition_FullMethodName             = "/snippetservice.pb.SnippetService/UpdateCondition"
	SnippetService_CreateConfiguration_FullMethodName         = "/snippetservice.pb.SnippetService/CreateConfiguration"
	SnippetService_GetConfigurations_FullMethodName           = "/snippetservice.pb.SnippetService/GetConfigurations"
	SnippetService_DeleteConfigurations_FullMethodName        = "/snippetservice.pb.SnippetService/DeleteConfigurations"
	SnippetService_UpdateConfiguration_FullMethodName         = "/snippetservice.pb.SnippetService/UpdateConfiguration"
	SnippetService_InvokeConfiguration_FullMethodName         = "/snippetservice.pb.SnippetService/InvokeConfiguration"
	SnippetService_GetAppliedConfigurations_FullMethodName    = "/snippetservice.pb.SnippetService/GetAppliedConfigurations"
	SnippetService_DeleteAppliedConfigurations_FullMethodName = "/snippetservice.pb.SnippetService/DeleteAppliedConfigurations"
)
View Source 
const (
	RecordIDKey        = "_id"
	IDKey              = "id"              // must match with Id field tag
	DeviceIDKey        = "deviceId"        // must match with DeviceId field tag
	OwnerKey           = "owner"           // must match with Owner field tag
	LatestKey          = "latest"          // must match with Latest field tag
	VersionKey         = "version"         // must match with Version field tag
	VersionsKey        = "versions"        // must match with Versions field tag
	ResourcesKey       = "resources"       // must match with Resources field tag
	ConfigurationIDKey = "configurationId" // must match with ConfigurationId field tag
	ConditionIDKey     = "conditionId"     // must match with ConditionId field tag
	EnabledKey         = "enabled"         // must match with Enabled field tag
	TimestampKey       = "timestamp"       // must match with Timestamp field tag
	StatusKey          = "status"          // must match with Status field tag
	HrefKey            = "href"            // must match with Href field tag
	ValidUntil         = "validUntil"      // must match with ValidUntil field tag

	DeviceIDFilterKey     = "deviceIdFilter"     // must match with Condition.DeviceIdFilter tag
	ResourceHrefFilterKey = "resourceHrefFilter" // must match with Condition.ResourceHrefFilter tag
	ResourceTypeFilterKey = "resourceTypeFilter" // must match with Condition.ResourceTypeFilter tag

	ConfigurationLinkIDKey      = ConfigurationIDKey + ".id"            // configurationId.id
	ConfigurationLinkVersionKey = ConfigurationIDKey + "." + VersionKey // configurationId.version
	ConditionLinkIDKey          = ConditionIDKey + ".id"                // conditionId.id
	ConditionLinkVersionKey     = ConditionIDKey + "." + VersionKey     // conditionId.version
)

Variables

View Source 
var (
	AppliedConfiguration_Resource_Status_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "QUEUED",
		2: "PENDING",
		3: "DONE",
		4: "TIMEOUT",
	}
	AppliedConfiguration_Resource_Status_value = map[string]int32{
		"UNSPECIFIED": 0,
		"QUEUED":      1,
		"PENDING":     2,
		"DONE":        3,
		"TIMEOUT":     4,
	}
)

Enum value maps for AppliedConfiguration_Resource_Status.

View Source 
var File_snippet_service_pb_service_proto protoreflect.FileDescriptor
View Source 
var SnippetService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "snippetservice.pb.SnippetService",
	HandlerType: (*SnippetServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateCondition",
			Handler:    _SnippetService_CreateCondition_Handler,
		},
		{
			MethodName: "DeleteConditions",
			Handler:    _SnippetService_DeleteConditions_Handler,
		},
		{
			MethodName: "UpdateCondition",
			Handler:    _SnippetService_UpdateCondition_Handler,
		},
		{
			MethodName: "CreateConfiguration",
			Handler:    _SnippetService_CreateConfiguration_Handler,
		},
		{
			MethodName: "DeleteConfigurations",
			Handler:    _SnippetService_DeleteConfigurations_Handler,
		},
		{
			MethodName: "UpdateConfiguration",
			Handler:    _SnippetService_UpdateConfiguration_Handler,
		},
		{
			MethodName: "InvokeConfiguration",
			Handler:    _SnippetService_InvokeConfiguration_Handler,
		},
		{
			MethodName: "DeleteAppliedConfigurations",
			Handler:    _SnippetService_DeleteAppliedConfigurations_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetConditions",
			Handler:       _SnippetService_GetConditions_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetConfigurations",
			Handler:       _SnippetService_GetConfigurations_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAppliedConfigurations",
			Handler:       _SnippetService_GetAppliedConfigurations_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "snippet-service/pb/service.proto",
}

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

Functions

func RegisterSnippetServiceHandler 

func RegisterSnippetServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterSnippetServiceHandler registers the http handlers for service SnippetService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterSnippetServiceHandlerClient 

func RegisterSnippetServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SnippetServiceClient) error

RegisterSnippetServiceHandlerClient registers the http handlers for service SnippetService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "SnippetServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "SnippetServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "SnippetServiceClient" to call the correct interceptors. This client ignores the HTTP middlewares.

func RegisterSnippetServiceHandlerFromEndpoint 

func RegisterSnippetServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterSnippetServiceHandlerFromEndpoint is same as RegisterSnippetServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterSnippetServiceHandlerServer 

func RegisterSnippetServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server SnippetServiceServer) error

RegisterSnippetServiceHandlerServer registers the http handlers for service SnippetService to "mux". UnaryRPC :call SnippetServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterSnippetServiceHandlerFromEndpoint instead. GRPC interceptors will not work for this type of registration. To use interceptors, you must use the "runtime.WithMiddlewares" option in the "runtime.NewServeMux" call.

func RegisterSnippetServiceServer 

func RegisterSnippetServiceServer(s grpc.ServiceRegistrar, srv SnippetServiceServer)

Types

type AppliedConfiguration 

type AppliedConfiguration struct {
	Id              string                         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	DeviceId        string                         `protobuf:"bytes,2,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty" bson:"deviceId"`
	ConfigurationId *AppliedConfiguration_LinkedTo `` /* 129-byte string literal not displayed */
	// Types that are assignable to ExecutedBy:
	//
	//	*AppliedConfiguration_OnDemand
	//	*AppliedConfiguration_ConditionId
	ExecutedBy isAppliedConfiguration_ExecutedBy `protobuf_oneof:"executed_by"`
	Resources  []*AppliedConfiguration_Resource  `protobuf:"bytes,6,rep,name=resources,proto3" json:"resources,omitempty"`
	Owner      string                            `protobuf:"bytes,7,opt,name=owner,proto3" json:"owner,omitempty"`
	// Unix timestamp in ns when the applied device configuration has been created/updated
	Timestamp int64 `protobuf:"varint,8,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*AppliedConfiguration) Clone 

func (c *AppliedConfiguration) Clone() *AppliedConfiguration

func (*AppliedConfiguration) CloneAppliedConfiguration_Resources 

func (c *AppliedConfiguration) CloneAppliedConfiguration_Resources() []*AppliedConfiguration_Resource

func (*AppliedConfiguration) CloneExecutedBy 

func (c *AppliedConfiguration) CloneExecutedBy() isAppliedConfiguration_ExecutedBy

func (*AppliedConfiguration) Descriptor deprecated 

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

Deprecated: Use AppliedConfiguration.ProtoReflect.Descriptor instead.

func (*AppliedConfiguration) GetConditionId 

func (x *AppliedConfiguration) GetConditionId() *AppliedConfiguration_LinkedTo

func (*AppliedConfiguration) GetConfigurationId 

func (x *AppliedConfiguration) GetConfigurationId() *AppliedConfiguration_LinkedTo

func (*AppliedConfiguration) GetDeviceId 

func (x *AppliedConfiguration) GetDeviceId() string

func (*AppliedConfiguration) GetExecutedBy 

func (m *AppliedConfiguration) GetExecutedBy() isAppliedConfiguration_ExecutedBy

func (*AppliedConfiguration) GetId 

func (x *AppliedConfiguration) GetId() string

func (*AppliedConfiguration) GetOnDemand 

func (x *AppliedConfiguration) GetOnDemand() bool

func (*AppliedConfiguration) GetOwner 

func (x *AppliedConfiguration) GetOwner() string

func (*AppliedConfiguration) GetResources 

func (x *AppliedConfiguration) GetResources() []*AppliedConfiguration_Resource

func (*AppliedConfiguration) GetTimestamp 

func (x *AppliedConfiguration) GetTimestamp() int64

func (*AppliedConfiguration) MarshalBSON 

func (c *AppliedConfiguration) MarshalBSON() ([]byte, error)

func (*AppliedConfiguration) ProtoMessage 

func (*AppliedConfiguration) ProtoMessage()

func (*AppliedConfiguration) ProtoReflect 

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

func (*AppliedConfiguration) Reset 

func (x *AppliedConfiguration) Reset()

func (*AppliedConfiguration) String 

func (x *AppliedConfiguration) String() string

func (*AppliedConfiguration) Validate 

func (c *AppliedConfiguration) Validate() error

type AppliedConfiguration_ConditionId 

type AppliedConfiguration_ConditionId struct {
	ConditionId *AppliedConfiguration_LinkedTo `protobuf:"bytes,5,opt,name=condition_id,json=conditionId,proto3,oneof" bson:"conditionId"`
}

func MakeExecutedByConditionId 

func MakeExecutedByConditionId(conditionID string, version uint64) *AppliedConfiguration_ConditionId

type AppliedConfiguration_LinkedTo 

type AppliedConfiguration_LinkedTo struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func MakeLinkedTo 

func MakeLinkedTo(id string, version uint64) *AppliedConfiguration_LinkedTo

func (*AppliedConfiguration_LinkedTo) Clone 

func (r *AppliedConfiguration_LinkedTo) Clone() *AppliedConfiguration_LinkedTo

func (*AppliedConfiguration_LinkedTo) Descriptor deprecated 

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

Deprecated: Use AppliedConfiguration_LinkedTo.ProtoReflect.Descriptor instead.

func (*AppliedConfiguration_LinkedTo) GetId 

func (x *AppliedConfiguration_LinkedTo) GetId() string

func (*AppliedConfiguration_LinkedTo) GetVersion 

func (x *AppliedConfiguration_LinkedTo) GetVersion() uint64

func (*AppliedConfiguration_LinkedTo) ProtoMessage 

func (*AppliedConfiguration_LinkedTo) ProtoMessage()

func (*AppliedConfiguration_LinkedTo) ProtoReflect 

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

func (*AppliedConfiguration_LinkedTo) Reset 

func (x *AppliedConfiguration_LinkedTo) Reset()

func (*AppliedConfiguration_LinkedTo) String 

func (x *AppliedConfiguration_LinkedTo) String() string

type AppliedConfiguration_OnDemand 

type AppliedConfiguration_OnDemand struct {
	OnDemand bool `protobuf:"varint,4,opt,name=on_demand,json=onDemand,proto3,oneof"`
}

func MakeExecutedByOnDemand 

func MakeExecutedByOnDemand() *AppliedConfiguration_OnDemand

type AppliedConfiguration_Resource 

type AppliedConfiguration_Resource struct {
	Href string `protobuf:"bytes,1,opt,name=href,proto3" json:"href,omitempty"`
	// Reused from invoke command or generated. Can be used to retrieve corresponding pending command.
	CorrelationId   string                               `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty" bson:"correlationId"`
	Status          AppliedConfiguration_Resource_Status `` /* 126-byte string literal not displayed */
	ResourceUpdated *events.ResourceUpdated              `` /* 139-byte string literal not displayed */
	// Unix nanoseconds timestamp for resource in PENDING status, until which the pending update is valid
	ValidUntil int64 `protobuf:"varint,5,opt,name=valid_until,json=validUntil,proto3" json:"valid_until,omitempty" bson:"validUntil,omitempty"`
	// contains filtered or unexported fields
}

func (*AppliedConfiguration_Resource) Clone 

func (r *AppliedConfiguration_Resource) Clone() *AppliedConfiguration_Resource

func (*AppliedConfiguration_Resource) Descriptor deprecated 

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

Deprecated: Use AppliedConfiguration_Resource.ProtoReflect.Descriptor instead.

func (*AppliedConfiguration_Resource) GetCorrelationId 

func (x *AppliedConfiguration_Resource) GetCorrelationId() string

func (*AppliedConfiguration_Resource) GetHref 

func (x *AppliedConfiguration_Resource) GetHref() string

func (*AppliedConfiguration_Resource) GetResourceUpdated 

func (x *AppliedConfiguration_Resource) GetResourceUpdated() *events.ResourceUpdated

func (*AppliedConfiguration_Resource) GetStatus 

func (x *AppliedConfiguration_Resource) GetStatus() AppliedConfiguration_Resource_Status

func (*AppliedConfiguration_Resource) GetValidUntil 

func (x *AppliedConfiguration_Resource) GetValidUntil() int64

func (*AppliedConfiguration_Resource) MarshalBSON 

func (r *AppliedConfiguration_Resource) MarshalBSON() ([]byte, error)

func (*AppliedConfiguration_Resource) ProtoMessage 

func (*AppliedConfiguration_Resource) ProtoMessage()

func (*AppliedConfiguration_Resource) ProtoReflect 

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

func (*AppliedConfiguration_Resource) Reset 

func (x *AppliedConfiguration_Resource) Reset()

func (*AppliedConfiguration_Resource) String 

func (x *AppliedConfiguration_Resource) String() string

func (*AppliedConfiguration_Resource) Validate 

func (r *AppliedConfiguration_Resource) Validate() error

type AppliedConfiguration_Resource_Status 

type AppliedConfiguration_Resource_Status int32
const (
	AppliedConfiguration_Resource_UNSPECIFIED AppliedConfiguration_Resource_Status = 0
	AppliedConfiguration_Resource_QUEUED      AppliedConfiguration_Resource_Status = 1
	AppliedConfiguration_Resource_PENDING     AppliedConfiguration_Resource_Status = 2
	AppliedConfiguration_Resource_DONE        AppliedConfiguration_Resource_Status = 3 // If done look to resource_updated if update resource failed for resource aggregate.
	AppliedConfiguration_Resource_TIMEOUT     AppliedConfiguration_Resource_Status = 4
)

func (AppliedConfiguration_Resource_Status) Descriptor 

func (AppliedConfiguration_Resource_Status) Descriptor() protoreflect.EnumDescriptor

func (AppliedConfiguration_Resource_Status) Enum 

func (x AppliedConfiguration_Resource_Status) Enum() *AppliedConfiguration_Resource_Status

func (AppliedConfiguration_Resource_Status) EnumDescriptor deprecated 

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

Deprecated: Use AppliedConfiguration_Resource_Status.Descriptor instead.

func (AppliedConfiguration_Resource_Status) Number 

func (x AppliedConfiguration_Resource_Status) Number() protoreflect.EnumNumber

func (AppliedConfiguration_Resource_Status) String 

func (x AppliedConfiguration_Resource_Status) String() string

func (AppliedConfiguration_Resource_Status) Type 

func (AppliedConfiguration_Resource_Status) Type() protoreflect.EnumType

type Condition 

type Condition struct {

	// Condition ID
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Condition version
	Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	// User-friendly condition name
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Condition is enabled/disabled
	Enabled bool `protobuf:"varint,4,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// ID of the configuration to be applied when the condition is satisfied
	ConfigurationId string `protobuf:"bytes,5,opt,name=configuration_id,json=configurationId,proto3" json:"configuration_id,omitempty"`
	// list of device IDs to which the condition applies
	DeviceIdFilter     []string `protobuf:"bytes,6,rep,name=device_id_filter,json=deviceIdFilter,proto3" json:"device_id_filter,omitempty"`
	ResourceTypeFilter []string `protobuf:"bytes,7,rep,name=resource_type_filter,json=resourceTypeFilter,proto3" json:"resource_type_filter,omitempty"`
	// list of resource hrefs to which the condition applies
	ResourceHrefFilter []string `protobuf:"bytes,8,rep,name=resource_href_filter,json=resourceHrefFilter,proto3" json:"resource_href_filter,omitempty"`
	JqExpressionFilter string   `protobuf:"bytes,9,opt,name=jq_expression_filter,json=jqExpressionFilter,proto3" json:"jq_expression_filter,omitempty"`
	// Token used to update resources in the configuration
	ApiAccessToken string `protobuf:"bytes,10,opt,name=api_access_token,json=apiAccessToken,proto3" json:"api_access_token,omitempty"`
	// Condition owner
	Owner string `protobuf:"bytes,11,opt,name=owner,proto3" json:"owner,omitempty"`
	// Unix timestamp in ns when the condition has been created/updated
	Timestamp int64 `protobuf:"varint,12,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*Condition) Clone 

func (c *Condition) Clone() *Condition

func (*Condition) Descriptor deprecated 

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

Deprecated: Use Condition.ProtoReflect.Descriptor instead.

func (*Condition) GetApiAccessToken 

func (x *Condition) GetApiAccessToken() string

func (*Condition) GetConfigurationId 

func (x *Condition) GetConfigurationId() string

func (*Condition) GetDeviceIdFilter 

func (x *Condition) GetDeviceIdFilter() []string

func (*Condition) GetEnabled 

func (x *Condition) GetEnabled() bool

func (*Condition) GetId 

func (x *Condition) GetId() string

func (*Condition) GetJqExpressionFilter 

func (x *Condition) GetJqExpressionFilter() string

func (*Condition) GetName 

func (x *Condition) GetName() string

func (*Condition) GetOwner 

func (x *Condition) GetOwner() string

func (*Condition) GetResourceHrefFilter 

func (x *Condition) GetResourceHrefFilter() []string

func (*Condition) GetResourceTypeFilter 

func (x *Condition) GetResourceTypeFilter() []string

func (*Condition) GetTimestamp 

func (x *Condition) GetTimestamp() int64

func (*Condition) GetVersion 

func (x *Condition) GetVersion() uint64

func (*Condition) Normalize 

func (c *Condition) Normalize()

func (*Condition) ProtoMessage 

func (*Condition) ProtoMessage()

func (*Condition) ProtoReflect 

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

func (*Condition) Reset 

func (x *Condition) Reset()

func (*Condition) String 

func (x *Condition) String() string

func (*Condition) Validate 

func (c *Condition) Validate(isUpdate bool) error

type Configuration 

type Configuration struct {

	// Configuration ID
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Configuration version
	Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	// User-friendly configuration name
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// List of resource updates to be applied
	Resources []*Configuration_Resource `protobuf:"bytes,4,rep,name=resources,proto3" json:"resources,omitempty"`
	// Configuration owner
	Owner string `protobuf:"bytes,5,opt,name=owner,proto3" json:"owner,omitempty"`
	// Unix timestamp in ns when the configuration has been created/updated
	Timestamp int64 `protobuf:"varint,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*Configuration) Clone 

func (c *Configuration) Clone() *Configuration

func (*Configuration) Descriptor deprecated 

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

Deprecated: Use Configuration.ProtoReflect.Descriptor instead.

func (*Configuration) GetId 

func (x *Configuration) GetId() string

func (*Configuration) GetName 

func (x *Configuration) GetName() string

func (*Configuration) GetOwner 

func (x *Configuration) GetOwner() string

func (*Configuration) GetResources 

func (x *Configuration) GetResources() []*Configuration_Resource

func (*Configuration) GetTimestamp 

func (x *Configuration) GetTimestamp() int64

func (*Configuration) GetVersion 

func (x *Configuration) GetVersion() uint64

func (*Configuration) Normalize 

func (c *Configuration) Normalize()

func (*Configuration) ProtoMessage 

func (*Configuration) ProtoMessage()

func (*Configuration) ProtoReflect 

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

func (*Configuration) Reset 

func (x *Configuration) Reset()

func (*Configuration) String 

func (x *Configuration) String() string

func (*Configuration) Validate 

func (c *Configuration) Validate(isUpdate bool) error

type Configuration_Resource 

type Configuration_Resource struct {

	// href of the resource
	Href string `protobuf:"bytes,1,opt,name=href,proto3" json:"href,omitempty"`
	// content update of the resource
	Content *commands.Content `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	// optional update command time to live, 0 is infinite
	TimeToLive int64 `protobuf:"varint,3,opt,name=time_to_live,json=timeToLive,proto3" json:"time_to_live,omitempty"`
	// contains filtered or unexported fields
}

func (*Configuration_Resource) Clone 

func (cr *Configuration_Resource) Clone() *Configuration_Resource

func (*Configuration_Resource) Descriptor deprecated 

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

Deprecated: Use Configuration_Resource.ProtoReflect.Descriptor instead.

func (*Configuration_Resource) GetContent 

func (x *Configuration_Resource) GetContent() *commands.Content

func (*Configuration_Resource) GetHref 

func (x *Configuration_Resource) GetHref() string

func (*Configuration_Resource) GetTimeToLive 

func (x *Configuration_Resource) GetTimeToLive() int64

func (*Configuration_Resource) ProtoMessage 

func (*Configuration_Resource) ProtoMessage()

func (*Configuration_Resource) ProtoReflect 

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

func (*Configuration_Resource) Reset 

func (x *Configuration_Resource) Reset()

func (*Configuration_Resource) String 

func (x *Configuration_Resource) String() string

type DeleteAppliedConfigurationsRequest 

type DeleteAppliedConfigurationsRequest struct {
	IdFilter []string `protobuf:"bytes,1,rep,name=id_filter,json=idFilter,proto3" json:"id_filter,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteAppliedConfigurationsRequest) Descriptor deprecated 

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

Deprecated: Use DeleteAppliedConfigurationsRequest.ProtoReflect.Descriptor instead.

func (*DeleteAppliedConfigurationsRequest) GetIdFilter 

func (x *DeleteAppliedConfigurationsRequest) GetIdFilter() []string

func (*DeleteAppliedConfigurationsRequest) ProtoMessage 

func (*DeleteAppliedConfigurationsRequest) ProtoMessage()

func (*DeleteAppliedConfigurationsRequest) ProtoReflect 

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

func (*DeleteAppliedConfigurationsRequest) Reset 

func (x *DeleteAppliedConfigurationsRequest) Reset()

func (*DeleteAppliedConfigurationsRequest) String 

func (x *DeleteAppliedConfigurationsRequest) String() string

type DeleteAppliedConfigurationsResponse 

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

func (*DeleteAppliedConfigurationsResponse) Descriptor deprecated 

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

Deprecated: Use DeleteAppliedConfigurationsResponse.ProtoReflect.Descriptor instead.

func (*DeleteAppliedConfigurationsResponse) GetSuccess 

func (x *DeleteAppliedConfigurationsResponse) GetSuccess() bool

func (*DeleteAppliedConfigurationsResponse) ProtoMessage 

func (*DeleteAppliedConfigurationsResponse) ProtoMessage()

func (*DeleteAppliedConfigurationsResponse) ProtoReflect 

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

func (*DeleteAppliedConfigurationsResponse) Reset 

func (x *DeleteAppliedConfigurationsResponse) Reset()

func (*DeleteAppliedConfigurationsResponse) String 

func (x *DeleteAppliedConfigurationsResponse) String() string

type DeleteConditionsRequest 

type DeleteConditionsRequest struct {
	IdFilter []*IDFilter `protobuf:"bytes,1,rep,name=id_filter,json=idFilter,proto3" json:"id_filter,omitempty"`
	// Format: {id}/{version}, e.g., "ae424c58-e517-4494-6de7-583536c48213/all" or "ae424c58-e517-4494-6de7-583536c48213/latest" or "ae424c58-e517-4494-6de7-583536c48213/1234"
	//
	// Deprecated: Marked as deprecated in snippet-service/pb/service.proto.
	HttpIdFilter []string `protobuf:"bytes,2,rep,name=http_id_filter,json=httpIdFilter,proto3" json:"http_id_filter,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteConditionsRequest) ConvertHTTPIDFilter 

func (r *DeleteConditionsRequest) ConvertHTTPIDFilter() []*IDFilter

func (*DeleteConditionsRequest) Descriptor deprecated 

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

Deprecated: Use DeleteConditionsRequest.ProtoReflect.Descriptor instead.

func (*DeleteConditionsRequest) GetHttpIdFilter deprecated 

func (x *DeleteConditionsRequest) GetHttpIdFilter() []string

Deprecated: Marked as deprecated in snippet-service/pb/service.proto.

func (*DeleteConditionsRequest) GetIdFilter 

func (x *DeleteConditionsRequest) GetIdFilter() []*IDFilter

func (*DeleteConditionsRequest) ProtoMessage 

func (*DeleteConditionsRequest) ProtoMessage()

func (*DeleteConditionsRequest) ProtoReflect 

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

func (*DeleteConditionsRequest) Reset 

func (x *DeleteConditionsRequest) Reset()

func (*DeleteConditionsRequest) String 

func (x *DeleteConditionsRequest) String() string

type DeleteConditionsResponse 

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

func (*DeleteConditionsResponse) Descriptor deprecated 

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

Deprecated: Use DeleteConditionsResponse.ProtoReflect.Descriptor instead.

func (*DeleteConditionsResponse) GetSuccess 

func (x *DeleteConditionsResponse) GetSuccess() bool

func (*DeleteConditionsResponse) ProtoMessage 

func (*DeleteConditionsResponse) ProtoMessage()

func (*DeleteConditionsResponse) ProtoReflect 

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

func (*DeleteConditionsResponse) Reset 

func (x *DeleteConditionsResponse) Reset()

func (*DeleteConditionsResponse) String 

func (x *DeleteConditionsResponse) String() string

type DeleteConfigurationsRequest 

type DeleteConfigurationsRequest struct {
	IdFilter []*IDFilter `protobuf:"bytes,1,rep,name=id_filter,json=idFilter,proto3" json:"id_filter,omitempty"`
	// Format: {id}/{version}, e.g., "ae424c58-e517-4494-6de7-583536c48213/all" or "ae424c58-e517-4494-6de7-583536c48213/latest" or "ae424c58-e517-4494-6de7-583536c48213/1234"
	//
	// Deprecated: Marked as deprecated in snippet-service/pb/service.proto.
	HttpIdFilter []string `protobuf:"bytes,2,rep,name=http_id_filter,json=httpIdFilter,proto3" json:"http_id_filter,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteConfigurationsRequest) ConvertHTTPIDFilter 

func (r *DeleteConfigurationsRequest) ConvertHTTPIDFilter() []*IDFilter

func (*DeleteConfigurationsRequest) Descriptor deprecated 

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

Deprecated: Use DeleteConfigurationsRequest.ProtoReflect.Descriptor instead.

func (*DeleteConfigurationsRequest) GetHttpIdFilter deprecated 

func (x *DeleteConfigurationsRequest) GetHttpIdFilter() []string

Deprecated: Marked as deprecated in snippet-service/pb/service.proto.

func (*DeleteConfigurationsRequest) GetIdFilter 

func (x *DeleteConfigurationsRequest) GetIdFilter() []*IDFilter

func (*DeleteConfigurationsRequest) ProtoMessage 

func (*DeleteConfigurationsRequest) ProtoMessage()

func (*DeleteConfigurationsRequest) ProtoReflect 

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

func (*DeleteConfigurationsRequest) Reset 

func (x *DeleteConfigurationsRequest) Reset()

func (*DeleteConfigurationsRequest) String 

func (x *DeleteConfigurationsRequest) String() string

type DeleteConfigurationsResponse 

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

func (*DeleteConfigurationsResponse) Descriptor deprecated 

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

Deprecated: Use DeleteConfigurationsResponse.ProtoReflect.Descriptor instead.

func (*DeleteConfigurationsResponse) GetSuccess 

func (x *DeleteConfigurationsResponse) GetSuccess() bool

func (*DeleteConfigurationsResponse) ProtoMessage 

func (*DeleteConfigurationsResponse) ProtoMessage()

func (*DeleteConfigurationsResponse) ProtoReflect 

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

func (*DeleteConfigurationsResponse) Reset 

func (x *DeleteConfigurationsResponse) Reset()

func (*DeleteConfigurationsResponse) String 

func (x *DeleteConfigurationsResponse) String() string

type GetAppliedConfigurationsRequest 

type GetAppliedConfigurationsRequest struct {
	IdFilter              []string    `protobuf:"bytes,1,rep,name=id_filter,json=idFilter,proto3" json:"id_filter,omitempty"`
	DeviceIdFilter        []string    `protobuf:"bytes,2,rep,name=device_id_filter,json=deviceIdFilter,proto3" json:"device_id_filter,omitempty"`
	ConfigurationIdFilter []*IDFilter `` /* 126-byte string literal not displayed */
	// Format: {id}/{version}, e.g., "ae424c58-e517-4494-6de7-583536c48213/all" or "ae424c58-e517-4494-6de7-583536c48213/latest" or "ae424c58-e517-4494-6de7-583536c48213/1234"
	//
	// Deprecated: Marked as deprecated in snippet-service/pb/service.proto.
	HttpConfigurationIdFilter []string    `` /* 140-byte string literal not displayed */
	ConditionIdFilter         []*IDFilter `protobuf:"bytes,5,rep,name=condition_id_filter,json=conditionIdFilter,proto3" json:"condition_id_filter,omitempty"`
	// Format: {id}/{version}, e.g., "ae424c58-e517-4494-6de7-583536c48213/all" or "ae424c58-e517-4494-6de7-583536c48213/latest" or "ae424c58-e517-4494-6de7-583536c48213/1234"
	//
	// Deprecated: Marked as deprecated in snippet-service/pb/service.proto.
	HttpConditionIdFilter []string `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetAppliedConfigurationsRequest) ConvertHTTPConditionIdFilter 

func (r *GetAppliedConfigurationsRequest) ConvertHTTPConditionIdFilter() []*IDFilter

func (*GetAppliedConfigurationsRequest) ConvertHTTPConfigurationIdFilter 

func (r *GetAppliedConfigurationsRequest) ConvertHTTPConfigurationIdFilter() []*IDFilter

func (*GetAppliedConfigurationsRequest) Descriptor deprecated 

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

Deprecated: Use GetAppliedConfigurationsRequest.ProtoReflect.Descriptor instead.

func (*GetAppliedConfigurationsRequest) GetConditionIdFilter 

func (x *GetAppliedConfigurationsRequest) GetConditionIdFilter() []*IDFilter

func (*GetAppliedConfigurationsRequest) GetConfigurationIdFilter 

func (x *GetAppliedConfigurationsRequest) GetConfigurationIdFilter() []*IDFilter

func (*GetAppliedConfigurationsRequest) GetDeviceIdFilter 

func (x *GetAppliedConfigurationsRequest) GetDeviceIdFilter() []string

func (*GetAppliedConfigurationsRequest) GetHttpConditionIdFilter deprecated 

func (x *GetAppliedConfigurationsRequest) GetHttpConditionIdFilter() []string

Deprecated: Marked as deprecated in snippet-service/pb/service.proto.

func (*GetAppliedConfigurationsRequest) GetHttpConfigurationIdFilter deprecated 

func (x *GetAppliedConfigurationsRequest) GetHttpConfigurationIdFilter() []string

Deprecated: Marked as deprecated in snippet-service/pb/service.proto.

func (*GetAppliedConfigurationsRequest) GetIdFilter 

func (x *GetAppliedConfigurationsRequest) GetIdFilter() []string

func (*GetAppliedConfigurationsRequest) ProtoMessage 

func (*GetAppliedConfigurationsRequest) ProtoMessage()

func (*GetAppliedConfigurationsRequest) ProtoReflect 

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

func (*GetAppliedConfigurationsRequest) Reset 

func (x *GetAppliedConfigurationsRequest) Reset()

func (*GetAppliedConfigurationsRequest) String 

func (x *GetAppliedConfigurationsRequest) String() string

type GetConditionsRequest 

type GetConditionsRequest struct {
	IdFilter []*IDFilter `protobuf:"bytes,1,rep,name=id_filter,json=idFilter,proto3" json:"id_filter,omitempty"`
	// returns latest conditions for given configurationId
	ConfigurationIdFilter []string `` /* 126-byte string literal not displayed */
	// Format: {id}/{version}, e.g., "ae424c58-e517-4494-6de7-583536c48213/all" or "ae424c58-e517-4494-6de7-583536c48213/latest" or "ae424c58-e517-4494-6de7-583536c48213/1234"
	//
	// Deprecated: Marked as deprecated in snippet-service/pb/service.proto.
	HttpIdFilter []string `protobuf:"bytes,3,rep,name=http_id_filter,json=httpIdFilter,proto3" json:"http_id_filter,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConditionsRequest) ConvertHTTPIDFilter 

func (r *GetConditionsRequest) ConvertHTTPIDFilter() []*IDFilter

func (*GetConditionsRequest) Descriptor deprecated 

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

Deprecated: Use GetConditionsRequest.ProtoReflect.Descriptor instead.

func (*GetConditionsRequest) GetConfigurationIdFilter 

func (x *GetConditionsRequest) GetConfigurationIdFilter() []string

func (*GetConditionsRequest) GetHttpIdFilter deprecated 

func (x *GetConditionsRequest) GetHttpIdFilter() []string

Deprecated: Marked as deprecated in snippet-service/pb/service.proto.

func (*GetConditionsRequest) GetIdFilter 

func (x *GetConditionsRequest) GetIdFilter() []*IDFilter

func (*GetConditionsRequest) ProtoMessage 

func (*GetConditionsRequest) ProtoMessage()

func (*GetConditionsRequest) ProtoReflect 

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

func (*GetConditionsRequest) Reset 

func (x *GetConditionsRequest) Reset()

func (*GetConditionsRequest) String 

func (x *GetConditionsRequest) String() string

type GetConfigurationsRequest 

type GetConfigurationsRequest struct {
	IdFilter []*IDFilter `protobuf:"bytes,1,rep,name=id_filter,json=idFilter,proto3" json:"id_filter,omitempty"`
	// Format: {id}/{version}, e.g., "ae424c58-e517-4494-6de7-583536c48213/all" or "ae424c58-e517-4494-6de7-583536c48213/latest" or "ae424c58-e517-4494-6de7-583536c48213/1234"
	//
	// Deprecated: Marked as deprecated in snippet-service/pb/service.proto.
	HttpIdFilter []string `protobuf:"bytes,2,rep,name=http_id_filter,json=httpIdFilter,proto3" json:"http_id_filter,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConfigurationsRequest) ConvertHTTPIDFilter 

func (r *GetConfigurationsRequest) ConvertHTTPIDFilter() []*IDFilter

func (*GetConfigurationsRequest) Descriptor deprecated 

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

Deprecated: Use GetConfigurationsRequest.ProtoReflect.Descriptor instead.

func (*GetConfigurationsRequest) GetHttpIdFilter deprecated 

func (x *GetConfigurationsRequest) GetHttpIdFilter() []string

Deprecated: Marked as deprecated in snippet-service/pb/service.proto.

func (*GetConfigurationsRequest) GetIdFilter 

func (x *GetConfigurationsRequest) GetIdFilter() []*IDFilter

func (*GetConfigurationsRequest) ProtoMessage 

func (*GetConfigurationsRequest) ProtoMessage()

func (*GetConfigurationsRequest) ProtoReflect 

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

func (*GetConfigurationsRequest) Reset 

func (x *GetConfigurationsRequest) Reset()

func (*GetConfigurationsRequest) String 

func (x *GetConfigurationsRequest) String() string

type IDFilter 

type IDFilter struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Version:
	//
	//	*IDFilter_Value
	//	*IDFilter_All
	//	*IDFilter_Latest
	Version isIDFilter_Version `protobuf_oneof:"version"`
	// contains filtered or unexported fields
}

func IDFilterFromString 

func IDFilterFromString(filter []string) []*IDFilter

func NormalizeIdFilter 

func NormalizeIdFilter(idfilter []*IDFilter) []*IDFilter

Normalizing the IDFilter entails: - ordering the filters:

  • primarily by ID
  • secondarily by type (All, Latest, Value)
  • tertiary for Value type by value

- removing duplicates - removing filters that are redundant due to other filters (eg if All is specified, no other filters are needed)

func (*IDFilter) Descriptor deprecated 

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

Deprecated: Use IDFilter.ProtoReflect.Descriptor instead.

func (*IDFilter) GetAll 

func (x *IDFilter) GetAll() bool

func (*IDFilter) GetId 

func (x *IDFilter) GetId() string

func (*IDFilter) GetLatest 

func (x *IDFilter) GetLatest() bool

func (*IDFilter) GetValue 

func (x *IDFilter) GetValue() uint64

func (*IDFilter) GetVersion 

func (m *IDFilter) GetVersion() isIDFilter_Version

func (*IDFilter) ProtoMessage 

func (*IDFilter) ProtoMessage()

func (*IDFilter) ProtoReflect 

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

func (*IDFilter) Reset 

func (x *IDFilter) Reset()

func (*IDFilter) String 

func (x *IDFilter) String() string

type IDFilter_All 

type IDFilter_All struct {
	All bool `protobuf:"varint,3,opt,name=all,proto3,oneof"`
}

type IDFilter_Latest 

type IDFilter_Latest struct {
	Latest bool `protobuf:"varint,4,opt,name=latest,proto3,oneof"`
}

type IDFilter_Value 

type IDFilter_Value struct {
	Value uint64 `protobuf:"varint,2,opt,name=value,proto3,oneof"`
}

type InvokeConfigurationRequest 

type InvokeConfigurationRequest struct {
	ConfigurationId string `protobuf:"bytes,1,opt,name=configuration_id,json=configurationId,proto3" json:"configuration_id,omitempty"` // applies latest configuration
	DeviceId        string `protobuf:"bytes,2,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	Force           bool   `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"`                                     // force update even if the configuration has already been applied to device
	CorrelationId   string `protobuf:"bytes,4,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"` // propagated down to the resource update command
	// contains filtered or unexported fields
}

func (*InvokeConfigurationRequest) Descriptor deprecated 

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

Deprecated: Use InvokeConfigurationRequest.ProtoReflect.Descriptor instead.

func (*InvokeConfigurationRequest) GetConfigurationId 

func (x *InvokeConfigurationRequest) GetConfigurationId() string

func (*InvokeConfigurationRequest) GetCorrelationId 

func (x *InvokeConfigurationRequest) GetCorrelationId() string

func (*InvokeConfigurationRequest) GetDeviceId 

func (x *InvokeConfigurationRequest) GetDeviceId() string

func (*InvokeConfigurationRequest) GetForce 

func (x *InvokeConfigurationRequest) GetForce() bool

func (*InvokeConfigurationRequest) ProtoMessage 

func (*InvokeConfigurationRequest) ProtoMessage()

func (*InvokeConfigurationRequest) ProtoReflect 

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

func (*InvokeConfigurationRequest) Reset 

func (x *InvokeConfigurationRequest) Reset()

func (*InvokeConfigurationRequest) String 

func (x *InvokeConfigurationRequest) String() string

func (*InvokeConfigurationRequest) Validate 

func (r *InvokeConfigurationRequest) Validate() error

type InvokeConfigurationResponse 

type InvokeConfigurationResponse struct {
	AppliedConfigurationId string `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*InvokeConfigurationResponse) Descriptor deprecated 

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

Deprecated: Use InvokeConfigurationResponse.ProtoReflect.Descriptor instead.

func (*InvokeConfigurationResponse) GetAppliedConfigurationId 

func (x *InvokeConfigurationResponse) GetAppliedConfigurationId() string

func (*InvokeConfigurationResponse) ProtoMessage 

func (*InvokeConfigurationResponse) ProtoMessage()

func (*InvokeConfigurationResponse) ProtoReflect 

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

func (*InvokeConfigurationResponse) Reset 

func (x *InvokeConfigurationResponse) Reset()

func (*InvokeConfigurationResponse) String 

func (x *InvokeConfigurationResponse) String() string

type SnippetServiceClient 

type SnippetServiceClient interface {
	CreateCondition(ctx context.Context, in *Condition, opts ...grpc.CallOption) (*Condition, error)
	GetConditions(ctx context.Context, in *GetConditionsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Condition], error)
	DeleteConditions(ctx context.Context, in *DeleteConditionsRequest, opts ...grpc.CallOption) (*DeleteConditionsResponse, error)
	// For update the condition whole condition is required and the version must be incremented.
	UpdateCondition(ctx context.Context, in *Condition, opts ...grpc.CallOption) (*Condition, error)
	CreateConfiguration(ctx context.Context, in *Configuration, opts ...grpc.CallOption) (*Configuration, error)
	GetConfigurations(ctx context.Context, in *GetConfigurationsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Configuration], error)
	DeleteConfigurations(ctx context.Context, in *DeleteConfigurationsRequest, opts ...grpc.CallOption) (*DeleteConfigurationsResponse, error)
	// For update the configuration whole configuration is required and the version must be incremented.
	UpdateConfiguration(ctx context.Context, in *Configuration, opts ...grpc.CallOption) (*Configuration, error)
	// streaming process of update configuration to invoker
	InvokeConfiguration(ctx context.Context, in *InvokeConfigurationRequest, opts ...grpc.CallOption) (*InvokeConfigurationResponse, error)
	GetAppliedConfigurations(ctx context.Context, in *GetAppliedConfigurationsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[AppliedConfiguration], error)
	DeleteAppliedConfigurations(ctx context.Context, in *DeleteAppliedConfigurationsRequest, opts ...grpc.CallOption) (*DeleteAppliedConfigurationsResponse, error)
}

SnippetServiceClient is the client API for SnippetService 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 NewSnippetServiceClient 

func NewSnippetServiceClient(cc grpc.ClientConnInterface) SnippetServiceClient

type SnippetServiceServer 

type SnippetServiceServer interface {
	CreateCondition(context.Context, *Condition) (*Condition, error)
	GetConditions(*GetConditionsRequest, grpc.ServerStreamingServer[Condition]) error
	DeleteConditions(context.Context, *DeleteConditionsRequest) (*DeleteConditionsResponse, error)
	// For update the condition whole condition is required and the version must be incremented.
	UpdateCondition(context.Context, *Condition) (*Condition, error)
	CreateConfiguration(context.Context, *Configuration) (*Configuration, error)
	GetConfigurations(*GetConfigurationsRequest, grpc.ServerStreamingServer[Configuration]) error
	DeleteConfigurations(context.Context, *DeleteConfigurationsRequest) (*DeleteConfigurationsResponse, error)
	// For update the configuration whole configuration is required and the version must be incremented.
	UpdateConfiguration(context.Context, *Configuration) (*Configuration, error)
	// streaming process of update configuration to invoker
	InvokeConfiguration(context.Context, *InvokeConfigurationRequest) (*InvokeConfigurationResponse, error)
	GetAppliedConfigurations(*GetAppliedConfigurationsRequest, grpc.ServerStreamingServer[AppliedConfiguration]) error
	DeleteAppliedConfigurations(context.Context, *DeleteAppliedConfigurationsRequest) (*DeleteAppliedConfigurationsResponse, error)
	// contains filtered or unexported methods
}

SnippetServiceServer is the server API for SnippetService service. All implementations must embed UnimplementedSnippetServiceServer for forward compatibility.

type SnippetService_GetAppliedConfigurationsClient 

type SnippetService_GetAppliedConfigurationsClient = grpc.ServerStreamingClient[AppliedConfiguration]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type SnippetService_GetAppliedConfigurationsServer 

type SnippetService_GetAppliedConfigurationsServer = grpc.ServerStreamingServer[AppliedConfiguration]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type SnippetService_GetConditionsClient 

type SnippetService_GetConditionsClient = grpc.ServerStreamingClient[Condition]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type SnippetService_GetConditionsServer 

type SnippetService_GetConditionsServer = grpc.ServerStreamingServer[Condition]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type SnippetService_GetConfigurationsClient 

type SnippetService_GetConfigurationsClient = grpc.ServerStreamingClient[Configuration]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type SnippetService_GetConfigurationsServer 

type SnippetService_GetConfigurationsServer = grpc.ServerStreamingServer[Configuration]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type UnimplementedSnippetServiceServer 

type UnimplementedSnippetServiceServer struct{}

UnimplementedSnippetServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedSnippetServiceServer) CreateCondition 

func (UnimplementedSnippetServiceServer) CreateCondition(context.Context, *Condition) (*Condition, error)

func (UnimplementedSnippetServiceServer) CreateConfiguration 

func (UnimplementedSnippetServiceServer) CreateConfiguration(context.Context, *Configuration) (*Configuration, error)

func (UnimplementedSnippetServiceServer) DeleteAppliedConfigurations 

func (UnimplementedSnippetServiceServer) DeleteAppliedConfigurations(context.Context, *DeleteAppliedConfigurationsRequest) (*DeleteAppliedConfigurationsResponse, error)

func (UnimplementedSnippetServiceServer) DeleteConditions 

func (UnimplementedSnippetServiceServer) DeleteConditions(context.Context, *DeleteConditionsRequest) (*DeleteConditionsResponse, error)

func (UnimplementedSnippetServiceServer) DeleteConfigurations 

func (UnimplementedSnippetServiceServer) DeleteConfigurations(context.Context, *DeleteConfigurationsRequest) (*DeleteConfigurationsResponse, error)

func (UnimplementedSnippetServiceServer) GetAppliedConfigurations 

func (UnimplementedSnippetServiceServer) GetAppliedConfigurations(*GetAppliedConfigurationsRequest, grpc.ServerStreamingServer[AppliedConfiguration]) error

func (UnimplementedSnippetServiceServer) GetConditions 

func (UnimplementedSnippetServiceServer) GetConditions(*GetConditionsRequest, grpc.ServerStreamingServer[Condition]) error

func (UnimplementedSnippetServiceServer) GetConfigurations 

func (UnimplementedSnippetServiceServer) GetConfigurations(*GetConfigurationsRequest, grpc.ServerStreamingServer[Configuration]) error

func (UnimplementedSnippetServiceServer) InvokeConfiguration 

func (UnimplementedSnippetServiceServer) InvokeConfiguration(context.Context, *InvokeConfigurationRequest) (*InvokeConfigurationResponse, error)

func (UnimplementedSnippetServiceServer) UpdateCondition 

func (UnimplementedSnippetServiceServer) UpdateCondition(context.Context, *Condition) (*Condition, error)

func (UnimplementedSnippetServiceServer) UpdateConfiguration 

func (UnimplementedSnippetServiceServer) UpdateConfiguration(context.Context, *Configuration) (*Configuration, error)

type UnsafeSnippetServiceServer 

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

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

type VersionFilter 

type VersionFilter struct {
	// document IDs for which we want full documents
	All []string
	// document IDs for which we want the latest version
	Latest []string
	// map of document IDs and specific versions we want
	Versions map[string][]uint64
}

func PartitionIDFilter 

func PartitionIDFilter(idfilter []*IDFilter) VersionFilter

func (*VersionFilter) IsEmpty 

func (vf *VersionFilter) IsEmpty() bool

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.