schema_server

package
v0.0.36 Latest Latest
Warning

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

 Go to latest Published: Nov 28, 2024 License: Apache-2.0 Imports: 11 Imported by: 50

Documentation

Index

Constants

View Source 
const (
	DataServer_ListDataStore_FullMethodName   = "/data.DataServer/ListDataStore"
	DataServer_GetDataStore_FullMethodName    = "/data.DataServer/GetDataStore"
	DataServer_CreateDataStore_FullMethodName = "/data.DataServer/CreateDataStore"
	DataServer_DeleteDataStore_FullMethodName = "/data.DataServer/DeleteDataStore"
	DataServer_Commit_FullMethodName          = "/data.DataServer/Commit"
	DataServer_Rebase_FullMethodName          = "/data.DataServer/Rebase"
	DataServer_Discard_FullMethodName         = "/data.DataServer/Discard"
	DataServer_GetData_FullMethodName         = "/data.DataServer/GetData"
	DataServer_SetData_FullMethodName         = "/data.DataServer/SetData"
	DataServer_Diff_FullMethodName            = "/data.DataServer/Diff"
	DataServer_Subscribe_FullMethodName       = "/data.DataServer/Subscribe"
	DataServer_Watch_FullMethodName           = "/data.DataServer/Watch"
	DataServer_GetIntent_FullMethodName       = "/data.DataServer/GetIntent"
	DataServer_SetIntent_FullMethodName       = "/data.DataServer/SetIntent"
	DataServer_ListIntent_FullMethodName      = "/data.DataServer/ListIntent"
	DataServer_WatchDeviations_FullMethodName = "/data.DataServer/WatchDeviations"
)
View Source 
const (
	SchemaServer_GetSchemaDetails_FullMethodName  = "/schema.SchemaServer/GetSchemaDetails"
	SchemaServer_ListSchema_FullMethodName        = "/schema.SchemaServer/ListSchema"
	SchemaServer_GetSchema_FullMethodName         = "/schema.SchemaServer/GetSchema"
	SchemaServer_CreateSchema_FullMethodName      = "/schema.SchemaServer/CreateSchema"
	SchemaServer_ReloadSchema_FullMethodName      = "/schema.SchemaServer/ReloadSchema"
	SchemaServer_DeleteSchema_FullMethodName      = "/schema.SchemaServer/DeleteSchema"
	SchemaServer_UploadSchema_FullMethodName      = "/schema.SchemaServer/UploadSchema"
	SchemaServer_ToPath_FullMethodName            = "/schema.SchemaServer/ToPath"
	SchemaServer_ExpandPath_FullMethodName        = "/schema.SchemaServer/ExpandPath"
	SchemaServer_GetSchemaElements_FullMethodName = "/schema.SchemaServer/GetSchemaElements"
)

Variables

View Source 
var (
	DeviationEvent_name = map[int32]string{
		0: "DE_UNKNOWN",
		1: "START",
		2: "END",
		3: "UPDATE",
		4: "CLEAR",
	}
	DeviationEvent_value = map[string]int32{
		"DE_UNKNOWN": 0,
		"START":      1,
		"END":        2,
		"UPDATE":     3,
		"CLEAR":      4,
	}
)

Enum value maps for DeviationEvent.

View Source 
var (
	DeviationReason_name = map[int32]string{
		0: "DR_UNKNOWN",
		1: "UNHANDLED",
		2: "NOT_APPLIED",
		3: "OVERRULED",
	}
	DeviationReason_value = map[string]int32{
		"DR_UNKNOWN":  0,
		"UNHANDLED":   1,
		"NOT_APPLIED": 2,
		"OVERRULED":   3,
	}
)

Enum value maps for DeviationReason.

View Source 
var (
	Type_name = map[int32]string{
		0: "MAIN",
		1: "CANDIDATE",
		2: "INTENDED",
	}
	Type_value = map[string]int32{
		"MAIN":      0,
		"CANDIDATE": 1,
		"INTENDED":  2,
	}
)

Enum value maps for Type.

View Source 
var (
	Encoding_name = map[int32]string{
		0: "STRING",
		1: "JSON",
		2: "JSON_IETF",
		3: "PROTO",
	}
	Encoding_value = map[string]int32{
		"STRING":    0,
		"JSON":      1,
		"JSON_IETF": 2,
		"PROTO":     3,
	}
)

Enum value maps for Encoding.

View Source 
var (
	TargetStatus_name = map[int32]string{
		0: "UNKNOWN",
		1: "CONNECTED",
		2: "NOT_CONNECTED",
	}
	TargetStatus_value = map[string]int32{
		"UNKNOWN":       0,
		"CONNECTED":     1,
		"NOT_CONNECTED": 2,
	}
)

Enum value maps for TargetStatus.

View Source 
var (
	CommitCandidate_name = map[int32]string{
		0: "COMMIT_CANDIDATE",
		1: "COMMIT_RUNNING",
	}
	CommitCandidate_value = map[string]int32{
		"COMMIT_CANDIDATE": 0,
		"COMMIT_RUNNING":   1,
	}
)

Enum value maps for CommitCandidate.

View Source 
var (
	SyncMode_name = map[int32]string{
		0: "SM_ON_CHANGE",
		1: "SM_SAMPLE",
		2: "SM_ONCE",
		3: "SM_GET",
	}
	SyncMode_value = map[string]int32{
		"SM_ON_CHANGE": 0,
		"SM_SAMPLE":    1,
		"SM_ONCE":      2,
		"SM_GET":       3,
	}
)

Enum value maps for SyncMode.

View Source 
var (
	UpdateResult_Operation_name = map[int32]string{
		0: "INVALID",
		1: "DELETE",
		2: "REPLACE",
		3: "UPDATE",
	}
	UpdateResult_Operation_value = map[string]int32{
		"INVALID": 0,
		"DELETE":  1,
		"REPLACE": 2,
		"UPDATE":  3,
	}
)

Enum value maps for UpdateResult_Operation.

View Source 
var (
	SchemaStatus_name = map[int32]string{
		0: "OK",
		1: "RELOADING",
		2: "INITIALIZING",
		3: "FAILED",
	}
	SchemaStatus_value = map[string]int32{
		"OK":           0,
		"RELOADING":    1,
		"INITIALIZING": 2,
		"FAILED":       3,
	}
)

Enum value maps for SchemaStatus.

View Source 
var (
	DataType_name = map[int32]string{
		0: "ALL",
		1: "CONFIG",
		2: "STATE",
	}
	DataType_value = map[string]int32{
		"ALL":    0,
		"CONFIG": 1,
		"STATE":  2,
	}
)

Enum value maps for DataType.

View Source 
var (
	UploadSchemaFile_FileType_name = map[int32]string{
		0: "MODULE",
		1: "DEPENDENCY",
	}
	UploadSchemaFile_FileType_value = map[string]int32{
		"MODULE":     0,
		"DEPENDENCY": 1,
	}
)

Enum value maps for UploadSchemaFile_FileType.

View Source 
var (
	Hash_HashMethod_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "MD5",
		2: "SHA256",
		3: "SHA512",
	}
	Hash_HashMethod_value = map[string]int32{
		"UNSPECIFIED": 0,
		"MD5":         1,
		"SHA256":      2,
		"SHA512":      3,
	}
)

Enum value maps for Hash_HashMethod.

View Source 
var DataServer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "data.DataServer",
	HandlerType: (*DataServerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListDataStore",
			Handler:    _DataServer_ListDataStore_Handler,
		},
		{
			MethodName: "GetDataStore",
			Handler:    _DataServer_GetDataStore_Handler,
		},
		{
			MethodName: "CreateDataStore",
			Handler:    _DataServer_CreateDataStore_Handler,
		},
		{
			MethodName: "DeleteDataStore",
			Handler:    _DataServer_DeleteDataStore_Handler,
		},
		{
			MethodName: "Commit",
			Handler:    _DataServer_Commit_Handler,
		},
		{
			MethodName: "Rebase",
			Handler:    _DataServer_Rebase_Handler,
		},
		{
			MethodName: "Discard",
			Handler:    _DataServer_Discard_Handler,
		},
		{
			MethodName: "SetData",
			Handler:    _DataServer_SetData_Handler,
		},
		{
			MethodName: "Diff",
			Handler:    _DataServer_Diff_Handler,
		},
		{
			MethodName: "GetIntent",
			Handler:    _DataServer_GetIntent_Handler,
		},
		{
			MethodName: "SetIntent",
			Handler:    _DataServer_SetIntent_Handler,
		},
		{
			MethodName: "ListIntent",
			Handler:    _DataServer_ListIntent_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetData",
			Handler:       _DataServer_GetData_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _DataServer_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Watch",
			Handler:       _DataServer_Watch_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchDeviations",
			Handler:       _DataServer_WatchDeviations_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "data.proto",
}

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

View Source 
var File_data_proto protoreflect.FileDescriptor
View Source 
var File_schema_proto protoreflect.FileDescriptor
View Source 
var SchemaServer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "schema.SchemaServer",
	HandlerType: (*SchemaServerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetSchemaDetails",
			Handler:    _SchemaServer_GetSchemaDetails_Handler,
		},
		{
			MethodName: "ListSchema",
			Handler:    _SchemaServer_ListSchema_Handler,
		},
		{
			MethodName: "GetSchema",
			Handler:    _SchemaServer_GetSchema_Handler,
		},
		{
			MethodName: "CreateSchema",
			Handler:    _SchemaServer_CreateSchema_Handler,
		},
		{
			MethodName: "ReloadSchema",
			Handler:    _SchemaServer_ReloadSchema_Handler,
		},
		{
			MethodName: "DeleteSchema",
			Handler:    _SchemaServer_DeleteSchema_Handler,
		},
		{
			MethodName: "ToPath",
			Handler:    _SchemaServer_ToPath_Handler,
		},
		{
			MethodName: "ExpandPath",
			Handler:    _SchemaServer_ExpandPath_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "UploadSchema",
			Handler:       _SchemaServer_UploadSchema_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "GetSchemaElements",
			Handler:       _SchemaServer_GetSchemaElements_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "schema.proto",
}

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

Functions

func RegisterDataServerServer 

func RegisterDataServerServer(s grpc.ServiceRegistrar, srv DataServerServer)

func RegisterSchemaServerServer 

func RegisterSchemaServerServer(s grpc.ServiceRegistrar, srv SchemaServerServer)

Types

type ChoiceCase 

type ChoiceCase struct {
	Elements []string `protobuf:"bytes,1,rep,name=elements,proto3" json:"elements,omitempty"`
	// contains filtered or unexported fields
}

func (*ChoiceCase) Descriptor deprecated 

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

Deprecated: Use ChoiceCase.ProtoReflect.Descriptor instead.

func (*ChoiceCase) GetElements 

func (x *ChoiceCase) GetElements() []string

func (*ChoiceCase) ProtoMessage 

func (*ChoiceCase) ProtoMessage()

func (*ChoiceCase) ProtoReflect 

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

func (*ChoiceCase) Reset 

func (x *ChoiceCase) Reset()

func (*ChoiceCase) String 

func (x *ChoiceCase) String() string

type ChoiceInfo 

type ChoiceInfo struct {

	// If the schema object (container, field, leaf-list)
	// is a case substatement
	// this attribute will hold
	// the choice statement name
	Choice map[string]*ChoiceInfoChoice `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ChoiceInfo) Descriptor deprecated 

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

Deprecated: Use ChoiceInfo.ProtoReflect.Descriptor instead.

func (*ChoiceInfo) GetChoice 

func (x *ChoiceInfo) GetChoice() map[string]*ChoiceInfoChoice

func (*ChoiceInfo) ProtoMessage 

func (*ChoiceInfo) ProtoMessage()

func (*ChoiceInfo) ProtoReflect 

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

func (*ChoiceInfo) Reset 

func (x *ChoiceInfo) Reset()

func (*ChoiceInfo) String 

func (x *ChoiceInfo) String() string

type ChoiceInfoChoice 

type ChoiceInfoChoice struct {
	Case map[string]*ChoiceCase `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ChoiceInfoChoice) Descriptor deprecated 

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

Deprecated: Use ChoiceInfoChoice.ProtoReflect.Descriptor instead.

func (*ChoiceInfoChoice) GetCase 

func (x *ChoiceInfoChoice) GetCase() map[string]*ChoiceCase

func (*ChoiceInfoChoice) ProtoMessage 

func (*ChoiceInfoChoice) ProtoMessage()

func (*ChoiceInfoChoice) ProtoReflect 

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

func (*ChoiceInfoChoice) Reset 

func (x *ChoiceInfoChoice) Reset()

func (*ChoiceInfoChoice) String 

func (x *ChoiceInfoChoice) String() string

type CommitCandidate 

type CommitCandidate int32
const (
	CommitCandidate_COMMIT_CANDIDATE CommitCandidate = 0
	CommitCandidate_COMMIT_RUNNING   CommitCandidate = 1
)

func (CommitCandidate) Descriptor 

func (CommitCandidate) Descriptor() protoreflect.EnumDescriptor

func (CommitCandidate) Enum 

func (x CommitCandidate) Enum() *CommitCandidate

func (CommitCandidate) EnumDescriptor deprecated 

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

Deprecated: Use CommitCandidate.Descriptor instead.

func (CommitCandidate) Number 

func (x CommitCandidate) Number() protoreflect.EnumNumber

func (CommitCandidate) String 

func (x CommitCandidate) String() string

func (CommitCandidate) Type 

func (CommitCandidate) Type() protoreflect.EnumType

type CommitRequest 

type CommitRequest struct {

	// datastore name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// candidate name
	Datastore *DataStore `protobuf:"bytes,2,opt,name=datastore,proto3" json:"datastore,omitempty"`
	// rebase before commiting
	Rebase bool `protobuf:"varint,3,opt,name=rebase,proto3" json:"rebase,omitempty"`
	// do not delete the candidate after commiting
	// reset changes and rebase after commiting
	Stay bool `protobuf:"varint,4,opt,name=stay,proto3" json:"stay,omitempty"`
	// contains filtered or unexported fields
}

func (*CommitRequest) Descriptor deprecated 

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

Deprecated: Use CommitRequest.ProtoReflect.Descriptor instead.

func (*CommitRequest) GetDatastore 

func (x *CommitRequest) GetDatastore() *DataStore

func (*CommitRequest) GetName 

func (x *CommitRequest) GetName() string

func (*CommitRequest) GetRebase 

func (x *CommitRequest) GetRebase() bool

func (*CommitRequest) GetStay 

func (x *CommitRequest) GetStay() bool

func (*CommitRequest) ProtoMessage 

func (*CommitRequest) ProtoMessage()

func (*CommitRequest) ProtoReflect 

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

func (*CommitRequest) Reset 

func (x *CommitRequest) Reset()

func (*CommitRequest) String 

func (x *CommitRequest) String() string

type CommitResponse 

type CommitResponse struct {
	// contains filtered or unexported fields
}

func (*CommitResponse) Descriptor deprecated 

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

Deprecated: Use CommitResponse.ProtoReflect.Descriptor instead.

func (*CommitResponse) ProtoMessage 

func (*CommitResponse) ProtoMessage()

func (*CommitResponse) ProtoReflect 

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

func (*CommitResponse) Reset 

func (x *CommitResponse) Reset()

func (*CommitResponse) String 

func (x *CommitResponse) String() string

type ContainerSchema 

type ContainerSchema struct {
	Name              string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description       string            `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Owner             string            `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
	Namespace         string            `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Prefix            string            `protobuf:"bytes,5,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Keys              []*LeafSchema     `protobuf:"bytes,6,rep,name=keys,proto3" json:"keys,omitempty"`
	Fields            []*LeafSchema     `protobuf:"bytes,7,rep,name=fields,proto3" json:"fields,omitempty"`
	Leaflists         []*LeafListSchema `protobuf:"bytes,8,rep,name=leaflists,proto3" json:"leaflists,omitempty"`
	Children          []string          `protobuf:"bytes,9,rep,name=children,proto3" json:"children,omitempty"`
	MandatoryChildren []*MandatoryChild `protobuf:"bytes,10,rep,name=mandatory_children,json=mandatoryChildren,proto3" json:"mandatory_children,omitempty"`
	MustStatements    []*MustStatement  `protobuf:"bytes,11,rep,name=must_statements,json=mustStatements,proto3" json:"must_statements,omitempty"`
	ModuleName        string            `protobuf:"bytes,12,opt,name=module_name,json=moduleName,proto3" json:"module_name,omitempty"`
	MaxElements       uint64            `protobuf:"varint,13,opt,name=max_elements,json=maxElements,proto3" json:"max_elements,omitempty"`
	MinElements       uint64            `protobuf:"varint,14,opt,name=min_elements,json=minElements,proto3" json:"min_elements,omitempty"`
	IsPresence        bool              `protobuf:"varint,20,opt,name=is_presence,json=isPresence,proto3" json:"is_presence,omitempty"`
	IsState           bool              `protobuf:"varint,21,opt,name=is_state,json=isState,proto3" json:"is_state,omitempty"`
	IsUserOrdered     bool              `protobuf:"varint,22,opt,name=is_user_ordered,json=isUserOrdered,proto3" json:"is_user_ordered,omitempty"`
	IfFeature         []string          `protobuf:"bytes,23,rep,name=if_feature,json=ifFeature,proto3" json:"if_feature,omitempty"`
	ChoiceInfo        *ChoiceInfo       `protobuf:"bytes,30,opt,name=choice_info,json=choiceInfo,proto3" json:"choice_info,omitempty"`
	// contains filtered or unexported fields
}

sub messages

func (*ContainerSchema) Descriptor deprecated 

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

Deprecated: Use ContainerSchema.ProtoReflect.Descriptor instead.

func (*ContainerSchema) GetChildren 

func (x *ContainerSchema) GetChildren() []string

func (*ContainerSchema) GetChoiceInfo 

func (x *ContainerSchema) GetChoiceInfo() *ChoiceInfo

func (*ContainerSchema) GetDescription 

func (x *ContainerSchema) GetDescription() string

func (*ContainerSchema) GetFields 

func (x *ContainerSchema) GetFields() []*LeafSchema

func (*ContainerSchema) GetIfFeature 

func (x *ContainerSchema) GetIfFeature() []string

func (*ContainerSchema) GetIsPresence 

func (x *ContainerSchema) GetIsPresence() bool

func (*ContainerSchema) GetIsState 

func (x *ContainerSchema) GetIsState() bool

func (*ContainerSchema) GetIsUserOrdered 

func (x *ContainerSchema) GetIsUserOrdered() bool

func (*ContainerSchema) GetKeys 

func (x *ContainerSchema) GetKeys() []*LeafSchema

func (*ContainerSchema) GetLeaflists 

func (x *ContainerSchema) GetLeaflists() []*LeafListSchema

func (*ContainerSchema) GetMandatoryChildren 

func (x *ContainerSchema) GetMandatoryChildren() []*MandatoryChild

func (*ContainerSchema) GetMandatoryChildrenConfig added in v0.0.36 

func (x *ContainerSchema) GetMandatoryChildrenConfig() []*MandatoryChild

func (*ContainerSchema) GetMandatoryChildrenState added in v0.0.36 

func (x *ContainerSchema) GetMandatoryChildrenState() []*MandatoryChild

func (*ContainerSchema) GetMaxElements 

func (x *ContainerSchema) GetMaxElements() uint64

func (*ContainerSchema) GetMinElements 

func (x *ContainerSchema) GetMinElements() uint64

func (*ContainerSchema) GetModuleName added in v0.0.33 

func (x *ContainerSchema) GetModuleName() string

func (*ContainerSchema) GetMustStatements 

func (x *ContainerSchema) GetMustStatements() []*MustStatement

func (*ContainerSchema) GetName 

func (x *ContainerSchema) GetName() string

func (*ContainerSchema) GetNamespace 

func (x *ContainerSchema) GetNamespace() string

func (*ContainerSchema) GetOwner 

func (x *ContainerSchema) GetOwner() string

func (*ContainerSchema) GetPrefix 

func (x *ContainerSchema) GetPrefix() string

func (*ContainerSchema) ProtoMessage 

func (*ContainerSchema) ProtoMessage()

func (*ContainerSchema) ProtoReflect 

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

func (*ContainerSchema) Reset 

func (x *ContainerSchema) Reset()

func (*ContainerSchema) String 

func (x *ContainerSchema) String() string

type CreateDataStoreRequest 

type CreateDataStoreRequest struct {

	// datastore name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// datastore type to be created
	Datastore *DataStore `protobuf:"bytes,2,opt,name=datastore,proto3" json:"datastore,omitempty"`
	// the schema this datastore should comply with
	Schema *Schema `protobuf:"bytes,3,opt,name=schema,proto3" json:"schema,omitempty"`
	// south bound interface target of this datastore
	Target *Target `protobuf:"bytes,4,opt,name=target,proto3" json:"target,omitempty"`
	// datastore sync strategy
	Sync *Sync `protobuf:"bytes,5,opt,name=sync,proto3" json:"sync,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDataStoreRequest) Descriptor deprecated 

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

Deprecated: Use CreateDataStoreRequest.ProtoReflect.Descriptor instead.

func (*CreateDataStoreRequest) GetDatastore 

func (x *CreateDataStoreRequest) GetDatastore() *DataStore

func (*CreateDataStoreRequest) GetName 

func (x *CreateDataStoreRequest) GetName() string

func (*CreateDataStoreRequest) GetSchema 

func (x *CreateDataStoreRequest) GetSchema() *Schema

func (*CreateDataStoreRequest) GetSync 

func (x *CreateDataStoreRequest) GetSync() *Sync

func (*CreateDataStoreRequest) GetTarget 

func (x *CreateDataStoreRequest) GetTarget() *Target

func (*CreateDataStoreRequest) ProtoMessage 

func (*CreateDataStoreRequest) ProtoMessage()

func (*CreateDataStoreRequest) ProtoReflect 

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

func (*CreateDataStoreRequest) Reset 

func (x *CreateDataStoreRequest) Reset()

func (*CreateDataStoreRequest) String 

func (x *CreateDataStoreRequest) String() string

type CreateDataStoreResponse 

type CreateDataStoreResponse struct {
	// contains filtered or unexported fields
}

func (*CreateDataStoreResponse) Descriptor deprecated 

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

Deprecated: Use CreateDataStoreResponse.ProtoReflect.Descriptor instead.

func (*CreateDataStoreResponse) ProtoMessage 

func (*CreateDataStoreResponse) ProtoMessage()

func (*CreateDataStoreResponse) ProtoReflect 

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

func (*CreateDataStoreResponse) Reset 

func (x *CreateDataStoreResponse) Reset()

func (*CreateDataStoreResponse) String 

func (x *CreateDataStoreResponse) String() string

type CreateSchemaRequest 

type CreateSchemaRequest struct {
	Schema    *Schema  `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"` // status unset
	File      []string `protobuf:"bytes,2,rep,name=file,proto3" json:"file,omitempty"`
	Directory []string `protobuf:"bytes,3,rep,name=directory,proto3" json:"directory,omitempty"`
	Exclude   []string `protobuf:"bytes,4,rep,name=exclude,proto3" json:"exclude,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSchemaRequest) Descriptor deprecated 

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

Deprecated: Use CreateSchemaRequest.ProtoReflect.Descriptor instead.

func (*CreateSchemaRequest) GetDirectory 

func (x *CreateSchemaRequest) GetDirectory() []string

func (*CreateSchemaRequest) GetExclude 

func (x *CreateSchemaRequest) GetExclude() []string

func (*CreateSchemaRequest) GetFile 

func (x *CreateSchemaRequest) GetFile() []string

func (*CreateSchemaRequest) GetSchema 

func (x *CreateSchemaRequest) GetSchema() *Schema

func (*CreateSchemaRequest) ProtoMessage 

func (*CreateSchemaRequest) ProtoMessage()

func (*CreateSchemaRequest) ProtoReflect 

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

func (*CreateSchemaRequest) Reset 

func (x *CreateSchemaRequest) Reset()

func (*CreateSchemaRequest) String 

func (x *CreateSchemaRequest) String() string

type CreateSchemaResponse 

type CreateSchemaResponse struct {
	Schema *Schema `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"` // status should be intializing
	// contains filtered or unexported fields
}

func (*CreateSchemaResponse) Descriptor deprecated 

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

Deprecated: Use CreateSchemaResponse.ProtoReflect.Descriptor instead.

func (*CreateSchemaResponse) GetSchema 

func (x *CreateSchemaResponse) GetSchema() *Schema

func (*CreateSchemaResponse) ProtoMessage 

func (*CreateSchemaResponse) ProtoMessage()

func (*CreateSchemaResponse) ProtoReflect 

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

func (*CreateSchemaResponse) Reset 

func (x *CreateSchemaResponse) Reset()

func (*CreateSchemaResponse) String 

func (x *CreateSchemaResponse) String() string

type Credentials 

type Credentials struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	Token    string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

Target Credentials

func (*Credentials) Descriptor deprecated 

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

Deprecated: Use Credentials.ProtoReflect.Descriptor instead.

func (*Credentials) GetPassword 

func (x *Credentials) GetPassword() string

func (*Credentials) GetToken 

func (x *Credentials) GetToken() string

func (*Credentials) GetUsername 

func (x *Credentials) GetUsername() string

func (*Credentials) ProtoMessage 

func (*Credentials) ProtoMessage()

func (*Credentials) ProtoReflect 

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

func (*Credentials) Reset 

func (x *Credentials) Reset()

func (*Credentials) String 

func (x *Credentials) String() string

type DataServerClient 

type DataServerClient interface {
	// datastore
	ListDataStore(ctx context.Context, in *ListDataStoreRequest, opts ...grpc.CallOption) (*ListDataStoreResponse, error)
	// return a datastore details
	GetDataStore(ctx context.Context, in *GetDataStoreRequest, opts ...grpc.CallOption) (*GetDataStoreResponse, error)
	// creates a new datastore, either a MAIN or a CANDIDATE datastore
	CreateDataStore(ctx context.Context, in *CreateDataStoreRequest, opts ...grpc.CallOption) (*CreateDataStoreResponse, error)
	// deletes a datastore, either a MAIN or a CANDIDATE datastore
	DeleteDataStore(ctx context.Context, in *DeleteDataStoreRequest, opts ...grpc.CallOption) (*DeleteDataStoreResponse, error)
	// commits changes in a CANDIDATE datastore to the datastore Target
	Commit(ctx context.Context, in *CommitRequest, opts ...grpc.CallOption) (*CommitResponse, error)
	// rebases a CANDIDATE datastore
	Rebase(ctx context.Context, in *RebaseRequest, opts ...grpc.CallOption) (*RebaseResponse, error)
	// discards changes made to a CANDIDATE datastore
	Discard(ctx context.Context, in *DiscardRequest, opts ...grpc.CallOption) (*DiscardResponse, error)
	// data
	// retrieve data from a MAIN or CANDIDATE datastore, the data is specified
	// with a set of schema.prot.Path
	GetData(ctx context.Context, in *GetDataRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetDataResponse], error)
	// writes changes to a CANDIDATE datastore,
	// validates the values written against the datastore schema.
	SetData(ctx context.Context, in *SetDataRequest, opts ...grpc.CallOption) (*SetDataResponse, error)
	// returns a list of difference between a CANDIDATE datastore and its base
	Diff(ctx context.Context, in *DiffRequest, opts ...grpc.CallOption) (*DiffResponse, error)
	// subscribes for notification from a MAIN datastore,
	// the client specified a list of paths it is interested on as well as
	// a sample interval.
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[SubscribeResponse], error)
	// watches a set of paths, returns the values each path points at if the value
	// changes.
	Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[WatchResponse], error)
	// returns an intent details: name, priority and list of updates
	GetIntent(ctx context.Context, in *GetIntentRequest, opts ...grpc.CallOption) (*GetIntentResponse, error)
	// applies an intent to the specified datastore
	SetIntent(ctx context.Context, in *SetIntentRequest, opts ...grpc.CallOption) (*SetIntentResponse, error)
	// list intents for a given datastore (name and priority)
	ListIntent(ctx context.Context, in *ListIntentRequest, opts ...grpc.CallOption) (*ListIntentResponse, error)
	WatchDeviations(ctx context.Context, in *WatchDeviationRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[WatchDeviationResponse], error)
}

DataServerClient is the client API for DataServer 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 NewDataServerClient 

func NewDataServerClient(cc grpc.ClientConnInterface) DataServerClient

type DataServerServer 

type DataServerServer interface {
	// datastore
	ListDataStore(context.Context, *ListDataStoreRequest) (*ListDataStoreResponse, error)
	// return a datastore details
	GetDataStore(context.Context, *GetDataStoreRequest) (*GetDataStoreResponse, error)
	// creates a new datastore, either a MAIN or a CANDIDATE datastore
	CreateDataStore(context.Context, *CreateDataStoreRequest) (*CreateDataStoreResponse, error)
	// deletes a datastore, either a MAIN or a CANDIDATE datastore
	DeleteDataStore(context.Context, *DeleteDataStoreRequest) (*DeleteDataStoreResponse, error)
	// commits changes in a CANDIDATE datastore to the datastore Target
	Commit(context.Context, *CommitRequest) (*CommitResponse, error)
	// rebases a CANDIDATE datastore
	Rebase(context.Context, *RebaseRequest) (*RebaseResponse, error)
	// discards changes made to a CANDIDATE datastore
	Discard(context.Context, *DiscardRequest) (*DiscardResponse, error)
	// data
	// retrieve data from a MAIN or CANDIDATE datastore, the data is specified
	// with a set of schema.prot.Path
	GetData(*GetDataRequest, grpc.ServerStreamingServer[GetDataResponse]) error
	// writes changes to a CANDIDATE datastore,
	// validates the values written against the datastore schema.
	SetData(context.Context, *SetDataRequest) (*SetDataResponse, error)
	// returns a list of difference between a CANDIDATE datastore and its base
	Diff(context.Context, *DiffRequest) (*DiffResponse, error)
	// subscribes for notification from a MAIN datastore,
	// the client specified a list of paths it is interested on as well as
	// a sample interval.
	Subscribe(*SubscribeRequest, grpc.ServerStreamingServer[SubscribeResponse]) error
	// watches a set of paths, returns the values each path points at if the value
	// changes.
	Watch(*WatchRequest, grpc.ServerStreamingServer[WatchResponse]) error
	// returns an intent details: name, priority and list of updates
	GetIntent(context.Context, *GetIntentRequest) (*GetIntentResponse, error)
	// applies an intent to the specified datastore
	SetIntent(context.Context, *SetIntentRequest) (*SetIntentResponse, error)
	// list intents for a given datastore (name and priority)
	ListIntent(context.Context, *ListIntentRequest) (*ListIntentResponse, error)
	WatchDeviations(*WatchDeviationRequest, grpc.ServerStreamingServer[WatchDeviationResponse]) error
	// contains filtered or unexported methods
}

DataServerServer is the server API for DataServer service. All implementations must embed UnimplementedDataServerServer for forward compatibility.

type DataServer_GetDataClient 

type DataServer_GetDataClient = grpc.ServerStreamingClient[GetDataResponse]

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

type DataServer_GetDataServer 

type DataServer_GetDataServer = grpc.ServerStreamingServer[GetDataResponse]

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

type DataServer_SubscribeClient 

type DataServer_SubscribeClient = grpc.ServerStreamingClient[SubscribeResponse]

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

type DataServer_SubscribeServer 

type DataServer_SubscribeServer = grpc.ServerStreamingServer[SubscribeResponse]

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

type DataServer_WatchClient 

type DataServer_WatchClient = grpc.ServerStreamingClient[WatchResponse]

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

type DataServer_WatchDeviationsClient 

type DataServer_WatchDeviationsClient = grpc.ServerStreamingClient[WatchDeviationResponse]

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

type DataServer_WatchDeviationsServer 

type DataServer_WatchDeviationsServer = grpc.ServerStreamingServer[WatchDeviationResponse]

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

type DataServer_WatchServer 

type DataServer_WatchServer = grpc.ServerStreamingServer[WatchResponse]

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

type DataStore 

type DataStore struct {

	// datastore type, MAIN, CANDIDATE or INTENDED
	Type Type `protobuf:"varint,1,opt,name=type,proto3,enum=data.Type" json:"type,omitempty"`
	// name of the datastore (candidate)
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// candidate datastore owner
	Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
	// candidate datastore priority
	Priority int32 `protobuf:"varint,4,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

func (*DataStore) Descriptor deprecated 

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

Deprecated: Use DataStore.ProtoReflect.Descriptor instead.

func (*DataStore) GetName 

func (x *DataStore) GetName() string

func (*DataStore) GetOwner 

func (x *DataStore) GetOwner() string

func (*DataStore) GetPriority 

func (x *DataStore) GetPriority() int32

func (*DataStore) GetType 

func (x *DataStore) GetType() Type

func (*DataStore) ProtoMessage 

func (*DataStore) ProtoMessage()

func (*DataStore) ProtoReflect 

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

func (*DataStore) Reset 

func (x *DataStore) Reset()

func (*DataStore) String 

func (x *DataStore) String() string

type DataType 

type DataType int32
const (
	DataType_ALL    DataType = 0
	DataType_CONFIG DataType = 1
	DataType_STATE  DataType = 2
)

func (DataType) Descriptor 

func (DataType) Descriptor() protoreflect.EnumDescriptor

func (DataType) Enum 

func (x DataType) Enum() *DataType

func (DataType) EnumDescriptor deprecated 

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

Deprecated: Use DataType.Descriptor instead.

func (DataType) Number 

func (x DataType) Number() protoreflect.EnumNumber

func (DataType) String 

func (x DataType) String() string

func (DataType) Type 

func (DataType) Type() protoreflect.EnumType

type Decimal64 

type Decimal64 struct {
	Digits    int64  `protobuf:"varint,1,opt,name=digits,proto3" json:"digits,omitempty"`       // Set of digits.
	Precision uint32 `protobuf:"varint,2,opt,name=precision,proto3" json:"precision,omitempty"` // Number of digits following the decimal point.
	// contains filtered or unexported fields
}

Decimal64 is used to encode a fixed precision decimal number. The value is expressed as a set of digits with the precision specifying the number of digits following the decimal point in the digit set.

func (*Decimal64) Descriptor deprecated 

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

Deprecated: Use Decimal64.ProtoReflect.Descriptor instead.

func (*Decimal64) GetDigits 

func (x *Decimal64) GetDigits() int64

func (*Decimal64) GetPrecision 

func (x *Decimal64) GetPrecision() uint32

func (*Decimal64) ProtoMessage 

func (*Decimal64) ProtoMessage()

func (*Decimal64) ProtoReflect 

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

func (*Decimal64) Reset 

func (x *Decimal64) Reset()

func (*Decimal64) String 

func (x *Decimal64) String() string

type DeleteDataStoreRequest 

type DeleteDataStoreRequest struct {

	// datastore name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// datastore (to be deleted) type and name
	Datastore *DataStore `protobuf:"bytes,2,opt,name=datastore,proto3" json:"datastore,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDataStoreRequest) Descriptor deprecated 

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

Deprecated: Use DeleteDataStoreRequest.ProtoReflect.Descriptor instead.

func (*DeleteDataStoreRequest) GetDatastore 

func (x *DeleteDataStoreRequest) GetDatastore() *DataStore

func (*DeleteDataStoreRequest) GetName 

func (x *DeleteDataStoreRequest) GetName() string

func (*DeleteDataStoreRequest) ProtoMessage 

func (*DeleteDataStoreRequest) ProtoMessage()

func (*DeleteDataStoreRequest) ProtoReflect 

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

func (*DeleteDataStoreRequest) Reset 

func (x *DeleteDataStoreRequest) Reset()

func (*DeleteDataStoreRequest) String 

func (x *DeleteDataStoreRequest) String() string

type DeleteDataStoreResponse 

type DeleteDataStoreResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteDataStoreResponse) Descriptor deprecated 

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

Deprecated: Use DeleteDataStoreResponse.ProtoReflect.Descriptor instead.

func (*DeleteDataStoreResponse) ProtoMessage 

func (*DeleteDataStoreResponse) ProtoMessage()

func (*DeleteDataStoreResponse) ProtoReflect 

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

func (*DeleteDataStoreResponse) Reset 

func (x *DeleteDataStoreResponse) Reset()

func (*DeleteDataStoreResponse) String 

func (x *DeleteDataStoreResponse) String() string

type DeleteSchemaRequest 

type DeleteSchemaRequest struct {
	Schema *Schema `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSchemaRequest) Descriptor deprecated 

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

Deprecated: Use DeleteSchemaRequest.ProtoReflect.Descriptor instead.

func (*DeleteSchemaRequest) GetSchema 

func (x *DeleteSchemaRequest) GetSchema() *Schema

func (*DeleteSchemaRequest) ProtoMessage 

func (*DeleteSchemaRequest) ProtoMessage()

func (*DeleteSchemaRequest) ProtoReflect 

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

func (*DeleteSchemaRequest) Reset 

func (x *DeleteSchemaRequest) Reset()

func (*DeleteSchemaRequest) String 

func (x *DeleteSchemaRequest) String() string

type DeleteSchemaResponse 

type DeleteSchemaResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteSchemaResponse) Descriptor deprecated 

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

Deprecated: Use DeleteSchemaResponse.ProtoReflect.Descriptor instead.

func (*DeleteSchemaResponse) ProtoMessage 

func (*DeleteSchemaResponse) ProtoMessage()

func (*DeleteSchemaResponse) ProtoReflect 

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

func (*DeleteSchemaResponse) Reset 

func (x *DeleteSchemaResponse) Reset()

func (*DeleteSchemaResponse) String 

func (x *DeleteSchemaResponse) String() string

type DeviationEvent 

type DeviationEvent int32
const (
	DeviationEvent_DE_UNKNOWN DeviationEvent = 0
	DeviationEvent_START      DeviationEvent = 1
	DeviationEvent_END        DeviationEvent = 2
	DeviationEvent_UPDATE     DeviationEvent = 3
	DeviationEvent_CLEAR      DeviationEvent = 4
)

func (DeviationEvent) Descriptor 

func (DeviationEvent) Descriptor() protoreflect.EnumDescriptor

func (DeviationEvent) Enum 

func (x DeviationEvent) Enum() *DeviationEvent

func (DeviationEvent) EnumDescriptor deprecated 

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

Deprecated: Use DeviationEvent.Descriptor instead.

func (DeviationEvent) Number 

func (x DeviationEvent) Number() protoreflect.EnumNumber

func (DeviationEvent) String 

func (x DeviationEvent) String() string

func (DeviationEvent) Type 

func (DeviationEvent) Type() protoreflect.EnumType

type DeviationReason 

type DeviationReason int32
const (
	DeviationReason_DR_UNKNOWN  DeviationReason = 0
	DeviationReason_UNHANDLED   DeviationReason = 1
	DeviationReason_NOT_APPLIED DeviationReason = 2
	DeviationReason_OVERRULED   DeviationReason = 3
)

func (DeviationReason) Descriptor 

func (DeviationReason) Descriptor() protoreflect.EnumDescriptor

func (DeviationReason) Enum 

func (x DeviationReason) Enum() *DeviationReason

func (DeviationReason) EnumDescriptor deprecated 

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

Deprecated: Use DeviationReason.Descriptor instead.

func (DeviationReason) Number 

func (x DeviationReason) Number() protoreflect.EnumNumber

func (DeviationReason) String 

func (x DeviationReason) String() string

func (DeviationReason) Type 

func (DeviationReason) Type() protoreflect.EnumType

type DiffRequest 

type DiffRequest struct {

	// datastore name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// CANDIDATE datastore name
	Datastore *DataStore `protobuf:"bytes,2,opt,name=datastore,proto3" json:"datastore,omitempty"`
	// contains filtered or unexported fields
}

func (*DiffRequest) Descriptor deprecated 

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

Deprecated: Use DiffRequest.ProtoReflect.Descriptor instead.

func (*DiffRequest) GetDatastore 

func (x *DiffRequest) GetDatastore() *DataStore

func (*DiffRequest) GetName 

func (x *DiffRequest) GetName() string

func (*DiffRequest) ProtoMessage 

func (*DiffRequest) ProtoMessage()

func (*DiffRequest) ProtoReflect 

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

func (*DiffRequest) Reset 

func (x *DiffRequest) Reset()

func (*DiffRequest) String 

func (x *DiffRequest) String() string

type DiffResponse 

type DiffResponse struct {

	// datastore name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// CANDIDATE datastore name
	Datastore *DataStore `protobuf:"bytes,2,opt,name=datastore,proto3" json:"datastore,omitempty"`
	// list of paths and values that differ between MAIN and CANDIDATE
	Diff []*DiffUpdate `protobuf:"bytes,3,rep,name=diff,proto3" json:"diff,omitempty"`
	// contains filtered or unexported fields
}

func (*DiffResponse) Descriptor deprecated 

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

Deprecated: Use DiffResponse.ProtoReflect.Descriptor instead.

func (*DiffResponse) GetDatastore 

func (x *DiffResponse) GetDatastore() *DataStore

func (*DiffResponse) GetDiff 

func (x *DiffResponse) GetDiff() []*DiffUpdate

func (*DiffResponse) GetName 

func (x *DiffResponse) GetName() string

func (*DiffResponse) ProtoMessage 

func (*DiffResponse) ProtoMessage()

func (*DiffResponse) ProtoReflect 

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

func (*DiffResponse) Reset 

func (x *DiffResponse) Reset()

func (*DiffResponse) String 

func (x *DiffResponse) String() string

type DiffUpdate 

type DiffUpdate struct {
	Path           *Path       `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	MainValue      *TypedValue `protobuf:"bytes,2,opt,name=main_value,json=mainValue,proto3" json:"main_value,omitempty"`
	CandidateValue *TypedValue `protobuf:"bytes,3,opt,name=candidate_value,json=candidateValue,proto3" json:"candidate_value,omitempty"`
	// contains filtered or unexported fields
}

func (*DiffUpdate) Descriptor deprecated 

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

Deprecated: Use DiffUpdate.ProtoReflect.Descriptor instead.

func (*DiffUpdate) GetCandidateValue 

func (x *DiffUpdate) GetCandidateValue() *TypedValue

func (*DiffUpdate) GetMainValue 

func (x *DiffUpdate) GetMainValue() *TypedValue

func (*DiffUpdate) GetPath 

func (x *DiffUpdate) GetPath() *Path

func (*DiffUpdate) ProtoMessage 

func (*DiffUpdate) ProtoMessage()

func (*DiffUpdate) ProtoReflect 

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

func (*DiffUpdate) Reset 

func (x *DiffUpdate) Reset()

func (*DiffUpdate) String 

func (x *DiffUpdate) String() string

type DiscardRequest 

type DiscardRequest struct {

	// datastore name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// candidate name to discard
	Datastore *DataStore `protobuf:"bytes,2,opt,name=datastore,proto3" json:"datastore,omitempty"`
	// do not delete candidate after discarding changes
	Stay bool `protobuf:"varint,3,opt,name=stay,proto3" json:"stay,omitempty"`
	// contains filtered or unexported fields
}

func (*DiscardRequest) Descriptor deprecated 

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

Deprecated: Use DiscardRequest.ProtoReflect.Descriptor instead.

func (*DiscardRequest) GetDatastore 

func (x *DiscardRequest) GetDatastore() *DataStore

func (*DiscardRequest) GetName 

func (x *DiscardRequest) GetName() string

func (*DiscardRequest) GetStay 

func (x *DiscardRequest) GetStay() bool

func (*DiscardRequest) ProtoMessage 

func (*DiscardRequest) ProtoMessage()

func (*DiscardRequest) ProtoReflect 

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

func (*DiscardRequest) Reset 

func (x *DiscardRequest) Reset()

func (*DiscardRequest) String 

func (x *DiscardRequest) String() string

type DiscardResponse 

type DiscardResponse struct {
	// contains filtered or unexported fields
}

func (*DiscardResponse) Descriptor deprecated 

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

Deprecated: Use DiscardResponse.ProtoReflect.Descriptor instead.

func (*DiscardResponse) ProtoMessage 

func (*DiscardResponse) ProtoMessage()

func (*DiscardResponse) ProtoReflect 

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

func (*DiscardResponse) Reset 

func (x *DiscardResponse) Reset()

func (*DiscardResponse) String 

func (x *DiscardResponse) String() string

type Encoding 

type Encoding int32

GetDataRequest encoding 

const (
	Encoding_STRING    Encoding = 0
	Encoding_JSON      Encoding = 1
	Encoding_JSON_IETF Encoding = 2
	Encoding_PROTO     Encoding = 3
)

func (Encoding) Descriptor 

func (Encoding) Descriptor() protoreflect.EnumDescriptor

func (Encoding) Enum 

func (x Encoding) Enum() *Encoding

func (Encoding) EnumDescriptor deprecated 

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

Deprecated: Use Encoding.Descriptor instead.

func (Encoding) Number 

func (x Encoding) Number() protoreflect.EnumNumber

func (Encoding) String 

func (x Encoding) String() string

func (Encoding) Type 

func (Encoding) Type() protoreflect.EnumType

type ExpandPathRequest 

type ExpandPathRequest struct {
	Path     *Path    `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Schema   *Schema  `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	DataType DataType `protobuf:"varint,3,opt,name=data_type,json=dataType,proto3,enum=schema.DataType" json:"data_type,omitempty"`
	Xpath    bool     `protobuf:"varint,4,opt,name=xpath,proto3" json:"xpath,omitempty"`
	// contains filtered or unexported fields
}

func (*ExpandPathRequest) Descriptor deprecated 

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

Deprecated: Use ExpandPathRequest.ProtoReflect.Descriptor instead.

func (*ExpandPathRequest) GetDataType 

func (x *ExpandPathRequest) GetDataType() DataType

func (*ExpandPathRequest) GetPath 

func (x *ExpandPathRequest) GetPath() *Path

func (*ExpandPathRequest) GetSchema 

func (x *ExpandPathRequest) GetSchema() *Schema

func (*ExpandPathRequest) GetXpath 

func (x *ExpandPathRequest) GetXpath() bool

func (*ExpandPathRequest) ProtoMessage 

func (*ExpandPathRequest) ProtoMessage()

func (*ExpandPathRequest) ProtoReflect 

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

func (*ExpandPathRequest) Reset 

func (x *ExpandPathRequest) Reset()

func (*ExpandPathRequest) String 

func (x *ExpandPathRequest) String() string

type ExpandPathResponse 

type ExpandPathResponse struct {
	Path  []*Path  `protobuf:"bytes,1,rep,name=path,proto3" json:"path,omitempty"`
	Xpath []string `protobuf:"bytes,2,rep,name=xpath,proto3" json:"xpath,omitempty"`
	// contains filtered or unexported fields
}

func (*ExpandPathResponse) Descriptor deprecated 

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

Deprecated: Use ExpandPathResponse.ProtoReflect.Descriptor instead.

func (*ExpandPathResponse) GetPath 

func (x *ExpandPathResponse) GetPath() []*Path

func (*ExpandPathResponse) GetXpath 

func (x *ExpandPathResponse) GetXpath() []string

func (*ExpandPathResponse) ProtoMessage 

func (*ExpandPathResponse) ProtoMessage()

func (*ExpandPathResponse) ProtoReflect 

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

func (*ExpandPathResponse) Reset 

func (x *ExpandPathResponse) Reset()

func (*ExpandPathResponse) String 

func (x *ExpandPathResponse) String() string

type GetDataRequest 

type GetDataRequest struct {

	// data store name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// data store type
	Datastore *DataStore `protobuf:"bytes,2,opt,name=datastore,proto3" json:"datastore,omitempty"`
	// path list
	Path []*Path `protobuf:"bytes,3,rep,name=path,proto3" json:"path,omitempty"`
	// dataType config, state
	DataType DataType `protobuf:"varint,4,opt,name=data_type,json=dataType,proto3,enum=schema.DataType" json:"data_type,omitempty"`
	// data encoding
	Encoding Encoding `protobuf:"varint,5,opt,name=encoding,proto3,enum=data.Encoding" json:"encoding,omitempty"`
	// contains filtered or unexported fields
}

messages

func (*GetDataRequest) Descriptor deprecated 

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

Deprecated: Use GetDataRequest.ProtoReflect.Descriptor instead.

func (*GetDataRequest) GetDataType 

func (x *GetDataRequest) GetDataType() DataType

func (*GetDataRequest) GetDatastore 

func (x *GetDataRequest) GetDatastore() *DataStore

func (*GetDataRequest) GetEncoding 

func (x *GetDataRequest) GetEncoding() Encoding

func (*GetDataRequest) GetName 

func (x *GetDataRequest) GetName() string

func (*GetDataRequest) GetPath 

func (x *GetDataRequest) GetPath() []*Path

func (*GetDataRequest) ProtoMessage 

func (*GetDataRequest) ProtoMessage()

func (*GetDataRequest) ProtoReflect 

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

func (*GetDataRequest) Reset 

func (x *GetDataRequest) Reset()

func (*GetDataRequest) String 

func (x *GetDataRequest) String() string

type GetDataResponse 

type GetDataResponse struct {

	// list of paths and values
	Notification []*Notification `protobuf:"bytes,1,rep,name=notification,proto3" json:"notification,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDataResponse) Descriptor deprecated 

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

Deprecated: Use GetDataResponse.ProtoReflect.Descriptor instead.

func (*GetDataResponse) GetNotification 

func (x *GetDataResponse) GetNotification() []*Notification

func (*GetDataResponse) ProtoMessage 

func (*GetDataResponse) ProtoMessage()

func (*GetDataResponse) ProtoReflect 

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

func (*GetDataResponse) Reset 

func (x *GetDataResponse) Reset()

func (*GetDataResponse) String 

func (x *GetDataResponse) String() string

type GetDataStoreRequest 

type GetDataStoreRequest struct {

	// datastore name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDataStoreRequest) Descriptor deprecated 

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

Deprecated: Use GetDataStoreRequest.ProtoReflect.Descriptor instead.

func (*GetDataStoreRequest) GetName 

func (x *GetDataStoreRequest) GetName() string

func (*GetDataStoreRequest) ProtoMessage 

func (*GetDataStoreRequest) ProtoMessage()

func (*GetDataStoreRequest) ProtoReflect 

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

func (*GetDataStoreRequest) Reset 

func (x *GetDataStoreRequest) Reset()

func (*GetDataStoreRequest) String 

func (x *GetDataStoreRequest) String() string

type GetDataStoreResponse 

type GetDataStoreResponse struct {

	// datastore name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// list of candidates in this datastore
	Datastore []*DataStore `protobuf:"bytes,2,rep,name=datastore,proto3" json:"datastore,omitempty"`
	// the schema this datastore should comply with
	Schema *Schema `protobuf:"bytes,3,opt,name=schema,proto3" json:"schema,omitempty"`
	// south bound interface target of this datastore
	Target *Target `protobuf:"bytes,4,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDataStoreResponse) Descriptor deprecated 

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

Deprecated: Use GetDataStoreResponse.ProtoReflect.Descriptor instead.

func (*GetDataStoreResponse) GetDatastore 

func (x *GetDataStoreResponse) GetDatastore() []*DataStore

func (*GetDataStoreResponse) GetName 

func (x *GetDataStoreResponse) GetName() string

func (*GetDataStoreResponse) GetSchema 

func (x *GetDataStoreResponse) GetSchema() *Schema

func (*GetDataStoreResponse) GetTarget 

func (x *GetDataStoreResponse) GetTarget() *Target

func (*GetDataStoreResponse) ProtoMessage 

func (*GetDataStoreResponse) ProtoMessage()

func (*GetDataStoreResponse) ProtoReflect 

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

func (*GetDataStoreResponse) Reset 

func (x *GetDataStoreResponse) Reset()

func (*GetDataStoreResponse) String 

func (x *GetDataStoreResponse) String() string

type GetIntentRequest 

type GetIntentRequest struct {

	// datastore name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// intent name
	Intent string `protobuf:"bytes,2,opt,name=intent,proto3" json:"intent,omitempty"`
	// intent priority
	Priority int32 `protobuf:"varint,3,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

func (*GetIntentRequest) Descriptor deprecated 

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

Deprecated: Use GetIntentRequest.ProtoReflect.Descriptor instead.

func (*GetIntentRequest) GetIntent 

func (x *GetIntentRequest) GetIntent() string

func (*GetIntentRequest) GetName 

func (x *GetIntentRequest) GetName() string

func (*GetIntentRequest) GetPriority 

func (x *GetIntentRequest) GetPriority() int32

func (*GetIntentRequest) ProtoMessage 

func (*GetIntentRequest) ProtoMessage()

func (*GetIntentRequest) ProtoReflect 

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

func (*GetIntentRequest) Reset 

func (x *GetIntentRequest) Reset()

func (*GetIntentRequest) String 

func (x *GetIntentRequest) String() string

type GetIntentResponse 

type GetIntentResponse struct {

	// datastore name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// intent details
	Intent *Intent `protobuf:"bytes,2,opt,name=intent,proto3" json:"intent,omitempty"`
	// contains filtered or unexported fields
}

func (*GetIntentResponse) Descriptor deprecated 

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

Deprecated: Use GetIntentResponse.ProtoReflect.Descriptor instead.

func (*GetIntentResponse) GetIntent 

func (x *GetIntentResponse) GetIntent() *Intent

func (*GetIntentResponse) GetName 

func (x *GetIntentResponse) GetName() string

func (*GetIntentResponse) ProtoMessage 

func (*GetIntentResponse) ProtoMessage()

func (*GetIntentResponse) ProtoReflect 

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

func (*GetIntentResponse) Reset 

func (x *GetIntentResponse) Reset()

func (*GetIntentResponse) String 

func (x *GetIntentResponse) String() string

type GetSchemaDetailsRequest 

type GetSchemaDetailsRequest struct {
	Schema *Schema `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

RPC messages

func (*GetSchemaDetailsRequest) Descriptor deprecated 

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

Deprecated: Use GetSchemaDetailsRequest.ProtoReflect.Descriptor instead.

func (*GetSchemaDetailsRequest) GetSchema 

func (x *GetSchemaDetailsRequest) GetSchema() *Schema

func (*GetSchemaDetailsRequest) ProtoMessage 

func (*GetSchemaDetailsRequest) ProtoMessage()

func (*GetSchemaDetailsRequest) ProtoReflect 

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

func (*GetSchemaDetailsRequest) Reset 

func (x *GetSchemaDetailsRequest) Reset()

func (*GetSchemaDetailsRequest) String 

func (x *GetSchemaDetailsRequest) String() string

type GetSchemaDetailsResponse 

type GetSchemaDetailsResponse struct {
	Schema    *Schema  `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"` // with status
	File      []string `protobuf:"bytes,2,rep,name=file,proto3" json:"file,omitempty"`
	Directory []string `protobuf:"bytes,3,rep,name=directory,proto3" json:"directory,omitempty"`
	Exclude   []string `protobuf:"bytes,4,rep,name=exclude,proto3" json:"exclude,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSchemaDetailsResponse) Descriptor deprecated 

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

Deprecated: Use GetSchemaDetailsResponse.ProtoReflect.Descriptor instead.

func (*GetSchemaDetailsResponse) GetDirectory 

func (x *GetSchemaDetailsResponse) GetDirectory() []string

func (*GetSchemaDetailsResponse) GetExclude 

func (x *GetSchemaDetailsResponse) GetExclude() []string

func (*GetSchemaDetailsResponse) GetFile 

func (x *GetSchemaDetailsResponse) GetFile() []string

func (*GetSchemaDetailsResponse) GetSchema 

func (x *GetSchemaDetailsResponse) GetSchema() *Schema

func (*GetSchemaDetailsResponse) ProtoMessage 

func (*GetSchemaDetailsResponse) ProtoMessage()

func (*GetSchemaDetailsResponse) ProtoReflect 

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

func (*GetSchemaDetailsResponse) Reset 

func (x *GetSchemaDetailsResponse) Reset()

func (*GetSchemaDetailsResponse) String 

func (x *GetSchemaDetailsResponse) String() string

type GetSchemaRequest 

type GetSchemaRequest struct {
	Path            *Path   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Schema          *Schema `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	ValidateKeys    bool    `protobuf:"varint,3,opt,name=validate_keys,json=validateKeys,proto3" json:"validate_keys,omitempty"`          // TODO
	WithDescription bool    `protobuf:"varint,4,opt,name=with_description,json=withDescription,proto3" json:"with_description,omitempty"` // TODO
	// contains filtered or unexported fields
}

func (*GetSchemaRequest) Descriptor deprecated 

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

Deprecated: Use GetSchemaRequest.ProtoReflect.Descriptor instead.

func (*GetSchemaRequest) GetPath 

func (x *GetSchemaRequest) GetPath() *Path

func (*GetSchemaRequest) GetSchema 

func (x *GetSchemaRequest) GetSchema() *Schema

func (*GetSchemaRequest) GetValidateKeys 

func (x *GetSchemaRequest) GetValidateKeys() bool

func (*GetSchemaRequest) GetWithDescription 

func (x *GetSchemaRequest) GetWithDescription() bool

func (*GetSchemaRequest) ProtoMessage 

func (*GetSchemaRequest) ProtoMessage()

func (*GetSchemaRequest) ProtoReflect 

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

func (*GetSchemaRequest) Reset 

func (x *GetSchemaRequest) Reset()

func (*GetSchemaRequest) String 

func (x *GetSchemaRequest) String() string

type GetSchemaResponse 

type GetSchemaResponse struct {
	Schema *SchemaElem `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSchemaResponse) Descriptor deprecated 

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

Deprecated: Use GetSchemaResponse.ProtoReflect.Descriptor instead.

func (*GetSchemaResponse) GetSchema 

func (x *GetSchemaResponse) GetSchema() *SchemaElem

func (*GetSchemaResponse) ProtoMessage 

func (*GetSchemaResponse) ProtoMessage()

func (*GetSchemaResponse) ProtoReflect 

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

func (*GetSchemaResponse) Reset 

func (x *GetSchemaResponse) Reset()

func (*GetSchemaResponse) String 

func (x *GetSchemaResponse) String() string

type GnmiOptions added in v0.0.33 

type GnmiOptions struct {

	// for gnmi targets
	Encoding string `protobuf:"bytes,11,opt,name=encoding,proto3" json:"encoding,omitempty"`
	// contains filtered or unexported fields
}

func (*GnmiOptions) Descriptor deprecated added in v0.0.33 

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

Deprecated: Use GnmiOptions.ProtoReflect.Descriptor instead.

func (*GnmiOptions) GetEncoding added in v0.0.33 

func (x *GnmiOptions) GetEncoding() string

func (*GnmiOptions) ProtoMessage added in v0.0.33 

func (*GnmiOptions) ProtoMessage()

func (*GnmiOptions) ProtoReflect added in v0.0.33 

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

func (*GnmiOptions) Reset added in v0.0.33 

func (x *GnmiOptions) Reset()

func (*GnmiOptions) String added in v0.0.33 

func (x *GnmiOptions) String() string

type Hash 

type Hash struct {
	Method Hash_HashMethod `protobuf:"varint,1,opt,name=method,proto3,enum=schema.Hash_HashMethod" json:"method,omitempty"`
	Hash   []byte          `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

func (*Hash) Descriptor deprecated 

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

Deprecated: Use Hash.ProtoReflect.Descriptor instead.

func (*Hash) GetHash 

func (x *Hash) GetHash() []byte

func (*Hash) GetMethod 

func (x *Hash) GetMethod() Hash_HashMethod

func (*Hash) ProtoMessage 

func (*Hash) ProtoMessage()

func (*Hash) ProtoReflect 

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

func (*Hash) Reset 

func (x *Hash) Reset()

func (*Hash) String 

func (x *Hash) String() string

type Hash_HashMethod 

type Hash_HashMethod int32
const (
	Hash_UNSPECIFIED Hash_HashMethod = 0 // Error
	Hash_MD5         Hash_HashMethod = 1
	Hash_SHA256      Hash_HashMethod = 2
	Hash_SHA512      Hash_HashMethod = 3
)

func (Hash_HashMethod) Descriptor 

func (Hash_HashMethod) Descriptor() protoreflect.EnumDescriptor

func (Hash_HashMethod) Enum 

func (x Hash_HashMethod) Enum() *Hash_HashMethod

func (Hash_HashMethod) EnumDescriptor deprecated 

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

Deprecated: Use Hash_HashMethod.Descriptor instead.

func (Hash_HashMethod) Number 

func (x Hash_HashMethod) Number() protoreflect.EnumNumber

func (Hash_HashMethod) String 

func (x Hash_HashMethod) String() string

func (Hash_HashMethod) Type 

func (Hash_HashMethod) Type() protoreflect.EnumType

type IdentityRef added in v0.0.33 

type IdentityRef struct {
	Value  string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Prefix string `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Module string `protobuf:"bytes,3,opt,name=module,proto3" json:"module,omitempty"`
	// contains filtered or unexported fields
}

func (*IdentityRef) Descriptor deprecated added in v0.0.33 

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

Deprecated: Use IdentityRef.ProtoReflect.Descriptor instead.

func (*IdentityRef) GetModule added in v0.0.33 

func (x *IdentityRef) GetModule() string

func (*IdentityRef) GetPrefix added in v0.0.33 

func (x *IdentityRef) GetPrefix() string

func (*IdentityRef) GetValue added in v0.0.33 

func (x *IdentityRef) GetValue() string

func (*IdentityRef) JsonIetfString added in v0.0.33 

func (x *IdentityRef) JsonIetfString() string

JsonString resturns the Value as "<module>:<value>" as represented in json_ietf

func (*IdentityRef) ProtoMessage added in v0.0.33 

func (*IdentityRef) ProtoMessage()

func (*IdentityRef) ProtoReflect added in v0.0.33 

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

func (*IdentityRef) Reset added in v0.0.33 

func (x *IdentityRef) Reset()

func (*IdentityRef) String added in v0.0.33 

func (x *IdentityRef) String() string

func (*IdentityRef) YangString added in v0.0.33 

func (x *IdentityRef) YangString() string

YangString resturns the Value as "<prefix>:<value>" as represented in the schema

type Intent 

type Intent struct {

	// intent name
	Intent string `protobuf:"bytes,1,opt,name=intent,proto3" json:"intent,omitempty"`
	// intent priority
	Priority int32 `protobuf:"varint,2,opt,name=priority,proto3" json:"priority,omitempty"`
	// list of updates
	Update []*Update `protobuf:"bytes,3,rep,name=update,proto3" json:"update,omitempty"`
	// contains filtered or unexported fields
}

func (*Intent) Descriptor deprecated 

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

Deprecated: Use Intent.ProtoReflect.Descriptor instead.

func (*Intent) GetIntent 

func (x *Intent) GetIntent() string

func (*Intent) GetPriority 

func (x *Intent) GetPriority() int32

func (*Intent) GetUpdate 

func (x *Intent) GetUpdate() []*Update

func (*Intent) ProtoMessage 

func (*Intent) ProtoMessage()

func (*Intent) ProtoReflect 

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

func (*Intent) Reset 

func (x *Intent) Reset()

func (*Intent) String 

func (x *Intent) String() string

type LeafListSchema 

type LeafListSchema struct {
	Name           string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description    string           `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Owner          string           `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
	Namespace      string           `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Prefix         string           `protobuf:"bytes,5,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Type           *SchemaLeafType  `protobuf:"bytes,6,opt,name=type,proto3" json:"type,omitempty"`
	Encrypted      bool             `protobuf:"varint,7,opt,name=encrypted,proto3" json:"encrypted,omitempty"`
	ModuleName     string           `protobuf:"bytes,8,opt,name=module_name,json=moduleName,proto3" json:"module_name,omitempty"`
	Units          string           `protobuf:"bytes,9,opt,name=units,proto3" json:"units,omitempty"`
	MustStatements []*MustStatement `protobuf:"bytes,11,rep,name=must_statements,json=mustStatements,proto3" json:"must_statements,omitempty"`
	Defaults       []string         `protobuf:"bytes,12,rep,name=defaults,proto3" json:"defaults,omitempty"`
	MaxElements    uint64           `protobuf:"varint,13,opt,name=max_elements,json=maxElements,proto3" json:"max_elements,omitempty"`
	MinElements    uint64           `protobuf:"varint,14,opt,name=min_elements,json=minElements,proto3" json:"min_elements,omitempty"`
	IsState        bool             `protobuf:"varint,21,opt,name=is_state,json=isState,proto3" json:"is_state,omitempty"`
	IsUserOrdered  bool             `protobuf:"varint,22,opt,name=is_user_ordered,json=isUserOrdered,proto3" json:"is_user_ordered,omitempty"`
	IfFeature      []string         `protobuf:"bytes,23,rep,name=if_feature,json=ifFeature,proto3" json:"if_feature,omitempty"`
	// contains filtered or unexported fields
}

func (*LeafListSchema) Descriptor deprecated 

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

Deprecated: Use LeafListSchema.ProtoReflect.Descriptor instead.

func (*LeafListSchema) GetDefaults 

func (x *LeafListSchema) GetDefaults() []string

func (*LeafListSchema) GetDescription 

func (x *LeafListSchema) GetDescription() string

func (*LeafListSchema) GetEncrypted 

func (x *LeafListSchema) GetEncrypted() bool

func (*LeafListSchema) GetIfFeature 

func (x *LeafListSchema) GetIfFeature() []string

func (*LeafListSchema) GetIsState 

func (x *LeafListSchema) GetIsState() bool

func (*LeafListSchema) GetIsUserOrdered 

func (x *LeafListSchema) GetIsUserOrdered() bool

func (*LeafListSchema) GetMaxElements 

func (x *LeafListSchema) GetMaxElements() uint64

func (*LeafListSchema) GetMinElements 

func (x *LeafListSchema) GetMinElements() uint64

func (*LeafListSchema) GetModuleName added in v0.0.33 

func (x *LeafListSchema) GetModuleName() string

func (*LeafListSchema) GetMustStatements 

func (x *LeafListSchema) GetMustStatements() []*MustStatement

func (*LeafListSchema) GetName 

func (x *LeafListSchema) GetName() string

func (*LeafListSchema) GetNamespace 

func (x *LeafListSchema) GetNamespace() string

func (*LeafListSchema) GetOwner 

func (x *LeafListSchema) GetOwner() string

func (*LeafListSchema) GetPrefix 

func (x *LeafListSchema) GetPrefix() string

func (*LeafListSchema) GetType 

func (x *LeafListSchema) GetType() *SchemaLeafType

func (*LeafListSchema) GetUnits 

func (x *LeafListSchema) GetUnits() string

func (*LeafListSchema) ProtoMessage 

func (*LeafListSchema) ProtoMessage()

func (*LeafListSchema) ProtoReflect 

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

func (*LeafListSchema) Reset 

func (x *LeafListSchema) Reset()

func (*LeafListSchema) String 

func (x *LeafListSchema) String() string

type LeafSchema 

type LeafSchema struct {
	Name           string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description    string           `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Owner          string           `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
	Namespace      string           `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Prefix         string           `protobuf:"bytes,5,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Type           *SchemaLeafType  `protobuf:"bytes,6,opt,name=type,proto3" json:"type,omitempty"`
	Encrypted      bool             `protobuf:"varint,7,opt,name=encrypted,proto3" json:"encrypted,omitempty"`
	IsMandatory    bool             `protobuf:"varint,8,opt,name=is_mandatory,json=isMandatory,proto3" json:"is_mandatory,omitempty"`
	Units          string           `protobuf:"bytes,9,opt,name=units,proto3" json:"units,omitempty"`
	ModuleName     string           `protobuf:"bytes,10,opt,name=module_name,json=moduleName,proto3" json:"module_name,omitempty"`
	MustStatements []*MustStatement `protobuf:"bytes,11,rep,name=must_statements,json=mustStatements,proto3" json:"must_statements,omitempty"`
	Default        string           `protobuf:"bytes,12,opt,name=default,proto3" json:"default,omitempty"`
	IsState        bool             `protobuf:"varint,21,opt,name=is_state,json=isState,proto3" json:"is_state,omitempty"`
	IfFeature      []string         `protobuf:"bytes,23,rep,name=if_feature,json=ifFeature,proto3" json:"if_feature,omitempty"`
	Reference      []string         `protobuf:"bytes,25,rep,name=reference,proto3" json:"reference,omitempty"`
	// contains filtered or unexported fields
}

func (*LeafSchema) Descriptor deprecated 

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

Deprecated: Use LeafSchema.ProtoReflect.Descriptor instead.

func (*LeafSchema) GetDefault 

func (x *LeafSchema) GetDefault() string

func (*LeafSchema) GetDescription 

func (x *LeafSchema) GetDescription() string

func (*LeafSchema) GetEncrypted 

func (x *LeafSchema) GetEncrypted() bool

func (*LeafSchema) GetIfFeature 

func (x *LeafSchema) GetIfFeature() []string

func (*LeafSchema) GetIsMandatory 

func (x *LeafSchema) GetIsMandatory() bool

func (*LeafSchema) GetIsState 

func (x *LeafSchema) GetIsState() bool

func (*LeafSchema) GetModuleName added in v0.0.33 

func (x *LeafSchema) GetModuleName() string

func (*LeafSchema) GetMustStatements 

func (x *LeafSchema) GetMustStatements() []*MustStatement

func (*LeafSchema) GetName 

func (x *LeafSchema) GetName() string

func (*LeafSchema) GetNamespace 

func (x *LeafSchema) GetNamespace() string

func (*LeafSchema) GetOwner 

func (x *LeafSchema) GetOwner() string

func (*LeafSchema) GetPrefix 

func (x *LeafSchema) GetPrefix() string

func (*LeafSchema) GetReference 

func (x *LeafSchema) GetReference() []string

func (*LeafSchema) GetType 

func (x *LeafSchema) GetType() *SchemaLeafType

func (*LeafSchema) GetUnits 

func (x *LeafSchema) GetUnits() string

func (*LeafSchema) ProtoMessage 

func (*LeafSchema) ProtoMessage()

func (*LeafSchema) ProtoReflect 

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

func (*LeafSchema) Reset 

func (x *LeafSchema) Reset()

func (*LeafSchema) String 

func (x *LeafSchema) String() string

type ListDataStoreRequest 

type ListDataStoreRequest struct {
	// contains filtered or unexported fields
}

DS

func (*ListDataStoreRequest) Descriptor deprecated 

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

Deprecated: Use ListDataStoreRequest.ProtoReflect.Descriptor instead.

func (*ListDataStoreRequest) ProtoMessage 

func (*ListDataStoreRequest) ProtoMessage()

func (*ListDataStoreRequest) ProtoReflect 

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

func (*ListDataStoreRequest) Reset 

func (x *ListDataStoreRequest) Reset()

func (*ListDataStoreRequest) String 

func (x *ListDataStoreRequest) String() string

type ListDataStoreResponse 

type ListDataStoreResponse struct {
	Datastores []*GetDataStoreResponse `protobuf:"bytes,1,rep,name=datastores,proto3" json:"datastores,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDataStoreResponse) Descriptor deprecated 

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

Deprecated: Use ListDataStoreResponse.ProtoReflect.Descriptor instead.

func (*ListDataStoreResponse) GetDatastores 

func (x *ListDataStoreResponse) GetDatastores() []*GetDataStoreResponse

func (*ListDataStoreResponse) ProtoMessage 

func (*ListDataStoreResponse) ProtoMessage()

func (*ListDataStoreResponse) ProtoReflect 

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

func (*ListDataStoreResponse) Reset 

func (x *ListDataStoreResponse) Reset()

func (*ListDataStoreResponse) String 

func (x *ListDataStoreResponse) String() string

type ListIntentRequest 

type ListIntentRequest struct {

	// datastore name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*ListIntentRequest) Descriptor deprecated 

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

Deprecated: Use ListIntentRequest.ProtoReflect.Descriptor instead.

func (*ListIntentRequest) GetName 

func (x *ListIntentRequest) GetName() string

func (*ListIntentRequest) ProtoMessage 

func (*ListIntentRequest) ProtoMessage()

func (*ListIntentRequest) ProtoReflect 

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

func (*ListIntentRequest) Reset 

func (x *ListIntentRequest) Reset()

func (*ListIntentRequest) String 

func (x *ListIntentRequest) String() string

type ListIntentResponse 

type ListIntentResponse struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// list of intents without updates
	Intent []*Intent `protobuf:"bytes,2,rep,name=intent,proto3" json:"intent,omitempty"`
	// contains filtered or unexported fields
}

func (*ListIntentResponse) Descriptor deprecated 

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

Deprecated: Use ListIntentResponse.ProtoReflect.Descriptor instead.

func (*ListIntentResponse) GetIntent 

func (x *ListIntentResponse) GetIntent() []*Intent

func (*ListIntentResponse) GetName 

func (x *ListIntentResponse) GetName() string

func (*ListIntentResponse) ProtoMessage 

func (*ListIntentResponse) ProtoMessage()

func (*ListIntentResponse) ProtoReflect 

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

func (*ListIntentResponse) Reset 

func (x *ListIntentResponse) Reset()

func (*ListIntentResponse) String 

func (x *ListIntentResponse) String() string

type ListSchemaRequest 

type ListSchemaRequest struct {
	// contains filtered or unexported fields
}

func (*ListSchemaRequest) Descriptor deprecated 

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

Deprecated: Use ListSchemaRequest.ProtoReflect.Descriptor instead.

func (*ListSchemaRequest) ProtoMessage 

func (*ListSchemaRequest) ProtoMessage()

func (*ListSchemaRequest) ProtoReflect 

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

func (*ListSchemaRequest) Reset 

func (x *ListSchemaRequest) Reset()

func (*ListSchemaRequest) String 

func (x *ListSchemaRequest) String() string

type ListSchemaResponse 

type ListSchemaResponse struct {
	Schema []*Schema `protobuf:"bytes,1,rep,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSchemaResponse) Descriptor deprecated 

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

Deprecated: Use ListSchemaResponse.ProtoReflect.Descriptor instead.

func (*ListSchemaResponse) GetSchema 

func (x *ListSchemaResponse) GetSchema() []*Schema

func (*ListSchemaResponse) ProtoMessage 

func (*ListSchemaResponse) ProtoMessage()

func (*ListSchemaResponse) ProtoReflect 

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

func (*ListSchemaResponse) Reset 

func (x *ListSchemaResponse) Reset()

func (*ListSchemaResponse) String 

func (x *ListSchemaResponse) String() string

type MandatoryChild added in v0.0.36 

type MandatoryChild struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	IsState bool   `protobuf:"varint,2,opt,name=is_state,json=isState,proto3" json:"is_state,omitempty"`
	// contains filtered or unexported fields
}

func (*MandatoryChild) Descriptor deprecated added in v0.0.36 

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

Deprecated: Use MandatoryChild.ProtoReflect.Descriptor instead.

func (*MandatoryChild) GetIsState added in v0.0.36 

func (x *MandatoryChild) GetIsState() bool

func (*MandatoryChild) GetName added in v0.0.36 

func (x *MandatoryChild) GetName() string

func (*MandatoryChild) ProtoMessage added in v0.0.36 

func (*MandatoryChild) ProtoMessage()

func (*MandatoryChild) ProtoReflect added in v0.0.36 

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

func (*MandatoryChild) Reset added in v0.0.36 

func (x *MandatoryChild) Reset()

func (*MandatoryChild) String added in v0.0.36 

func (x *MandatoryChild) String() string

type MustStatement 

type MustStatement struct {
	Statement string `protobuf:"bytes,1,opt,name=statement,proto3" json:"statement,omitempty"`
	Error     string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*MustStatement) Descriptor deprecated 

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

Deprecated: Use MustStatement.ProtoReflect.Descriptor instead.

func (*MustStatement) GetError 

func (x *MustStatement) GetError() string

func (*MustStatement) GetStatement 

func (x *MustStatement) GetStatement() string

func (*MustStatement) ProtoMessage 

func (*MustStatement) ProtoMessage()

func (*MustStatement) ProtoReflect 

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

func (*MustStatement) Reset 

func (x *MustStatement) Reset()

func (*MustStatement) String 

func (x *MustStatement) String() string

type NetconfOptions added in v0.0.33 

type NetconfOptions struct {

	// for netconf targets:
	// include namespace if a prefix is present
	// in the path elements.
	IncludeNs bool `protobuf:"varint,5,opt,name=include_ns,json=includeNs,proto3" json:"include_ns,omitempty"`
	// for netconf targets:
	// add base1.0 as ns for operation attribute.
	OperationWithNs bool `protobuf:"varint,6,opt,name=operation_with_ns,json=operationWithNs,proto3" json:"operation_with_ns,omitempty"`
	// for netconf targets:
	// use operation remove instead of delete when deleting.
	UseOperationRemove bool `protobuf:"varint,7,opt,name=use_operation_remove,json=useOperationRemove,proto3" json:"use_operation_remove,omitempty"`
	// for netconf type, specifies which datastore to commit.
	// Can be either `candidate` or `running`.
	CommitCandidate CommitCandidate `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NetconfOptions) Descriptor deprecated added in v0.0.33 

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

Deprecated: Use NetconfOptions.ProtoReflect.Descriptor instead.

func (*NetconfOptions) GetCommitCandidate added in v0.0.33 

func (x *NetconfOptions) GetCommitCandidate() CommitCandidate

func (*NetconfOptions) GetIncludeNs added in v0.0.33 

func (x *NetconfOptions) GetIncludeNs() bool

func (*NetconfOptions) GetOperationWithNs added in v0.0.33 

func (x *NetconfOptions) GetOperationWithNs() bool

func (*NetconfOptions) GetUseOperationRemove added in v0.0.33 

func (x *NetconfOptions) GetUseOperationRemove() bool

func (*NetconfOptions) ProtoMessage added in v0.0.33 

func (*NetconfOptions) ProtoMessage()

func (*NetconfOptions) ProtoReflect added in v0.0.33 

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

func (*NetconfOptions) Reset added in v0.0.33 

func (x *NetconfOptions) Reset()

func (*NetconfOptions) String added in v0.0.33 

func (x *NetconfOptions) String() string

type Notification 

type Notification struct {

	// Timestamp in nanoseconds since Epoch.
	Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Data elements that have changed values.
	Update []*Update `protobuf:"bytes,4,rep,name=update,proto3" json:"update,omitempty"`
	// Data elements that have been deleted.
	Delete []*Path `protobuf:"bytes,5,rep,name=delete,proto3" json:"delete,omitempty"`
	// contains filtered or unexported fields
}

func (*Notification) Descriptor deprecated 

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

Deprecated: Use Notification.ProtoReflect.Descriptor instead.

func (*Notification) GetDelete 

func (x *Notification) GetDelete() []*Path

func (*Notification) GetTimestamp 

func (x *Notification) GetTimestamp() int64

func (*Notification) GetUpdate 

func (x *Notification) GetUpdate() []*Update

func (*Notification) ProtoMessage 

func (*Notification) ProtoMessage()

func (*Notification) ProtoReflect 

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

func (*Notification) Reset 

func (x *Notification) Reset()

func (*Notification) String 

func (x *Notification) String() string

type Number added in v0.0.27 

type Number struct {
	Value    uint64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	Negative bool   `protobuf:"varint,2,opt,name=negative,proto3" json:"negative,omitempty"`
	// contains filtered or unexported fields
}

func (*Number) Descriptor deprecated added in v0.0.27 

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

Deprecated: Use Number.ProtoReflect.Descriptor instead.

func (*Number) GetNegative added in v0.0.27 

func (x *Number) GetNegative() bool

func (*Number) GetValue added in v0.0.27 

func (x *Number) GetValue() uint64

func (*Number) ProtoMessage added in v0.0.27 

func (*Number) ProtoMessage()

func (*Number) ProtoReflect added in v0.0.27 

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

func (*Number) Reset added in v0.0.27 

func (x *Number) Reset()

func (*Number) String added in v0.0.27 

func (x *Number) String() string

type Path 

type Path struct {
	Origin string      `protobuf:"bytes,2,opt,name=origin,proto3" json:"origin,omitempty"`
	Elem   []*PathElem `protobuf:"bytes,3,rep,name=elem,proto3" json:"elem,omitempty"`
	Target string      `protobuf:"bytes,4,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

func (*Path) Descriptor deprecated 

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

Deprecated: Use Path.ProtoReflect.Descriptor instead.

func (*Path) GetElem 

func (x *Path) GetElem() []*PathElem

func (*Path) GetOrigin 

func (x *Path) GetOrigin() string

func (*Path) GetTarget 

func (x *Path) GetTarget() string

func (*Path) ProtoMessage 

func (*Path) ProtoMessage()

func (*Path) ProtoReflect 

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

func (*Path) Reset 

func (x *Path) Reset()

func (*Path) String 

func (x *Path) String() string

type PathElem 

type PathElem struct {

	// The name of the element in the path.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Map of key (attribute) name to value.
	Key map[string]string `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PathElem) Descriptor deprecated 

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

Deprecated: Use PathElem.ProtoReflect.Descriptor instead.

func (*PathElem) GetKey 

func (x *PathElem) GetKey() map[string]string

func (*PathElem) GetName 

func (x *PathElem) GetName() string

func (*PathElem) ProtoMessage 

func (*PathElem) ProtoMessage()

func (*PathElem) ProtoReflect 

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

func (*PathElem) Reset 

func (x *PathElem) Reset()

func (*PathElem) String 

func (x *PathElem) String() string

type RebaseRequest 

type RebaseRequest struct {

	// datastore name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// candidate name
	Datastore *DataStore `protobuf:"bytes,2,opt,name=datastore,proto3" json:"datastore,omitempty"`
	// contains filtered or unexported fields
}

func (*RebaseRequest) Descriptor deprecated 

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

Deprecated: Use RebaseRequest.ProtoReflect.Descriptor instead.

func (*RebaseRequest) GetDatastore 

func (x *RebaseRequest) GetDatastore() *DataStore

func (*RebaseRequest) GetName 

func (x *RebaseRequest) GetName() string

func (*RebaseRequest) ProtoMessage 

func (*RebaseRequest) ProtoMessage()

func (*RebaseRequest) ProtoReflect 

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

func (*RebaseRequest) Reset 

func (x *RebaseRequest) Reset()

func (*RebaseRequest) String 

func (x *RebaseRequest) String() string

type RebaseResponse 

type RebaseResponse struct {
	// contains filtered or unexported fields
}

func (*RebaseResponse) Descriptor deprecated 

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

Deprecated: Use RebaseResponse.ProtoReflect.Descriptor instead.

func (*RebaseResponse) ProtoMessage 

func (*RebaseResponse) ProtoMessage()

func (*RebaseResponse) ProtoReflect 

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

func (*RebaseResponse) Reset 

func (x *RebaseResponse) Reset()

func (*RebaseResponse) String 

func (x *RebaseResponse) String() string

type ReloadSchemaRequest 

type ReloadSchemaRequest struct {
	Schema *Schema `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*ReloadSchemaRequest) Descriptor deprecated 

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

Deprecated: Use ReloadSchemaRequest.ProtoReflect.Descriptor instead.

func (*ReloadSchemaRequest) GetSchema 

func (x *ReloadSchemaRequest) GetSchema() *Schema

func (*ReloadSchemaRequest) ProtoMessage 

func (*ReloadSchemaRequest) ProtoMessage()

func (*ReloadSchemaRequest) ProtoReflect 

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

func (*ReloadSchemaRequest) Reset 

func (x *ReloadSchemaRequest) Reset()

func (*ReloadSchemaRequest) String 

func (x *ReloadSchemaRequest) String() string

type ReloadSchemaResponse 

type ReloadSchemaResponse struct {
	// contains filtered or unexported fields
}

func (*ReloadSchemaResponse) Descriptor deprecated 

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

Deprecated: Use ReloadSchemaResponse.ProtoReflect.Descriptor instead.

func (*ReloadSchemaResponse) ProtoMessage 

func (*ReloadSchemaResponse) ProtoMessage()

func (*ReloadSchemaResponse) ProtoReflect 

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

func (*ReloadSchemaResponse) Reset 

func (x *ReloadSchemaResponse) Reset()

func (*ReloadSchemaResponse) String 

func (x *ReloadSchemaResponse) String() string

type ScalarArray 

type ScalarArray struct {

	// The set of elements within the array. Each TypedValue message should
	// specify only elements that have a field identifier of 1-7 (i.e., the
	// values are scalar values).
	Element []*TypedValue `protobuf:"bytes,1,rep,name=element,proto3" json:"element,omitempty"`
	// contains filtered or unexported fields
}

ScalarArray is used to encode a mixed-type array of values.

func (*ScalarArray) Descriptor deprecated 

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

Deprecated: Use ScalarArray.ProtoReflect.Descriptor instead.

func (*ScalarArray) GetElement 

func (x *ScalarArray) GetElement() []*TypedValue

func (*ScalarArray) ProtoMessage 

func (*ScalarArray) ProtoMessage()

func (*ScalarArray) ProtoReflect 

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

func (*ScalarArray) Reset 

func (x *ScalarArray) Reset()

func (*ScalarArray) String 

func (x *ScalarArray) String() string

type Schema 

type Schema struct {

	// string type = 1;
	Name    string       `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Vendor  string       `protobuf:"bytes,3,opt,name=vendor,proto3" json:"vendor,omitempty"`
	Version string       `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	Status  SchemaStatus `protobuf:"varint,5,opt,name=status,proto3,enum=schema.SchemaStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*Schema) Descriptor deprecated 

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

Deprecated: Use Schema.ProtoReflect.Descriptor instead.

func (*Schema) GetName 

func (x *Schema) GetName() string

func (*Schema) GetStatus 

func (x *Schema) GetStatus() SchemaStatus

func (*Schema) GetVendor 

func (x *Schema) GetVendor() string

func (*Schema) GetVersion 

func (x *Schema) GetVersion() string

func (*Schema) ProtoMessage 

func (*Schema) ProtoMessage()

func (*Schema) ProtoReflect 

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

func (*Schema) Reset 

func (x *Schema) Reset()

func (*Schema) String 

func (x *Schema) String() string

type SchemaElem 

type SchemaElem struct {

	// Types that are assignable to Schema:
	//
	//	*SchemaElem_Container
	//	*SchemaElem_Field
	//	*SchemaElem_Leaflist
	Schema isSchemaElem_Schema `protobuf_oneof:"schema"`
	// contains filtered or unexported fields
}

func (*SchemaElem) Descriptor deprecated 

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

Deprecated: Use SchemaElem.ProtoReflect.Descriptor instead.

func (*SchemaElem) GetContainer 

func (x *SchemaElem) GetContainer() *ContainerSchema

func (*SchemaElem) GetField 

func (x *SchemaElem) GetField() *LeafSchema

func (*SchemaElem) GetLeaflist 

func (x *SchemaElem) GetLeaflist() *LeafListSchema

func (*SchemaElem) GetSchema 

func (m *SchemaElem) GetSchema() isSchemaElem_Schema

func (*SchemaElem) ProtoMessage 

func (*SchemaElem) ProtoMessage()

func (*SchemaElem) ProtoReflect 

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

func (*SchemaElem) Reset 

func (x *SchemaElem) Reset()

func (*SchemaElem) String 

func (x *SchemaElem) String() string

type SchemaElem_Container 

type SchemaElem_Container struct {
	Container *ContainerSchema `protobuf:"bytes,1,opt,name=container,proto3,oneof"`
}

type SchemaElem_Field 

type SchemaElem_Field struct {
	Field *LeafSchema `protobuf:"bytes,2,opt,name=field,proto3,oneof"`
}

type SchemaElem_Leaflist 

type SchemaElem_Leaflist struct {
	Leaflist *LeafListSchema `protobuf:"bytes,3,opt,name=leaflist,proto3,oneof"`
}

type SchemaLeafType 

type SchemaLeafType struct {
	Type                string              `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Range               []*SchemaMinMaxType `protobuf:"bytes,2,rep,name=range,proto3" json:"range,omitempty"`
	Length              []*SchemaMinMaxType `protobuf:"bytes,3,rep,name=length,proto3" json:"length,omitempty"`
	EnumNames           []string            `protobuf:"bytes,4,rep,name=enum_names,json=enumNames,proto3" json:"enum_names,omitempty"`
	Units               string              `protobuf:"bytes,5,opt,name=units,proto3" json:"units,omitempty"`
	TypeName            string              `protobuf:"bytes,6,opt,name=type_name,json=typeName,proto3" json:"type_name,omitempty"`
	Leafref             string              `protobuf:"bytes,7,opt,name=leafref,proto3" json:"leafref,omitempty"`
	Patterns            []*SchemaPattern    `protobuf:"bytes,9,rep,name=patterns,proto3" json:"patterns,omitempty"`
	UnionTypes          []*SchemaLeafType   `protobuf:"bytes,10,rep,name=union_types,json=unionTypes,proto3" json:"union_types,omitempty"`
	IdentityPrefixesMap map[string]string   `` /* 209-byte string literal not displayed */
	ModulePrefixMap     map[string]string   `` /* 197-byte string literal not displayed */
	LeafrefTargetType   *SchemaLeafType     `protobuf:"bytes,13,opt,name=leafref_target_type,json=leafrefTargetType,proto3" json:"leafref_target_type,omitempty"`
	// contains filtered or unexported fields
}

func (*SchemaLeafType) Descriptor deprecated 

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

Deprecated: Use SchemaLeafType.ProtoReflect.Descriptor instead.

func (*SchemaLeafType) GetEnumNames added in v0.0.31 

func (x *SchemaLeafType) GetEnumNames() []string

func (*SchemaLeafType) GetIdentityPrefixesMap added in v0.0.31 

func (x *SchemaLeafType) GetIdentityPrefixesMap() map[string]string

func (*SchemaLeafType) GetLeafref 

func (x *SchemaLeafType) GetLeafref() string

func (*SchemaLeafType) GetLeafrefTargetType added in v0.0.35 

func (x *SchemaLeafType) GetLeafrefTargetType() *SchemaLeafType

func (*SchemaLeafType) GetLength 

func (x *SchemaLeafType) GetLength() []*SchemaMinMaxType

func (*SchemaLeafType) GetModulePrefixMap added in v0.0.33 

func (x *SchemaLeafType) GetModulePrefixMap() map[string]string

func (*SchemaLeafType) GetPatterns 

func (x *SchemaLeafType) GetPatterns() []*SchemaPattern

func (*SchemaLeafType) GetRange 

func (x *SchemaLeafType) GetRange() []*SchemaMinMaxType

func (*SchemaLeafType) GetType 

func (x *SchemaLeafType) GetType() string

func (*SchemaLeafType) GetTypeName 

func (x *SchemaLeafType) GetTypeName() string

func (*SchemaLeafType) GetUnionTypes 

func (x *SchemaLeafType) GetUnionTypes() []*SchemaLeafType

func (*SchemaLeafType) GetUnits 

func (x *SchemaLeafType) GetUnits() string

func (*SchemaLeafType) ProtoMessage 

func (*SchemaLeafType) ProtoMessage()

func (*SchemaLeafType) ProtoReflect 

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

func (*SchemaLeafType) Reset 

func (x *SchemaLeafType) Reset()

func (*SchemaLeafType) String 

func (x *SchemaLeafType) String() string

type SchemaMinMaxType added in v0.0.27 

type SchemaMinMaxType struct {
	Min *Number `protobuf:"bytes,1,opt,name=min,proto3" json:"min,omitempty"`
	Max *Number `protobuf:"bytes,2,opt,name=max,proto3" json:"max,omitempty"`
	// contains filtered or unexported fields
}

func (*SchemaMinMaxType) Descriptor deprecated added in v0.0.27 

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

Deprecated: Use SchemaMinMaxType.ProtoReflect.Descriptor instead.

func (*SchemaMinMaxType) GetMax added in v0.0.27 

func (x *SchemaMinMaxType) GetMax() *Number

func (*SchemaMinMaxType) GetMin added in v0.0.27 

func (x *SchemaMinMaxType) GetMin() *Number

func (*SchemaMinMaxType) ProtoMessage added in v0.0.27 

func (*SchemaMinMaxType) ProtoMessage()

func (*SchemaMinMaxType) ProtoReflect added in v0.0.27 

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

func (*SchemaMinMaxType) Reset added in v0.0.27 

func (x *SchemaMinMaxType) Reset()

func (*SchemaMinMaxType) String added in v0.0.27 

func (x *SchemaMinMaxType) String() string

type SchemaPattern 

type SchemaPattern struct {
	Pattern  string `protobuf:"bytes,1,opt,name=pattern,proto3" json:"pattern,omitempty"`
	Inverted bool   `protobuf:"varint,2,opt,name=inverted,proto3" json:"inverted,omitempty"`
	// contains filtered or unexported fields
}

func (*SchemaPattern) Descriptor deprecated 

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

Deprecated: Use SchemaPattern.ProtoReflect.Descriptor instead.

func (*SchemaPattern) GetInverted 

func (x *SchemaPattern) GetInverted() bool

func (*SchemaPattern) GetPattern 

func (x *SchemaPattern) GetPattern() string

func (*SchemaPattern) ProtoMessage 

func (*SchemaPattern) ProtoMessage()

func (*SchemaPattern) ProtoReflect 

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

func (*SchemaPattern) Reset 

func (x *SchemaPattern) Reset()

func (*SchemaPattern) String 

func (x *SchemaPattern) String() string

type SchemaServerClient 

type SchemaServerClient interface {
	// returns schema name, vendor, version, and files path(s)
	GetSchemaDetails(ctx context.Context, in *GetSchemaDetailsRequest, opts ...grpc.CallOption) (*GetSchemaDetailsResponse, error)
	// lists known schemas with name, vendor, version and status
	ListSchema(ctx context.Context, in *ListSchemaRequest, opts ...grpc.CallOption) (*ListSchemaResponse, error)
	// returns the schema of an item identified by a gNMI-like path
	GetSchema(ctx context.Context, in *GetSchemaRequest, opts ...grpc.CallOption) (*GetSchemaResponse, error)
	// creates a schema
	CreateSchema(ctx context.Context, in *CreateSchemaRequest, opts ...grpc.CallOption) (*CreateSchemaResponse, error)
	// trigger schema reload
	ReloadSchema(ctx context.Context, in *ReloadSchemaRequest, opts ...grpc.CallOption) (*ReloadSchemaResponse, error)
	// delete a schema
	DeleteSchema(ctx context.Context, in *DeleteSchemaRequest, opts ...grpc.CallOption) (*DeleteSchemaResponse, error)
	// client stream RPC to upload yang files to the server:
	// - uses CreateSchema as a first message
	// - then N intermediate UploadSchemaFile, initial, bytes, hash for each file
	// - and ends with an UploadSchemaFinalize{}
	UploadSchema(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[UploadSchemaRequest, UploadSchemaResponse], error)
	// ToPath converts a list of items into a schema.proto.Path
	ToPath(ctx context.Context, in *ToPathRequest, opts ...grpc.CallOption) (*ToPathResponse, error)
	// ExpandPath returns a list of sub paths given a single path
	ExpandPath(ctx context.Context, in *ExpandPathRequest, opts ...grpc.CallOption) (*ExpandPathResponse, error)
	// GetSchemaElements returns the schema of each path element
	GetSchemaElements(ctx context.Context, in *GetSchemaRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetSchemaResponse], error)
}

SchemaServerClient is the client API for SchemaServer 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 NewSchemaServerClient 

func NewSchemaServerClient(cc grpc.ClientConnInterface) SchemaServerClient

type SchemaServerServer 

type SchemaServerServer interface {
	// returns schema name, vendor, version, and files path(s)
	GetSchemaDetails(context.Context, *GetSchemaDetailsRequest) (*GetSchemaDetailsResponse, error)
	// lists known schemas with name, vendor, version and status
	ListSchema(context.Context, *ListSchemaRequest) (*ListSchemaResponse, error)
	// returns the schema of an item identified by a gNMI-like path
	GetSchema(context.Context, *GetSchemaRequest) (*GetSchemaResponse, error)
	// creates a schema
	CreateSchema(context.Context, *CreateSchemaRequest) (*CreateSchemaResponse, error)
	// trigger schema reload
	ReloadSchema(context.Context, *ReloadSchemaRequest) (*ReloadSchemaResponse, error)
	// delete a schema
	DeleteSchema(context.Context, *DeleteSchemaRequest) (*DeleteSchemaResponse, error)
	// client stream RPC to upload yang files to the server:
	// - uses CreateSchema as a first message
	// - then N intermediate UploadSchemaFile, initial, bytes, hash for each file
	// - and ends with an UploadSchemaFinalize{}
	UploadSchema(grpc.ClientStreamingServer[UploadSchemaRequest, UploadSchemaResponse]) error
	// ToPath converts a list of items into a schema.proto.Path
	ToPath(context.Context, *ToPathRequest) (*ToPathResponse, error)
	// ExpandPath returns a list of sub paths given a single path
	ExpandPath(context.Context, *ExpandPathRequest) (*ExpandPathResponse, error)
	// GetSchemaElements returns the schema of each path element
	GetSchemaElements(*GetSchemaRequest, grpc.ServerStreamingServer[GetSchemaResponse]) error
	// contains filtered or unexported methods
}

SchemaServerServer is the server API for SchemaServer service. All implementations must embed UnimplementedSchemaServerServer for forward compatibility.

type SchemaServer_GetSchemaElementsClient 

type SchemaServer_GetSchemaElementsClient = grpc.ServerStreamingClient[GetSchemaResponse]

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

type SchemaServer_GetSchemaElementsServer 

type SchemaServer_GetSchemaElementsServer = grpc.ServerStreamingServer[GetSchemaResponse]

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

type SchemaServer_UploadSchemaClient 

type SchemaServer_UploadSchemaClient = grpc.ClientStreamingClient[UploadSchemaRequest, UploadSchemaResponse]

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

type SchemaServer_UploadSchemaServer 

type SchemaServer_UploadSchemaServer = grpc.ClientStreamingServer[UploadSchemaRequest, UploadSchemaResponse]

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

type SchemaStatus 

type SchemaStatus int32
const (
	SchemaStatus_OK           SchemaStatus = 0 // all good
	SchemaStatus_RELOADING    SchemaStatus = 1 // reloading YANG, should be locked
	SchemaStatus_INITIALIZING SchemaStatus = 2 // initial state after creation
	SchemaStatus_FAILED       SchemaStatus = 3 // chema files parsing failed, yang load failed
)

func (SchemaStatus) Descriptor 

func (SchemaStatus) Descriptor() protoreflect.EnumDescriptor

func (SchemaStatus) Enum 

func (x SchemaStatus) Enum() *SchemaStatus

func (SchemaStatus) EnumDescriptor deprecated 

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

Deprecated: Use SchemaStatus.Descriptor instead.

func (SchemaStatus) Number 

func (x SchemaStatus) Number() protoreflect.EnumNumber

func (SchemaStatus) String 

func (x SchemaStatus) String() string

func (SchemaStatus) Type 

func (SchemaStatus) Type() protoreflect.EnumType

type SetDataRequest 

type SetDataRequest struct {

	// datastore name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// datastore type and name
	Datastore *DataStore `protobuf:"bytes,2,opt,name=datastore,proto3" json:"datastore,omitempty"`
	// list of updates
	Update []*Update `protobuf:"bytes,10,rep,name=update,proto3" json:"update,omitempty"`
	// list of replaces
	Replace []*Update `protobuf:"bytes,11,rep,name=replace,proto3" json:"replace,omitempty"`
	// list of deletes
	Delete []*Path `protobuf:"bytes,12,rep,name=delete,proto3" json:"delete,omitempty"`
	// contains filtered or unexported fields
}

func (*SetDataRequest) Descriptor deprecated 

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

Deprecated: Use SetDataRequest.ProtoReflect.Descriptor instead.

func (*SetDataRequest) GetDatastore 

func (x *SetDataRequest) GetDatastore() *DataStore

func (*SetDataRequest) GetDelete 

func (x *SetDataRequest) GetDelete() []*Path

func (*SetDataRequest) GetName 

func (x *SetDataRequest) GetName() string

func (*SetDataRequest) GetReplace 

func (x *SetDataRequest) GetReplace() []*Update

func (*SetDataRequest) GetUpdate 

func (x *SetDataRequest) GetUpdate() []*Update

func (*SetDataRequest) ProtoMessage 

func (*SetDataRequest) ProtoMessage()

func (*SetDataRequest) ProtoReflect 

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

func (*SetDataRequest) Reset 

func (x *SetDataRequest) Reset()

func (*SetDataRequest) String 

func (x *SetDataRequest) String() string

type SetDataResponse 

type SetDataResponse struct {

	// A set of responses specifying the result of the operations specified in
	// the SetRequest.
	Response []*UpdateResult `protobuf:"bytes,2,rep,name=response,proto3" json:"response,omitempty"`
	// e.g. netconf rpc-errors with severity warning
	Warnings []string `protobuf:"bytes,3,rep,name=warnings,proto3" json:"warnings,omitempty"`
	// Timestamp of transaction (ns since epoch).
	Timestamp int64 `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*SetDataResponse) Descriptor deprecated 

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

Deprecated: Use SetDataResponse.ProtoReflect.Descriptor instead.

func (*SetDataResponse) GetResponse 

func (x *SetDataResponse) GetResponse() []*UpdateResult

func (*SetDataResponse) GetTimestamp 

func (x *SetDataResponse) GetTimestamp() int64

func (*SetDataResponse) GetWarnings added in v0.0.27 

func (x *SetDataResponse) GetWarnings() []string

func (*SetDataResponse) ProtoMessage 

func (*SetDataResponse) ProtoMessage()

func (*SetDataResponse) ProtoReflect 

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

func (*SetDataResponse) Reset 

func (x *SetDataResponse) Reset()

func (*SetDataResponse) String 

func (x *SetDataResponse) String() string

type SetIntentRequest 

type SetIntentRequest struct {

	// datastore name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// intent name
	Intent string `protobuf:"bytes,2,opt,name=intent,proto3" json:"intent,omitempty"`
	// intent priority
	Priority int32 `protobuf:"varint,3,opt,name=priority,proto3" json:"priority,omitempty"`
	// list of updates
	Update []*Update `protobuf:"bytes,4,rep,name=update,proto3" json:"update,omitempty"`
	// delete indicator
	Delete bool `protobuf:"varint,5,opt,name=delete,proto3" json:"delete,omitempty"`
	// dry run indicator
	DryRun bool `protobuf:"varint,6,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"`
	// delete only from intended store
	// basically keeping the config on the device but unmanaged
	OnlyIntended bool `protobuf:"varint,7,opt,name=only_intended,json=onlyIntended,proto3" json:"only_intended,omitempty"`
	// contains filtered or unexported fields
}

func (*SetIntentRequest) Descriptor deprecated 

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

Deprecated: Use SetIntentRequest.ProtoReflect.Descriptor instead.

func (*SetIntentRequest) GetDelete 

func (x *SetIntentRequest) GetDelete() bool

func (*SetIntentRequest) GetDryRun 

func (x *SetIntentRequest) GetDryRun() bool

func (*SetIntentRequest) GetIntent 

func (x *SetIntentRequest) GetIntent() string

func (*SetIntentRequest) GetName 

func (x *SetIntentRequest) GetName() string

func (*SetIntentRequest) GetOnlyIntended added in v0.0.27 

func (x *SetIntentRequest) GetOnlyIntended() bool

func (*SetIntentRequest) GetPriority 

func (x *SetIntentRequest) GetPriority() int32

func (*SetIntentRequest) GetUpdate 

func (x *SetIntentRequest) GetUpdate() []*Update

func (*SetIntentRequest) ProtoMessage 

func (*SetIntentRequest) ProtoMessage()

func (*SetIntentRequest) ProtoReflect 

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

func (*SetIntentRequest) Reset 

func (x *SetIntentRequest) Reset()

func (*SetIntentRequest) String 

func (x *SetIntentRequest) String() string

type SetIntentResponse 

type SetIntentResponse struct {
	Update   []*Update `protobuf:"bytes,1,rep,name=update,proto3" json:"update,omitempty"`
	Delete   []*Path   `protobuf:"bytes,2,rep,name=delete,proto3" json:"delete,omitempty"`
	Warnings []string  `protobuf:"bytes,3,rep,name=warnings,proto3" json:"warnings,omitempty"`
	// contains filtered or unexported fields
}

func (*SetIntentResponse) Descriptor deprecated 

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

Deprecated: Use SetIntentResponse.ProtoReflect.Descriptor instead.

func (*SetIntentResponse) GetDelete 

func (x *SetIntentResponse) GetDelete() []*Path

func (*SetIntentResponse) GetUpdate 

func (x *SetIntentResponse) GetUpdate() []*Update

func (*SetIntentResponse) GetWarnings added in v0.0.27 

func (x *SetIntentResponse) GetWarnings() []string

func (*SetIntentResponse) ProtoMessage 

func (*SetIntentResponse) ProtoMessage()

func (*SetIntentResponse) ProtoReflect 

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

func (*SetIntentResponse) Reset 

func (x *SetIntentResponse) Reset()

func (*SetIntentResponse) String 

func (x *SetIntentResponse) String() string

type SubscribeRequest 

type SubscribeRequest struct {

	// datastore name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// subscriptions list
	Subscription []*Subscription `protobuf:"bytes,2,rep,name=subscription,proto3" json:"subscription,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetName 

func (x *SubscribeRequest) GetName() string

func (*SubscribeRequest) GetSubscription 

func (x *SubscribeRequest) GetSubscription() []*Subscription

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect 

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

func (*SubscribeRequest) Reset 

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (x *SubscribeRequest) String() string

type SubscribeResponse 

type SubscribeResponse struct {

	// Types that are assignable to Response:
	//
	//	*SubscribeResponse_Update
	//	*SubscribeResponse_SyncResponse
	Response isSubscribeResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*SubscribeResponse) Descriptor deprecated 

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

Deprecated: Use SubscribeResponse.ProtoReflect.Descriptor instead.

func (*SubscribeResponse) GetResponse 

func (m *SubscribeResponse) GetResponse() isSubscribeResponse_Response

func (*SubscribeResponse) GetSyncResponse 

func (x *SubscribeResponse) GetSyncResponse() bool

func (*SubscribeResponse) GetUpdate 

func (x *SubscribeResponse) GetUpdate() *Notification

func (*SubscribeResponse) ProtoMessage 

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) ProtoReflect 

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

func (*SubscribeResponse) Reset 

func (x *SubscribeResponse) Reset()

func (*SubscribeResponse) String 

func (x *SubscribeResponse) String() string

type SubscribeResponse_SyncResponse 

type SubscribeResponse_SyncResponse struct {
	SyncResponse bool `protobuf:"varint,3,opt,name=sync_response,json=syncResponse,proto3,oneof"`
}

type SubscribeResponse_Update 

type SubscribeResponse_Update struct {
	Update *Notification `protobuf:"bytes,1,opt,name=update,proto3,oneof"`
}

type Subscription 

type Subscription struct {

	// objects to subscribe to
	Path []*Path `protobuf:"bytes,1,rep,name=path,proto3" json:"path,omitempty"`
	// data type config, state
	DataType DataType `protobuf:"varint,2,opt,name=data_type,json=dataType,proto3,enum=schema.DataType" json:"data_type,omitempty"`
	// sample interval
	SampleInterval uint64 `protobuf:"varint,3,opt,name=sample_interval,json=sampleInterval,proto3" json:"sample_interval,omitempty"`
	// suppress redandant.. this is probably not needed
	SuppressRedundant bool `protobuf:"varint,4,opt,name=suppress_redundant,json=suppressRedundant,proto3" json:"suppress_redundant,omitempty"`
	// contains filtered or unexported fields
}

func (*Subscription) Descriptor deprecated 

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

Deprecated: Use Subscription.ProtoReflect.Descriptor instead.

func (*Subscription) GetDataType 

func (x *Subscription) GetDataType() DataType

func (*Subscription) GetPath 

func (x *Subscription) GetPath() []*Path

func (*Subscription) GetSampleInterval 

func (x *Subscription) GetSampleInterval() uint64

func (*Subscription) GetSuppressRedundant 

func (x *Subscription) GetSuppressRedundant() bool

func (*Subscription) ProtoMessage 

func (*Subscription) ProtoMessage()

func (*Subscription) ProtoReflect 

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

func (*Subscription) Reset 

func (x *Subscription) Reset()

func (*Subscription) String 

func (x *Subscription) String() string

type Sync 

type Sync struct {

	// if true, all received notifications
	// are validated agains the schema
	Validate bool `protobuf:"varint,1,opt,name=validate,proto3" json:"validate,omitempty"`
	// number of notification to buffer while writing
	// to cache
	Buffer int64 `protobuf:"varint,2,opt,name=buffer,proto3" json:"buffer,omitempty"`
	// number of cache writers
	WriteWorkers int64 `protobuf:"varint,3,opt,name=write_workers,json=writeWorkers,proto3" json:"write_workers,omitempty"`
	// list of sync strategies
	Config []*SyncConfig `protobuf:"bytes,4,rep,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*Sync) Descriptor deprecated 

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

Deprecated: Use Sync.ProtoReflect.Descriptor instead.

func (*Sync) GetBuffer 

func (x *Sync) GetBuffer() int64

func (*Sync) GetConfig 

func (x *Sync) GetConfig() []*SyncConfig

func (*Sync) GetValidate 

func (x *Sync) GetValidate() bool

func (*Sync) GetWriteWorkers 

func (x *Sync) GetWriteWorkers() int64

func (*Sync) ProtoMessage 

func (*Sync) ProtoMessage()

func (*Sync) ProtoReflect 

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

func (*Sync) Reset 

func (x *Sync) Reset()

func (*Sync) String 

func (x *Sync) String() string

type SyncConfig 

type SyncConfig struct {

	// sync routing name
	Name   string  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Target *Target `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	// paths to subscribe to
	Path []string `protobuf:"bytes,3,rep,name=path,proto3" json:"path,omitempty"`
	// gnmi only: mode, on-change, sample, or once
	Mode SyncMode `protobuf:"varint,4,opt,name=mode,proto3,enum=data.SyncMode" json:"mode,omitempty"`
	// interval for gNMI mode sample or once
	// as well for netconf
	Interval uint64 `protobuf:"varint,5,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncConfig) Descriptor deprecated 

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

Deprecated: Use SyncConfig.ProtoReflect.Descriptor instead.

func (*SyncConfig) GetInterval 

func (x *SyncConfig) GetInterval() uint64

func (*SyncConfig) GetMode 

func (x *SyncConfig) GetMode() SyncMode

func (*SyncConfig) GetName 

func (x *SyncConfig) GetName() string

func (*SyncConfig) GetPath 

func (x *SyncConfig) GetPath() []string

func (*SyncConfig) GetTarget added in v0.0.33 

func (x *SyncConfig) GetTarget() *Target

func (*SyncConfig) ProtoMessage 

func (*SyncConfig) ProtoMessage()

func (*SyncConfig) ProtoReflect 

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

func (*SyncConfig) Reset 

func (x *SyncConfig) Reset()

func (*SyncConfig) String 

func (x *SyncConfig) String() string

type SyncMode 

type SyncMode int32
const (
	SyncMode_SM_ON_CHANGE SyncMode = 0
	SyncMode_SM_SAMPLE    SyncMode = 1
	SyncMode_SM_ONCE      SyncMode = 2
	SyncMode_SM_GET       SyncMode = 3
)

func (SyncMode) Descriptor 

func (SyncMode) Descriptor() protoreflect.EnumDescriptor

func (SyncMode) Enum 

func (x SyncMode) Enum() *SyncMode

func (SyncMode) EnumDescriptor deprecated 

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

Deprecated: Use SyncMode.Descriptor instead.

func (SyncMode) Number 

func (x SyncMode) Number() protoreflect.EnumNumber

func (SyncMode) String 

func (x SyncMode) String() string

func (SyncMode) Type 

func (SyncMode) Type() protoreflect.EnumType

type TLS 

type TLS struct {
	Ca         string `protobuf:"bytes,1,opt,name=ca,proto3" json:"ca,omitempty"`
	Cert       string `protobuf:"bytes,2,opt,name=cert,proto3" json:"cert,omitempty"`
	Key        string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	SkipVerify bool   `protobuf:"varint,4,opt,name=skip_verify,json=skipVerify,proto3" json:"skip_verify,omitempty"`
	// contains filtered or unexported fields
}

TLS Config

func (*TLS) Descriptor deprecated 

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

Deprecated: Use TLS.ProtoReflect.Descriptor instead.

func (*TLS) GetCa 

func (x *TLS) GetCa() string

func (*TLS) GetCert 

func (x *TLS) GetCert() string

func (*TLS) GetKey 

func (x *TLS) GetKey() string

func (*TLS) GetSkipVerify 

func (x *TLS) GetSkipVerify() bool

func (*TLS) ProtoMessage 

func (*TLS) ProtoMessage()

func (*TLS) ProtoReflect 

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

func (*TLS) Reset 

func (x *TLS) Reset()

func (*TLS) String 

func (x *TLS) String() string

type Target 

type Target struct {

	// target type: gnmi or netconf
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// target address
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// per protocol ports
	Port uint32 `protobuf:"varint,12,opt,name=port,proto3" json:"port,omitempty"`
	// tls client certs, ca cert or skip_verify
	Tls *TLS `protobuf:"bytes,3,opt,name=tls,proto3" json:"tls,omitempty"`
	// target credentials
	Credentials *Credentials `protobuf:"bytes,4,opt,name=credentials,proto3" json:"credentials,omitempty"`
	// protocol options
	//
	// Types that are assignable to ProtocolOptions:
	//
	//	*Target_GnmiOpts
	//	*Target_NetconfOpts
	ProtocolOptions isTarget_ProtocolOptions `protobuf_oneof:"protocolOptions"`
	// reflects the target connection status
	Status TargetStatus `protobuf:"varint,9,opt,name=status,proto3,enum=data.TargetStatus" json:"status,omitempty"`
	// if the status is NOT_CONNECTED, this fields might
	// more details about the reason.
	StatusDetails string `protobuf:"bytes,10,opt,name=status_details,json=statusDetails,proto3" json:"status_details,omitempty"`
	// contains filtered or unexported fields
}

Southbound interface of the datastore

func (*Target) Descriptor deprecated 

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

Deprecated: Use Target.ProtoReflect.Descriptor instead.

func (*Target) GetAddress 

func (x *Target) GetAddress() string

func (*Target) GetCredentials 

func (x *Target) GetCredentials() *Credentials

func (*Target) GetGnmiOpts added in v0.0.33 

func (x *Target) GetGnmiOpts() *GnmiOptions

func (*Target) GetNetconfOpts added in v0.0.33 

func (x *Target) GetNetconfOpts() *NetconfOptions

func (*Target) GetPort added in v0.0.33 

func (x *Target) GetPort() uint32

func (*Target) GetProtocolOptions added in v0.0.33 

func (m *Target) GetProtocolOptions() isTarget_ProtocolOptions

func (*Target) GetStatus 

func (x *Target) GetStatus() TargetStatus

func (*Target) GetStatusDetails 

func (x *Target) GetStatusDetails() string

func (*Target) GetTls 

func (x *Target) GetTls() *TLS

func (*Target) GetType 

func (x *Target) GetType() string

func (*Target) ProtoMessage 

func (*Target) ProtoMessage()

func (*Target) ProtoReflect 

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

func (*Target) Reset 

func (x *Target) Reset()

func (*Target) String 

func (x *Target) String() string

type TargetStatus 

type TargetStatus int32
const (
	TargetStatus_UNKNOWN       TargetStatus = 0
	TargetStatus_CONNECTED     TargetStatus = 1
	TargetStatus_NOT_CONNECTED TargetStatus = 2
)

func (TargetStatus) Descriptor 

func (TargetStatus) Descriptor() protoreflect.EnumDescriptor

func (TargetStatus) Enum 

func (x TargetStatus) Enum() *TargetStatus

func (TargetStatus) EnumDescriptor deprecated 

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

Deprecated: Use TargetStatus.Descriptor instead.

func (TargetStatus) Number 

func (x TargetStatus) Number() protoreflect.EnumNumber

func (TargetStatus) String 

func (x TargetStatus) String() string

func (TargetStatus) Type 

func (TargetStatus) Type() protoreflect.EnumType

type Target_GnmiOpts added in v0.0.33 

type Target_GnmiOpts struct {
	GnmiOpts *GnmiOptions `protobuf:"bytes,5,opt,name=gnmi_opts,json=gnmiOpts,proto3,oneof"`
}

type Target_NetconfOpts added in v0.0.33 

type Target_NetconfOpts struct {
	NetconfOpts *NetconfOptions `protobuf:"bytes,6,opt,name=netconf_opts,json=netconfOpts,proto3,oneof"`
}

type ToPathRequest 

type ToPathRequest struct {
	PathElement []string `protobuf:"bytes,1,rep,name=path_element,json=pathElement,proto3" json:"path_element,omitempty"`
	Schema      *Schema  `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*ToPathRequest) Descriptor deprecated 

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

Deprecated: Use ToPathRequest.ProtoReflect.Descriptor instead.

func (*ToPathRequest) GetPathElement 

func (x *ToPathRequest) GetPathElement() []string

func (*ToPathRequest) GetSchema 

func (x *ToPathRequest) GetSchema() *Schema

func (*ToPathRequest) ProtoMessage 

func (*ToPathRequest) ProtoMessage()

func (*ToPathRequest) ProtoReflect 

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

func (*ToPathRequest) Reset 

func (x *ToPathRequest) Reset()

func (*ToPathRequest) String 

func (x *ToPathRequest) String() string

type ToPathResponse 

type ToPathResponse struct {
	Path *Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*ToPathResponse) Descriptor deprecated 

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

Deprecated: Use ToPathResponse.ProtoReflect.Descriptor instead.

func (*ToPathResponse) GetPath 

func (x *ToPathResponse) GetPath() *Path

func (*ToPathResponse) ProtoMessage 

func (*ToPathResponse) ProtoMessage()

func (*ToPathResponse) ProtoReflect 

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

func (*ToPathResponse) Reset 

func (x *ToPathResponse) Reset()

func (*ToPathResponse) String 

func (x *ToPathResponse) String() string

type Type 

type Type int32
const (
	Type_MAIN      Type = 0
	Type_CANDIDATE Type = 1
	Type_INTENDED  Type = 2
)

func (Type) Descriptor 

func (Type) Descriptor() protoreflect.EnumDescriptor

func (Type) Enum 

func (x Type) Enum() *Type

func (Type) EnumDescriptor deprecated 

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

Deprecated: Use Type.Descriptor instead.

func (Type) Number 

func (x Type) Number() protoreflect.EnumNumber

func (Type) String 

func (x Type) String() string

func (Type) Type 

func (Type) Type() protoreflect.EnumType

type TypedValue 

type TypedValue struct {
	Timestamp uint64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Types that are assignable to Value:
	//
	//	*TypedValue_StringVal
	//	*TypedValue_IntVal
	//	*TypedValue_UintVal
	//	*TypedValue_BoolVal
	//	*TypedValue_BytesVal
	//	*TypedValue_FloatVal
	//	*TypedValue_DecimalVal
	//	*TypedValue_DoubleVal
	//	*TypedValue_LeaflistVal
	//	*TypedValue_AnyVal
	//	*TypedValue_JsonVal
	//	*TypedValue_JsonIetfVal
	//	*TypedValue_AsciiVal
	//	*TypedValue_ProtoBytes
	//	*TypedValue_EmptyVal
	//	*TypedValue_IdentityrefVal
	Value isTypedValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*TypedValue) Descriptor deprecated 

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

Deprecated: Use TypedValue.ProtoReflect.Descriptor instead.

func (*TypedValue) GetAnyVal 

func (x *TypedValue) GetAnyVal() *any1.Any

func (*TypedValue) GetAsciiVal 

func (x *TypedValue) GetAsciiVal() string

func (*TypedValue) GetBoolVal 

func (x *TypedValue) GetBoolVal() bool

func (*TypedValue) GetBytesVal 

func (x *TypedValue) GetBytesVal() []byte

func (*TypedValue) GetDecimalVal 

func (x *TypedValue) GetDecimalVal() *Decimal64

func (*TypedValue) GetDoubleVal 

func (x *TypedValue) GetDoubleVal() float64

func (*TypedValue) GetEmptyVal added in v0.0.32 

func (x *TypedValue) GetEmptyVal() *empty.Empty

func (*TypedValue) GetFloatVal 

func (x *TypedValue) GetFloatVal() float32

func (*TypedValue) GetIdentityrefVal added in v0.0.33 

func (x *TypedValue) GetIdentityrefVal() *IdentityRef

func (*TypedValue) GetIntVal 

func (x *TypedValue) GetIntVal() int64

func (*TypedValue) GetJsonIetfVal 

func (x *TypedValue) GetJsonIetfVal() []byte

func (*TypedValue) GetJsonVal 

func (x *TypedValue) GetJsonVal() []byte

func (*TypedValue) GetLeaflistVal 

func (x *TypedValue) GetLeaflistVal() *ScalarArray

func (*TypedValue) GetProtoBytes 

func (x *TypedValue) GetProtoBytes() []byte

func (*TypedValue) GetStringVal 

func (x *TypedValue) GetStringVal() string

func (*TypedValue) GetTimestamp 

func (x *TypedValue) GetTimestamp() uint64

func (*TypedValue) GetUintVal 

func (x *TypedValue) GetUintVal() uint64

func (*TypedValue) GetValue 

func (m *TypedValue) GetValue() isTypedValue_Value

func (*TypedValue) ProtoMessage 

func (*TypedValue) ProtoMessage()

func (*TypedValue) ProtoReflect 

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

func (*TypedValue) Reset 

func (x *TypedValue) Reset()

func (*TypedValue) String 

func (x *TypedValue) String() string

type TypedValue_AnyVal 

type TypedValue_AnyVal struct {
	AnyVal *any1.Any `protobuf:"bytes,11,opt,name=any_val,json=anyVal,proto3,oneof"`
}

type TypedValue_AsciiVal 

type TypedValue_AsciiVal struct {
	AsciiVal string `protobuf:"bytes,14,opt,name=ascii_val,json=asciiVal,proto3,oneof"`
}

type TypedValue_BoolVal 

type TypedValue_BoolVal struct {
	BoolVal bool `protobuf:"varint,5,opt,name=bool_val,json=boolVal,proto3,oneof"`
}

type TypedValue_BytesVal 

type TypedValue_BytesVal struct {
	BytesVal []byte `protobuf:"bytes,6,opt,name=bytes_val,json=bytesVal,proto3,oneof"`
}

type TypedValue_DecimalVal 

type TypedValue_DecimalVal struct {
	DecimalVal *Decimal64 `protobuf:"bytes,8,opt,name=decimal_val,json=decimalVal,proto3,oneof"`
}

type TypedValue_DoubleVal 

type TypedValue_DoubleVal struct {
	DoubleVal float64 `protobuf:"fixed64,9,opt,name=Double_val,json=DoubleVal,proto3,oneof"`
}

type TypedValue_EmptyVal added in v0.0.32 

type TypedValue_EmptyVal struct {
	EmptyVal *empty.Empty `protobuf:"bytes,16,opt,name=empty_val,json=emptyVal,proto3,oneof"`
}

type TypedValue_FloatVal 

type TypedValue_FloatVal struct {
	FloatVal float32 `protobuf:"fixed32,7,opt,name=float_val,json=floatVal,proto3,oneof"`
}

type TypedValue_IdentityrefVal added in v0.0.33 

type TypedValue_IdentityrefVal struct {
	IdentityrefVal *IdentityRef `protobuf:"bytes,17,opt,name=identityref_val,json=identityrefVal,proto3,oneof"`
}

type TypedValue_IntVal 

type TypedValue_IntVal struct {
	IntVal int64 `protobuf:"varint,3,opt,name=int_val,json=intVal,proto3,oneof"`
}

type TypedValue_JsonIetfVal 

type TypedValue_JsonIetfVal struct {
	JsonIetfVal []byte `protobuf:"bytes,13,opt,name=json_ietf_val,json=jsonIetfVal,proto3,oneof"`
}

type TypedValue_JsonVal 

type TypedValue_JsonVal struct {
	JsonVal []byte `protobuf:"bytes,12,opt,name=json_val,json=jsonVal,proto3,oneof"`
}

type TypedValue_LeaflistVal 

type TypedValue_LeaflistVal struct {
	LeaflistVal *ScalarArray `protobuf:"bytes,10,opt,name=leaflist_val,json=leaflistVal,proto3,oneof"`
}

type TypedValue_ProtoBytes 

type TypedValue_ProtoBytes struct {
	ProtoBytes []byte `protobuf:"bytes,15,opt,name=proto_bytes,json=protoBytes,proto3,oneof"`
}

type TypedValue_StringVal 

type TypedValue_StringVal struct {
	StringVal string `protobuf:"bytes,2,opt,name=string_val,json=stringVal,proto3,oneof"`
}

type TypedValue_UintVal 

type TypedValue_UintVal struct {
	UintVal uint64 `protobuf:"varint,4,opt,name=uint_val,json=uintVal,proto3,oneof"`
}

type UnimplementedDataServerServer 

type UnimplementedDataServerServer struct{}

UnimplementedDataServerServer 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 (UnimplementedDataServerServer) Commit 

func (UnimplementedDataServerServer) Commit(context.Context, *CommitRequest) (*CommitResponse, error)

func (UnimplementedDataServerServer) CreateDataStore 

func (UnimplementedDataServerServer) CreateDataStore(context.Context, *CreateDataStoreRequest) (*CreateDataStoreResponse, error)

func (UnimplementedDataServerServer) DeleteDataStore 

func (UnimplementedDataServerServer) DeleteDataStore(context.Context, *DeleteDataStoreRequest) (*DeleteDataStoreResponse, error)

func (UnimplementedDataServerServer) Diff 

func (UnimplementedDataServerServer) Diff(context.Context, *DiffRequest) (*DiffResponse, error)

func (UnimplementedDataServerServer) Discard 

func (UnimplementedDataServerServer) Discard(context.Context, *DiscardRequest) (*DiscardResponse, error)

func (UnimplementedDataServerServer) GetData 

func (UnimplementedDataServerServer) GetData(*GetDataRequest, grpc.ServerStreamingServer[GetDataResponse]) error

func (UnimplementedDataServerServer) GetDataStore 

func (UnimplementedDataServerServer) GetDataStore(context.Context, *GetDataStoreRequest) (*GetDataStoreResponse, error)

func (UnimplementedDataServerServer) GetIntent 

func (UnimplementedDataServerServer) GetIntent(context.Context, *GetIntentRequest) (*GetIntentResponse, error)

func (UnimplementedDataServerServer) ListDataStore 

func (UnimplementedDataServerServer) ListDataStore(context.Context, *ListDataStoreRequest) (*ListDataStoreResponse, error)

func (UnimplementedDataServerServer) ListIntent 

func (UnimplementedDataServerServer) ListIntent(context.Context, *ListIntentRequest) (*ListIntentResponse, error)

func (UnimplementedDataServerServer) Rebase 

func (UnimplementedDataServerServer) Rebase(context.Context, *RebaseRequest) (*RebaseResponse, error)

func (UnimplementedDataServerServer) SetData 

func (UnimplementedDataServerServer) SetData(context.Context, *SetDataRequest) (*SetDataResponse, error)

func (UnimplementedDataServerServer) SetIntent 

func (UnimplementedDataServerServer) SetIntent(context.Context, *SetIntentRequest) (*SetIntentResponse, error)

func (UnimplementedDataServerServer) Subscribe 

func (UnimplementedDataServerServer) Subscribe(*SubscribeRequest, grpc.ServerStreamingServer[SubscribeResponse]) error

func (UnimplementedDataServerServer) Watch 

func (UnimplementedDataServerServer) Watch(*WatchRequest, grpc.ServerStreamingServer[WatchResponse]) error

func (UnimplementedDataServerServer) WatchDeviations 

func (UnimplementedDataServerServer) WatchDeviations(*WatchDeviationRequest, grpc.ServerStreamingServer[WatchDeviationResponse]) error

type UnimplementedSchemaServerServer 

type UnimplementedSchemaServerServer struct{}

UnimplementedSchemaServerServer 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 (UnimplementedSchemaServerServer) CreateSchema 

func (UnimplementedSchemaServerServer) CreateSchema(context.Context, *CreateSchemaRequest) (*CreateSchemaResponse, error)

func (UnimplementedSchemaServerServer) DeleteSchema 

func (UnimplementedSchemaServerServer) DeleteSchema(context.Context, *DeleteSchemaRequest) (*DeleteSchemaResponse, error)

func (UnimplementedSchemaServerServer) ExpandPath 

func (UnimplementedSchemaServerServer) ExpandPath(context.Context, *ExpandPathRequest) (*ExpandPathResponse, error)

func (UnimplementedSchemaServerServer) GetSchema 

func (UnimplementedSchemaServerServer) GetSchema(context.Context, *GetSchemaRequest) (*GetSchemaResponse, error)

func (UnimplementedSchemaServerServer) GetSchemaDetails 

func (UnimplementedSchemaServerServer) GetSchemaDetails(context.Context, *GetSchemaDetailsRequest) (*GetSchemaDetailsResponse, error)

func (UnimplementedSchemaServerServer) GetSchemaElements 

func (UnimplementedSchemaServerServer) GetSchemaElements(*GetSchemaRequest, grpc.ServerStreamingServer[GetSchemaResponse]) error

func (UnimplementedSchemaServerServer) ListSchema 

func (UnimplementedSchemaServerServer) ListSchema(context.Context, *ListSchemaRequest) (*ListSchemaResponse, error)

func (UnimplementedSchemaServerServer) ReloadSchema 

func (UnimplementedSchemaServerServer) ReloadSchema(context.Context, *ReloadSchemaRequest) (*ReloadSchemaResponse, error)

func (UnimplementedSchemaServerServer) ToPath 

func (UnimplementedSchemaServerServer) ToPath(context.Context, *ToPathRequest) (*ToPathResponse, error)

func (UnimplementedSchemaServerServer) UploadSchema 

func (UnimplementedSchemaServerServer) UploadSchema(grpc.ClientStreamingServer[UploadSchemaRequest, UploadSchemaResponse]) error

type UnsafeDataServerServer 

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

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

type UnsafeSchemaServerServer 

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

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

type Update 

type Update struct {
	Path  *Path       `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Value *TypedValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

sub messages

func (*Update) Descriptor deprecated 

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

Deprecated: Use Update.ProtoReflect.Descriptor instead.

func (*Update) GetPath 

func (x *Update) GetPath() *Path

func (*Update) GetValue 

func (x *Update) GetValue() *TypedValue

func (*Update) ProtoMessage 

func (*Update) ProtoMessage()

func (*Update) ProtoReflect 

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

func (*Update) Reset 

func (x *Update) Reset()

func (*Update) String 

func (x *Update) String() string

type UpdateResult 

type UpdateResult struct {
	Path *Path                  `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`                               // schema.Path associated with the update.
	Op   UpdateResult_Operation `protobuf:"varint,4,opt,name=op,proto3,enum=data.UpdateResult_Operation" json:"op,omitempty"` // Update operation type.
	// contains filtered or unexported fields
}

func (*UpdateResult) Descriptor deprecated 

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

Deprecated: Use UpdateResult.ProtoReflect.Descriptor instead.

func (*UpdateResult) GetOp 

func (x *UpdateResult) GetOp() UpdateResult_Operation

func (*UpdateResult) GetPath 

func (x *UpdateResult) GetPath() *Path

func (*UpdateResult) ProtoMessage 

func (*UpdateResult) ProtoMessage()

func (*UpdateResult) ProtoReflect 

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

func (*UpdateResult) Reset 

func (x *UpdateResult) Reset()

func (*UpdateResult) String 

func (x *UpdateResult) String() string

type UpdateResult_Operation 

type UpdateResult_Operation int32

The operation that was associated with the schema.Path specified. 

const (
	UpdateResult_INVALID UpdateResult_Operation = 0
	UpdateResult_DELETE  UpdateResult_Operation = 1 // The result relates to a delete of  schema.Path.
	UpdateResult_REPLACE UpdateResult_Operation = 2 // The result relates to a replace of schema.Path.
	UpdateResult_UPDATE  UpdateResult_Operation = 3 // The result relates to an update of schema.Path.
)

func (UpdateResult_Operation) Descriptor 

func (UpdateResult_Operation) Descriptor() protoreflect.EnumDescriptor

func (UpdateResult_Operation) Enum 

func (x UpdateResult_Operation) Enum() *UpdateResult_Operation

func (UpdateResult_Operation) EnumDescriptor deprecated 

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

Deprecated: Use UpdateResult_Operation.Descriptor instead.

func (UpdateResult_Operation) Number 

func (x UpdateResult_Operation) Number() protoreflect.EnumNumber

func (UpdateResult_Operation) String 

func (x UpdateResult_Operation) String() string

func (UpdateResult_Operation) Type 

func (UpdateResult_Operation) Type() protoreflect.EnumType

type UploadSchemaFile 

type UploadSchemaFile struct {
	FileName string                    `protobuf:"bytes,1,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`                                        // file name with path
	FileType UploadSchemaFile_FileType `protobuf:"varint,2,opt,name=file_type,json=fileType,proto3,enum=schema.UploadSchemaFile_FileType" json:"file_type,omitempty"` // file
	Contents []byte                    `protobuf:"bytes,3,opt,name=contents,proto3" json:"contents,omitempty"`                                                        // raw bytes to be appended to the file
	Hash     *Hash                     `protobuf:"bytes,4,opt,name=hash,proto3" json:"hash,omitempty"`                                                                // if present marks the last message for that file
	// contains filtered or unexported fields
}

func (*UploadSchemaFile) Descriptor deprecated 

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

Deprecated: Use UploadSchemaFile.ProtoReflect.Descriptor instead.

func (*UploadSchemaFile) GetContents 

func (x *UploadSchemaFile) GetContents() []byte

func (*UploadSchemaFile) GetFileName 

func (x *UploadSchemaFile) GetFileName() string

func (*UploadSchemaFile) GetFileType 

func (x *UploadSchemaFile) GetFileType() UploadSchemaFile_FileType

func (*UploadSchemaFile) GetHash 

func (x *UploadSchemaFile) GetHash() *Hash

func (*UploadSchemaFile) ProtoMessage 

func (*UploadSchemaFile) ProtoMessage()

func (*UploadSchemaFile) ProtoReflect 

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

func (*UploadSchemaFile) Reset 

func (x *UploadSchemaFile) Reset()

func (*UploadSchemaFile) String 

func (x *UploadSchemaFile) String() string

type UploadSchemaFile_FileType 

type UploadSchemaFile_FileType int32
const (
	UploadSchemaFile_MODULE     UploadSchemaFile_FileType = 0
	UploadSchemaFile_DEPENDENCY UploadSchemaFile_FileType = 1
)

func (UploadSchemaFile_FileType) Descriptor 

func (UploadSchemaFile_FileType) Descriptor() protoreflect.EnumDescriptor

func (UploadSchemaFile_FileType) Enum 

func (x UploadSchemaFile_FileType) Enum() *UploadSchemaFile_FileType

func (UploadSchemaFile_FileType) EnumDescriptor deprecated 

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

Deprecated: Use UploadSchemaFile_FileType.Descriptor instead.

func (UploadSchemaFile_FileType) Number 

func (x UploadSchemaFile_FileType) Number() protoreflect.EnumNumber

func (UploadSchemaFile_FileType) String 

func (x UploadSchemaFile_FileType) String() string

func (UploadSchemaFile_FileType) Type 

func (UploadSchemaFile_FileType) Type() protoreflect.EnumType

type UploadSchemaFinalize 

type UploadSchemaFinalize struct {
	// contains filtered or unexported fields
}

func (*UploadSchemaFinalize) Descriptor deprecated 

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

Deprecated: Use UploadSchemaFinalize.ProtoReflect.Descriptor instead.

func (*UploadSchemaFinalize) ProtoMessage 

func (*UploadSchemaFinalize) ProtoMessage()

func (*UploadSchemaFinalize) ProtoReflect 

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

func (*UploadSchemaFinalize) Reset 

func (x *UploadSchemaFinalize) Reset()

func (*UploadSchemaFinalize) String 

func (x *UploadSchemaFinalize) String() string

type UploadSchemaRequest 

type UploadSchemaRequest struct {

	// Types that are assignable to Upload:
	//
	//	*UploadSchemaRequest_CreateSchema
	//	*UploadSchemaRequest_SchemaFile
	//	*UploadSchemaRequest_Finalize
	Upload isUploadSchemaRequest_Upload `protobuf_oneof:"upload"`
	// contains filtered or unexported fields
}

func (*UploadSchemaRequest) Descriptor deprecated 

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

Deprecated: Use UploadSchemaRequest.ProtoReflect.Descriptor instead.

func (*UploadSchemaRequest) GetCreateSchema 

func (x *UploadSchemaRequest) GetCreateSchema() *CreateSchemaRequest

func (*UploadSchemaRequest) GetFinalize 

func (x *UploadSchemaRequest) GetFinalize() *UploadSchemaFinalize

func (*UploadSchemaRequest) GetSchemaFile 

func (x *UploadSchemaRequest) GetSchemaFile() *UploadSchemaFile

func (*UploadSchemaRequest) GetUpload 

func (m *UploadSchemaRequest) GetUpload() isUploadSchemaRequest_Upload

func (*UploadSchemaRequest) ProtoMessage 

func (*UploadSchemaRequest) ProtoMessage()

func (*UploadSchemaRequest) ProtoReflect 

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

func (*UploadSchemaRequest) Reset 

func (x *UploadSchemaRequest) Reset()

func (*UploadSchemaRequest) String 

func (x *UploadSchemaRequest) String() string

type UploadSchemaRequest_CreateSchema 

type UploadSchemaRequest_CreateSchema struct {
	CreateSchema *CreateSchemaRequest `protobuf:"bytes,1,opt,name=create_schema,json=createSchema,proto3,oneof"`
}

type UploadSchemaRequest_Finalize 

type UploadSchemaRequest_Finalize struct {
	Finalize *UploadSchemaFinalize `protobuf:"bytes,3,opt,name=finalize,proto3,oneof"`
}

type UploadSchemaRequest_SchemaFile 

type UploadSchemaRequest_SchemaFile struct {
	SchemaFile *UploadSchemaFile `protobuf:"bytes,2,opt,name=schema_file,json=schemaFile,proto3,oneof"`
}

type UploadSchemaResponse 

type UploadSchemaResponse struct {
	// contains filtered or unexported fields
}

func (*UploadSchemaResponse) Descriptor deprecated 

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

Deprecated: Use UploadSchemaResponse.ProtoReflect.Descriptor instead.

func (*UploadSchemaResponse) ProtoMessage 

func (*UploadSchemaResponse) ProtoMessage()

func (*UploadSchemaResponse) ProtoReflect 

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

func (*UploadSchemaResponse) Reset 

func (x *UploadSchemaResponse) Reset()

func (*UploadSchemaResponse) String 

func (x *UploadSchemaResponse) String() string

type Watch 

type Watch struct {

	// objects to watch, identified by a path.
	Path []*Path `protobuf:"bytes,1,rep,name=path,proto3" json:"path,omitempty"`
	// data type config, state
	DataType DataType `protobuf:"varint,2,opt,name=data_type,json=dataType,proto3,enum=schema.DataType" json:"data_type,omitempty"`
	// heartbeat interval after which the object
	// data is sent to the watcher even if it did not change.
	HeartbeatInterval uint64 `protobuf:"varint,3,opt,name=heartbeat_interval,json=heartbeatInterval,proto3" json:"heartbeat_interval,omitempty"`
	// contains filtered or unexported fields
}

func (*Watch) Descriptor deprecated 

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

Deprecated: Use Watch.ProtoReflect.Descriptor instead.

func (*Watch) GetDataType 

func (x *Watch) GetDataType() DataType

func (*Watch) GetHeartbeatInterval 

func (x *Watch) GetHeartbeatInterval() uint64

func (*Watch) GetPath 

func (x *Watch) GetPath() []*Path

func (*Watch) ProtoMessage 

func (*Watch) ProtoMessage()

func (*Watch) ProtoReflect 

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

func (*Watch) Reset 

func (x *Watch) Reset()

func (*Watch) String 

func (x *Watch) String() string

type WatchDeviationRequest 

type WatchDeviationRequest struct {

	// datastore name
	Name []string `protobuf:"bytes,1,rep,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchDeviationRequest) Descriptor deprecated 

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

Deprecated: Use WatchDeviationRequest.ProtoReflect.Descriptor instead.

func (*WatchDeviationRequest) GetName 

func (x *WatchDeviationRequest) GetName() []string

func (*WatchDeviationRequest) ProtoMessage 

func (*WatchDeviationRequest) ProtoMessage()

func (*WatchDeviationRequest) ProtoReflect 

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

func (*WatchDeviationRequest) Reset 

func (x *WatchDeviationRequest) Reset()

func (*WatchDeviationRequest) String 

func (x *WatchDeviationRequest) String() string

type WatchDeviationResponse 

type WatchDeviationResponse struct {

	// datastore name
	Name          string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Intent        string          `protobuf:"bytes,2,opt,name=intent,proto3" json:"intent,omitempty"`
	Event         DeviationEvent  `protobuf:"varint,3,opt,name=event,proto3,enum=data.DeviationEvent" json:"event,omitempty"`
	Reason        DeviationReason `protobuf:"varint,4,opt,name=reason,proto3,enum=data.DeviationReason" json:"reason,omitempty"`
	Path          *Path           `protobuf:"bytes,5,opt,name=path,proto3" json:"path,omitempty"`
	ExpectedValue *TypedValue     `protobuf:"bytes,6,opt,name=expected_value,json=expectedValue,proto3" json:"expected_value,omitempty"`
	CurrentValue  *TypedValue     `protobuf:"bytes,7,opt,name=current_value,json=currentValue,proto3" json:"current_value,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchDeviationResponse) Descriptor deprecated 

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

Deprecated: Use WatchDeviationResponse.ProtoReflect.Descriptor instead.

func (*WatchDeviationResponse) GetCurrentValue 

func (x *WatchDeviationResponse) GetCurrentValue() *TypedValue

func (*WatchDeviationResponse) GetEvent 

func (x *WatchDeviationResponse) GetEvent() DeviationEvent

func (*WatchDeviationResponse) GetExpectedValue 

func (x *WatchDeviationResponse) GetExpectedValue() *TypedValue

func (*WatchDeviationResponse) GetIntent 

func (x *WatchDeviationResponse) GetIntent() string

func (*WatchDeviationResponse) GetName 

func (x *WatchDeviationResponse) GetName() string

func (*WatchDeviationResponse) GetPath 

func (x *WatchDeviationResponse) GetPath() *Path

func (*WatchDeviationResponse) GetReason 

func (x *WatchDeviationResponse) GetReason() DeviationReason

func (*WatchDeviationResponse) ProtoMessage 

func (*WatchDeviationResponse) ProtoMessage()

func (*WatchDeviationResponse) ProtoReflect 

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

func (*WatchDeviationResponse) Reset 

func (x *WatchDeviationResponse) Reset()

func (*WatchDeviationResponse) String 

func (x *WatchDeviationResponse) String() string

type WatchRequest 

type WatchRequest struct {

	// datastore name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// watched objects
	Watch []*Watch `protobuf:"bytes,2,rep,name=watch,proto3" json:"watch,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchRequest) Descriptor deprecated 

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

Deprecated: Use WatchRequest.ProtoReflect.Descriptor instead.

func (*WatchRequest) GetName 

func (x *WatchRequest) GetName() string

func (*WatchRequest) GetWatch 

func (x *WatchRequest) GetWatch() []*Watch

func (*WatchRequest) ProtoMessage 

func (*WatchRequest) ProtoMessage()

func (*WatchRequest) ProtoReflect 

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

func (*WatchRequest) Reset 

func (x *WatchRequest) Reset()

func (*WatchRequest) String 

func (x *WatchRequest) String() string

type WatchResponse 

type WatchResponse struct {
	Notification *Notification `protobuf:"bytes,1,opt,name=notification,proto3" json:"notification,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchResponse) Descriptor deprecated 

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

Deprecated: Use WatchResponse.ProtoReflect.Descriptor instead.

func (*WatchResponse) GetNotification 

func (x *WatchResponse) GetNotification() *Notification

func (*WatchResponse) ProtoMessage 

func (*WatchResponse) ProtoMessage()

func (*WatchResponse) ProtoReflect 

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

func (*WatchResponse) Reset 

func (x *WatchResponse) Reset()

func (*WatchResponse) String 

func (x *WatchResponse) 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.