netwdevpb

package module
v0.1.27 Latest Latest
Warning

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

 Go to latest Published: Jul 25, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	CacheUpdateRequest_ActionType_name = map[int32]string{
		0: "ActionReplace",
		1: "ActionUpdate",
		2: "ActionDelete",
	}
	CacheUpdateRequest_ActionType_value = map[string]int32{
		"ActionReplace": 0,
		"ActionUpdate":  1,
		"ActionDelete":  2,
	}
)

Enum value maps for CacheUpdateRequest_ActionType.

View Source 
var (
	CacheStatusReply_CacheResourceStatus_name = map[int32]string{
		0:  "CacheResourceStatusNone",
		1:  "CacheResourceStatusToBeProcessed",
		2:  "CacheResourceStatusUpdateBeingProcessed",
		3:  "CacheResourceStatusUpdateProcessedSuccess",
		4:  "CacheResourceStatusUpdateProcessedSuccessNatsUpdatePending",
		5:  "CacheResourceStatusUpdateProcessedFailed",
		6:  "CacheResourceStatusUpdateProcessedFailedNatsUpdatePending",
		7:  "CacheResourceStatusDependencyMissing",
		8:  "CacheResourceStatusLeafRefDependency",
		9:  "CacheResourceStatusDeletePending",
		10: "CacheResourceStatusDeletePendingWithParentDependency",
		11: "CacheResourceStatusDeleteWithMissingDependency",
		12: "CacheResourceStatusUpdatePending",
	}
	CacheStatusReply_CacheResourceStatus_value = map[string]int32{
		"CacheResourceStatusNone":                                    0,
		"CacheResourceStatusToBeProcessed":                           1,
		"CacheResourceStatusUpdateBeingProcessed":                    2,
		"CacheResourceStatusUpdateProcessedSuccess":                  3,
		"CacheResourceStatusUpdateProcessedSuccessNatsUpdatePending": 4,
		"CacheResourceStatusUpdateProcessedFailed":                   5,
		"CacheResourceStatusUpdateProcessedFailedNatsUpdatePending":  6,
		"CacheResourceStatusDependencyMissing":                       7,
		"CacheResourceStatusLeafRefDependency":                       8,
		"CacheResourceStatusDeletePending":                           9,
		"CacheResourceStatusDeletePendingWithParentDependency":       10,
		"CacheResourceStatusDeleteWithMissingDependency":             11,
		"CacheResourceStatusUpdatePending":                           12,
	}
)

Enum value maps for CacheStatusReply_CacheResourceStatus.

View Source 
var (
	Deviation_OnChangeAction_name = map[int32]string{
		0: "OnChangeActionUpdate",
		1: "OnChangeActionDelete",
	}
	Deviation_OnChangeAction_value = map[string]int32{
		"OnChangeActionUpdate": 0,
		"OnChangeActionDelete": 1,
	}
)

Enum value maps for Deviation_OnChangeAction.

View Source 
var (
	Deviation_DeviationAction_name = map[int32]string{
		0: "DeviationActionIgnore",
		1: "DeviationActionReApplyCache",
		2: "DeviationActionDelete",
		3: "DeviationActionDeleteIgnoredByParent",
		4: "DeviationActionIgnoreException",
	}
	Deviation_DeviationAction_value = map[string]int32{
		"DeviationActionIgnore":                0,
		"DeviationActionReApplyCache":          1,
		"DeviationActionDelete":                2,
		"DeviationActionDeleteIgnoredByParent": 3,
		"DeviationActionIgnoreException":       4,
	}
)

Enum value maps for Deviation_DeviationAction.

View Source 
var CacheStatus_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "netwdevpb.CacheStatus",
	HandlerType: (*CacheStatusServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Request",
			Handler:    _CacheStatus_Request_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "configMessage.proto",
}

CacheStatus_ServiceDesc is the grpc.ServiceDesc for CacheStatus 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 CacheUpdate_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "netwdevpb.CacheUpdate",
	HandlerType: (*CacheUpdateServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Update",
			Handler:    _CacheUpdate_Update_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "configMessage.proto",
}

CacheUpdate_ServiceDesc is the grpc.ServiceDesc for CacheUpdate 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 DeviationUpdate_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "netwdevpb.DeviationUpdate",
	HandlerType: (*DeviationUpdateServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Update",
			Handler:    _DeviationUpdate_Update_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "configMessage.proto",
}

DeviationUpdate_ServiceDesc is the grpc.ServiceDesc for DeviationUpdate 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_configMessage_proto protoreflect.FileDescriptor
View Source 
var Registration_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "netwdevpb.Registration",
	HandlerType: (*RegistrationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Register",
			Handler:    _Registration_Register_Handler,
		},
		{
			MethodName: "DeRegister",
			Handler:    _Registration_DeRegister_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "configMessage.proto",
}

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

Functions

func RegisterCacheStatusServer added in v0.1.7 

func RegisterCacheStatusServer(s grpc.ServiceRegistrar, srv CacheStatusServer)

func RegisterCacheUpdateServer added in v0.1.12 

func RegisterCacheUpdateServer(s grpc.ServiceRegistrar, srv CacheUpdateServer)

func RegisterDeviationUpdateServer added in v0.1.20 

func RegisterDeviationUpdateServer(s grpc.ServiceRegistrar, srv DeviationUpdateServer)

func RegisterRegistrationServer added in v0.1.25 

func RegisterRegistrationServer(s grpc.ServiceRegistrar, srv RegistrationServer)

Types

type CacheStatusClient added in v0.1.7 

type CacheStatusClient interface {
	Request(ctx context.Context, in *CacheStatusRequest, opts ...grpc.CallOption) (*CacheStatusReply, error)
}

CacheStatusClient is the client API for CacheStatus 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 NewCacheStatusClient added in v0.1.7 

func NewCacheStatusClient(cc grpc.ClientConnInterface) CacheStatusClient

type CacheStatusReply added in v0.1.7 

type CacheStatusReply struct {
	Exists bool                                 `protobuf:"varint,1,opt,name=Exists,proto3" json:"Exists,omitempty"`
	Status CacheStatusReply_CacheResourceStatus `protobuf:"varint,2,opt,name=Status,proto3,enum=netwdevpb.CacheStatusReply_CacheResourceStatus" json:"Status,omitempty"`
	Data   *CacheUpdateRequest                  `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"`
	// contains filtered or unexported fields
}

func (*CacheStatusReply) Descriptor deprecated added in v0.1.7 

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

Deprecated: Use CacheStatusReply.ProtoReflect.Descriptor instead.

func (*CacheStatusReply) GetData added in v0.1.12 

func (x *CacheStatusReply) GetData() *CacheUpdateRequest

func (*CacheStatusReply) GetExists added in v0.1.7 

func (x *CacheStatusReply) GetExists() bool

func (*CacheStatusReply) GetStatus added in v0.1.10 

func (x *CacheStatusReply) GetStatus() CacheStatusReply_CacheResourceStatus

func (*CacheStatusReply) ProtoMessage added in v0.1.7 

func (*CacheStatusReply) ProtoMessage()

func (*CacheStatusReply) ProtoReflect added in v0.1.7 

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

func (*CacheStatusReply) Reset added in v0.1.7 

func (x *CacheStatusReply) Reset()

func (*CacheStatusReply) String added in v0.1.7 

func (x *CacheStatusReply) String() string

type CacheStatusReply_CacheResourceStatus added in v0.1.15 

type CacheStatusReply_CacheResourceStatus int32
const (
	// None -> no status, object does not exist
	CacheStatusReply_CacheResourceStatusNone CacheStatusReply_CacheResourceStatus = 0
	// ToBeProcessed -> new data, not processed
	CacheStatusReply_CacheResourceStatusToBeProcessed CacheStatusReply_CacheResourceStatus = 1
	// UpdateBeingProcessed -> data is merged in the tree
	CacheStatusReply_CacheResourceStatusUpdateBeingProcessed CacheStatusReply_CacheResourceStatus = 2
	// UpdateProcessedSuccess -> data, processed successfully
	CacheStatusReply_CacheResourceStatusUpdateProcessedSuccess CacheStatusReply_CacheResourceStatus = 3
	// UpdateProcessedSuccessNatsUpdatePending -> data, processed successfully but nats update is missing
	CacheStatusReply_CacheResourceStatusUpdateProcessedSuccessNatsUpdatePending CacheStatusReply_CacheResourceStatus = 4
	// UpdateProcessedFailed -> data, processed unsuccessfully
	CacheStatusReply_CacheResourceStatusUpdateProcessedFailed CacheStatusReply_CacheResourceStatus = 5
	// UpdateProcessedFailedNatsUpdatePending -> data, processing Failed but nats update is missing
	CacheStatusReply_CacheResourceStatusUpdateProcessedFailedNatsUpdatePending CacheStatusReply_CacheResourceStatus = 6
	// DependencyMissing -> data with missing dependency
	CacheStatusReply_CacheResourceStatusDependencyMissing CacheStatusReply_CacheResourceStatus = 7
	// LeafRefDependency -> data with leafref dependency cannot delete
	CacheStatusReply_CacheResourceStatusLeafRefDependency CacheStatusReply_CacheResourceStatus = 8
	// DeletePending -> data with pending gnmi delete
	CacheStatusReply_CacheResourceStatusDeletePending CacheStatusReply_CacheResourceStatus = 9
	// DeletePendingWithParentDependency -> data with pending parent gnmi delete
	CacheStatusReply_CacheResourceStatusDeletePendingWithParentDependency CacheStatusReply_CacheResourceStatus = 10
	// DeleteWithMissingDependency -> data with No pending gnmi update
	CacheStatusReply_CacheResourceStatusDeleteWithMissingDependency CacheStatusReply_CacheResourceStatus = 11
	// UpdatePending -> data with pending update
	CacheStatusReply_CacheResourceStatusUpdatePending CacheStatusReply_CacheResourceStatus = 12
)

func (CacheStatusReply_CacheResourceStatus) Descriptor added in v0.1.15 

func (CacheStatusReply_CacheResourceStatus) Descriptor() protoreflect.EnumDescriptor

func (CacheStatusReply_CacheResourceStatus) Enum added in v0.1.15 

func (x CacheStatusReply_CacheResourceStatus) Enum() *CacheStatusReply_CacheResourceStatus

func (CacheStatusReply_CacheResourceStatus) EnumDescriptor deprecated added in v0.1.15 

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

Deprecated: Use CacheStatusReply_CacheResourceStatus.Descriptor instead.

func (CacheStatusReply_CacheResourceStatus) Number added in v0.1.15 

func (x CacheStatusReply_CacheResourceStatus) Number() protoreflect.EnumNumber

func (CacheStatusReply_CacheResourceStatus) String added in v0.1.15 

func (x CacheStatusReply_CacheResourceStatus) String() string

func (CacheStatusReply_CacheResourceStatus) Type added in v0.1.15 

func (CacheStatusReply_CacheResourceStatus) Type() protoreflect.EnumType

type CacheStatusRequest added in v0.1.7 

type CacheStatusRequest struct {
	Resource string `protobuf:"bytes,1,opt,name=Resource,proto3" json:"Resource,omitempty"`
	Level    int32  `protobuf:"varint,2,opt,name=Level,proto3" json:"Level,omitempty"`
	// contains filtered or unexported fields
}

func (*CacheStatusRequest) Descriptor deprecated added in v0.1.7 

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

Deprecated: Use CacheStatusRequest.ProtoReflect.Descriptor instead.

func (*CacheStatusRequest) GetLevel added in v0.1.7 

func (x *CacheStatusRequest) GetLevel() int32

func (*CacheStatusRequest) GetResource added in v0.1.15 

func (x *CacheStatusRequest) GetResource() string

func (*CacheStatusRequest) ProtoMessage added in v0.1.7 

func (*CacheStatusRequest) ProtoMessage()

func (*CacheStatusRequest) ProtoReflect added in v0.1.7 

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

func (*CacheStatusRequest) Reset added in v0.1.7 

func (x *CacheStatusRequest) Reset()

func (*CacheStatusRequest) String added in v0.1.7 

func (x *CacheStatusRequest) String() string

type CacheStatusServer added in v0.1.7 

type CacheStatusServer interface {
	Request(context.Context, *CacheStatusRequest) (*CacheStatusReply, error)
	// contains filtered or unexported methods
}

CacheStatusServer is the server API for CacheStatus service. All implementations must embed UnimplementedCacheStatusServer for forward compatibility

type CacheUpdateClient added in v0.1.12 

type CacheUpdateClient interface {
	Update(ctx context.Context, in *CacheUpdateRequest, opts ...grpc.CallOption) (*CacheUpdateReply, error)
}

CacheUpdateClient is the client API for CacheUpdate 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 NewCacheUpdateClient added in v0.1.12 

func NewCacheUpdateClient(cc grpc.ClientConnInterface) CacheUpdateClient

type CacheUpdateReply added in v0.1.12 

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

func (*CacheUpdateReply) Descriptor deprecated added in v0.1.12 

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

Deprecated: Use CacheUpdateReply.ProtoReflect.Descriptor instead.

func (*CacheUpdateReply) ProtoMessage added in v0.1.12 

func (*CacheUpdateReply) ProtoMessage()

func (*CacheUpdateReply) ProtoReflect added in v0.1.12 

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

func (*CacheUpdateReply) Reset added in v0.1.12 

func (x *CacheUpdateReply) Reset()

func (*CacheUpdateReply) String added in v0.1.12 

func (x *CacheUpdateReply) String() string

type CacheUpdateRequest added in v0.1.12 

type CacheUpdateRequest struct {
	Resource                    string                        `protobuf:"bytes,1,opt,name=Resource,proto3" json:"Resource,omitempty"`
	Level                       int32                         `protobuf:"varint,2,opt,name=Level,proto3" json:"Level,omitempty"`
	Action                      CacheUpdateRequest_ActionType `protobuf:"varint,3,opt,name=Action,proto3,enum=netwdevpb.CacheUpdateRequest_ActionType" json:"Action,omitempty"`
	AggregateActionPath         string                        `protobuf:"bytes,4,opt,name=AggregateActionPath,proto3" json:"AggregateActionPath,omitempty"`
	AggregateActionPathSuccess  bool                          `protobuf:"varint,5,opt,name=AggregateActionPathSuccess,proto3" json:"AggregateActionPathSuccess,omitempty"`
	IndividualActionPath        []string                      `protobuf:"bytes,6,rep,name=IndividualActionPath,proto3" json:"IndividualActionPath,omitempty"`
	IndividualActionPathSuccess []bool                        `protobuf:"varint,7,rep,packed,name=IndividualActionPathSuccess,proto3" json:"IndividualActionPathSuccess,omitempty"`
	ConfigData                  [][]byte                      `protobuf:"bytes,8,rep,name=ConfigData,proto3" json:"ConfigData,omitempty"`
	StatusData                  [][]byte                      `protobuf:"bytes,9,rep,name=StatusData,proto3" json:"StatusData,omitempty"`
	Dependencies                []string                      `protobuf:"bytes,10,rep,name=Dependencies,proto3" json:"Dependencies,omitempty"`
	LeafRefDependencies         []string                      `protobuf:"bytes,11,rep,name=LeafRefDependencies,proto3" json:"LeafRefDependencies,omitempty"`
	// contains filtered or unexported fields
}

func (*CacheUpdateRequest) Descriptor deprecated added in v0.1.12 

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

Deprecated: Use CacheUpdateRequest.ProtoReflect.Descriptor instead.

func (*CacheUpdateRequest) GetAction added in v0.1.12 

func (x *CacheUpdateRequest) GetAction() CacheUpdateRequest_ActionType

func (*CacheUpdateRequest) GetAggregateActionPath added in v0.1.12 

func (x *CacheUpdateRequest) GetAggregateActionPath() string

func (*CacheUpdateRequest) GetAggregateActionPathSuccess added in v0.1.12 

func (x *CacheUpdateRequest) GetAggregateActionPathSuccess() bool

func (*CacheUpdateRequest) GetConfigData added in v0.1.12 

func (x *CacheUpdateRequest) GetConfigData() [][]byte

func (*CacheUpdateRequest) GetDependencies added in v0.1.12 

func (x *CacheUpdateRequest) GetDependencies() []string

func (*CacheUpdateRequest) GetIndividualActionPath added in v0.1.12 

func (x *CacheUpdateRequest) GetIndividualActionPath() []string

func (*CacheUpdateRequest) GetIndividualActionPathSuccess added in v0.1.12 

func (x *CacheUpdateRequest) GetIndividualActionPathSuccess() []bool

func (*CacheUpdateRequest) GetLeafRefDependencies added in v0.1.18 

func (x *CacheUpdateRequest) GetLeafRefDependencies() []string

func (*CacheUpdateRequest) GetLevel added in v0.1.12 

func (x *CacheUpdateRequest) GetLevel() int32

func (*CacheUpdateRequest) GetResource added in v0.1.12 

func (x *CacheUpdateRequest) GetResource() string

func (*CacheUpdateRequest) GetStatusData added in v0.1.12 

func (x *CacheUpdateRequest) GetStatusData() [][]byte

func (*CacheUpdateRequest) ProtoMessage added in v0.1.12 

func (*CacheUpdateRequest) ProtoMessage()

func (*CacheUpdateRequest) ProtoReflect added in v0.1.12 

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

func (*CacheUpdateRequest) Reset added in v0.1.12 

func (x *CacheUpdateRequest) Reset()

func (*CacheUpdateRequest) String added in v0.1.12 

func (x *CacheUpdateRequest) String() string

type CacheUpdateRequest_ActionType added in v0.1.12 

type CacheUpdateRequest_ActionType int32
const (
	CacheUpdateRequest_ActionReplace CacheUpdateRequest_ActionType = 0
	CacheUpdateRequest_ActionUpdate  CacheUpdateRequest_ActionType = 1
	CacheUpdateRequest_ActionDelete  CacheUpdateRequest_ActionType = 2
)

func (CacheUpdateRequest_ActionType) Descriptor added in v0.1.12 

func (CacheUpdateRequest_ActionType) Descriptor() protoreflect.EnumDescriptor

func (CacheUpdateRequest_ActionType) Enum added in v0.1.12 

func (x CacheUpdateRequest_ActionType) Enum() *CacheUpdateRequest_ActionType

func (CacheUpdateRequest_ActionType) EnumDescriptor deprecated added in v0.1.12 

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

Deprecated: Use CacheUpdateRequest_ActionType.Descriptor instead.

func (CacheUpdateRequest_ActionType) Number added in v0.1.12 

func (x CacheUpdateRequest_ActionType) Number() protoreflect.EnumNumber

func (CacheUpdateRequest_ActionType) String added in v0.1.12 

func (x CacheUpdateRequest_ActionType) String() string

func (CacheUpdateRequest_ActionType) Type added in v0.1.12 

func (CacheUpdateRequest_ActionType) Type() protoreflect.EnumType

type CacheUpdateServer added in v0.1.12 

type CacheUpdateServer interface {
	Update(context.Context, *CacheUpdateRequest) (*CacheUpdateReply, error)
	// contains filtered or unexported methods
}

CacheUpdateServer is the server API for CacheUpdate service. All implementations must embed UnimplementedCacheUpdateServer for forward compatibility

type Deviation added in v0.1.20 

type Deviation struct {
	OnChange       Deviation_OnChangeAction  `protobuf:"varint,1,opt,name=OnChange,proto3,enum=netwdevpb.Deviation_OnChangeAction" json:"OnChange,omitempty"`
	Xpath          string                    `protobuf:"bytes,2,opt,name=Xpath,proto3" json:"Xpath,omitempty"`
	Value          []byte                    `protobuf:"bytes,3,opt,name=Value,proto3" json:"Value,omitempty"`
	DevationResult Deviation_DeviationAction `protobuf:"varint,4,opt,name=DevationResult,proto3,enum=netwdevpb.Deviation_DeviationAction" json:"DevationResult,omitempty"`
	// contains filtered or unexported fields
}

func (*Deviation) Descriptor deprecated added in v0.1.20 

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

Deprecated: Use Deviation.ProtoReflect.Descriptor instead.

func (*Deviation) GetDevationResult added in v0.1.20 

func (x *Deviation) GetDevationResult() Deviation_DeviationAction

func (*Deviation) GetOnChange added in v0.1.20 

func (x *Deviation) GetOnChange() Deviation_OnChangeAction

func (*Deviation) GetValue added in v0.1.20 

func (x *Deviation) GetValue() []byte

func (*Deviation) GetXpath added in v0.1.20 

func (x *Deviation) GetXpath() string

func (*Deviation) ProtoMessage added in v0.1.20 

func (*Deviation) ProtoMessage()

func (*Deviation) ProtoReflect added in v0.1.20 

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

func (*Deviation) Reset added in v0.1.20 

func (x *Deviation) Reset()

func (*Deviation) String added in v0.1.20 

func (x *Deviation) String() string

type DeviationUpdateClient added in v0.1.20 

type DeviationUpdateClient interface {
	Update(ctx context.Context, in *DeviationUpdateRequest, opts ...grpc.CallOption) (*DeviationUpdateReply, error)
}

DeviationUpdateClient is the client API for DeviationUpdate 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 NewDeviationUpdateClient added in v0.1.20 

func NewDeviationUpdateClient(cc grpc.ClientConnInterface) DeviationUpdateClient

type DeviationUpdateReply added in v0.1.19 

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

func (*DeviationUpdateReply) Descriptor deprecated added in v0.1.19 

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

Deprecated: Use DeviationUpdateReply.ProtoReflect.Descriptor instead.

func (*DeviationUpdateReply) ProtoMessage added in v0.1.19 

func (*DeviationUpdateReply) ProtoMessage()

func (*DeviationUpdateReply) ProtoReflect added in v0.1.19 

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

func (*DeviationUpdateReply) Reset added in v0.1.19 

func (x *DeviationUpdateReply) Reset()

func (*DeviationUpdateReply) String added in v0.1.19 

func (x *DeviationUpdateReply) String() string

type DeviationUpdateRequest added in v0.1.20 

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

func (*DeviationUpdateRequest) Descriptor deprecated added in v0.1.20 

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

Deprecated: Use DeviationUpdateRequest.ProtoReflect.Descriptor instead.

func (*DeviationUpdateRequest) GetDeviations added in v0.1.21 

func (x *DeviationUpdateRequest) GetDeviations() []*Deviation

func (*DeviationUpdateRequest) ProtoMessage added in v0.1.20 

func (*DeviationUpdateRequest) ProtoMessage()

func (*DeviationUpdateRequest) ProtoReflect added in v0.1.20 

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

func (*DeviationUpdateRequest) Reset added in v0.1.20 

func (x *DeviationUpdateRequest) Reset()

func (*DeviationUpdateRequest) String added in v0.1.20 

func (x *DeviationUpdateRequest) String() string

type DeviationUpdateServer added in v0.1.20 

type DeviationUpdateServer interface {
	Update(context.Context, *DeviationUpdateRequest) (*DeviationUpdateReply, error)
	// contains filtered or unexported methods
}

DeviationUpdateServer is the server API for DeviationUpdate service. All implementations must embed UnimplementedDeviationUpdateServer for forward compatibility

type Deviation_DeviationAction added in v0.1.20 

type Deviation_DeviationAction int32
const (
	Deviation_DeviationActionIgnore                Deviation_DeviationAction = 0
	Deviation_DeviationActionReApplyCache          Deviation_DeviationAction = 1
	Deviation_DeviationActionDelete                Deviation_DeviationAction = 2
	Deviation_DeviationActionDeleteIgnoredByParent Deviation_DeviationAction = 3
	Deviation_DeviationActionIgnoreException       Deviation_DeviationAction = 4
)

func (Deviation_DeviationAction) Descriptor added in v0.1.20 

func (Deviation_DeviationAction) Descriptor() protoreflect.EnumDescriptor

func (Deviation_DeviationAction) Enum added in v0.1.20 

func (x Deviation_DeviationAction) Enum() *Deviation_DeviationAction

func (Deviation_DeviationAction) EnumDescriptor deprecated added in v0.1.20 

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

Deprecated: Use Deviation_DeviationAction.Descriptor instead.

func (Deviation_DeviationAction) Number added in v0.1.20 

func (x Deviation_DeviationAction) Number() protoreflect.EnumNumber

func (Deviation_DeviationAction) String added in v0.1.20 

func (x Deviation_DeviationAction) String() string

func (Deviation_DeviationAction) Type added in v0.1.20 

func (Deviation_DeviationAction) Type() protoreflect.EnumType

type Deviation_OnChangeAction added in v0.1.20 

type Deviation_OnChangeAction int32
const (
	Deviation_OnChangeActionUpdate Deviation_OnChangeAction = 0
	Deviation_OnChangeActionDelete Deviation_OnChangeAction = 1
)

func (Deviation_OnChangeAction) Descriptor added in v0.1.20 

func (Deviation_OnChangeAction) Descriptor() protoreflect.EnumDescriptor

func (Deviation_OnChangeAction) Enum added in v0.1.20 

func (x Deviation_OnChangeAction) Enum() *Deviation_OnChangeAction

func (Deviation_OnChangeAction) EnumDescriptor deprecated added in v0.1.20 

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

Deprecated: Use Deviation_OnChangeAction.Descriptor instead.

func (Deviation_OnChangeAction) Number added in v0.1.20 

func (x Deviation_OnChangeAction) Number() protoreflect.EnumNumber

func (Deviation_OnChangeAction) String added in v0.1.20 

func (x Deviation_OnChangeAction) String() string

func (Deviation_OnChangeAction) Type added in v0.1.20 

func (Deviation_OnChangeAction) Type() protoreflect.EnumType

type RegistrationClient added in v0.1.25 

type RegistrationClient interface {
	Register(ctx context.Context, in *RegistrationRequest, opts ...grpc.CallOption) (*RegistrationReply, error)
	DeRegister(ctx context.Context, in *RegistrationRequest, opts ...grpc.CallOption) (*RegistrationReply, error)
}

RegistrationClient is the client API for Registration 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 NewRegistrationClient added in v0.1.25 

func NewRegistrationClient(cc grpc.ClientConnInterface) RegistrationClient

type RegistrationReply added in v0.1.25 

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

func (*RegistrationReply) Descriptor deprecated added in v0.1.25 

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

Deprecated: Use RegistrationReply.ProtoReflect.Descriptor instead.

func (*RegistrationReply) ProtoMessage added in v0.1.25 

func (*RegistrationReply) ProtoMessage()

func (*RegistrationReply) ProtoReflect added in v0.1.25 

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

func (*RegistrationReply) Reset added in v0.1.25 

func (x *RegistrationReply) Reset()

func (*RegistrationReply) String added in v0.1.25 

func (x *RegistrationReply) String() string

type RegistrationRequest added in v0.1.25 

type RegistrationRequest struct {
	DeviceType             string   `protobuf:"bytes,1,opt,name=DeviceType,proto3" json:"DeviceType,omitempty"`
	MatchString            string   `protobuf:"bytes,2,opt,name=MatchString,proto3" json:"MatchString,omitempty"`
	Subscriptions          []string `protobuf:"bytes,3,rep,name=Subscriptions,proto3" json:"Subscriptions,omitempty"`
	ExcpetionPaths         []string `protobuf:"bytes,4,rep,name=ExcpetionPaths,proto3" json:"ExcpetionPaths,omitempty"`
	ExplicitExceptionPaths []string `protobuf:"bytes,5,rep,name=ExplicitExceptionPaths,proto3" json:"ExplicitExceptionPaths,omitempty"`
	// contains filtered or unexported fields
}

func (*RegistrationRequest) Descriptor deprecated added in v0.1.25 

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

Deprecated: Use RegistrationRequest.ProtoReflect.Descriptor instead.

func (*RegistrationRequest) GetDeviceType added in v0.1.27 

func (x *RegistrationRequest) GetDeviceType() string

func (*RegistrationRequest) GetExcpetionPaths added in v0.1.25 

func (x *RegistrationRequest) GetExcpetionPaths() []string

func (*RegistrationRequest) GetExplicitExceptionPaths added in v0.1.25 

func (x *RegistrationRequest) GetExplicitExceptionPaths() []string

func (*RegistrationRequest) GetMatchString added in v0.1.27 

func (x *RegistrationRequest) GetMatchString() string

func (*RegistrationRequest) GetSubscriptions added in v0.1.25 

func (x *RegistrationRequest) GetSubscriptions() []string

func (*RegistrationRequest) ProtoMessage added in v0.1.25 

func (*RegistrationRequest) ProtoMessage()

func (*RegistrationRequest) ProtoReflect added in v0.1.25 

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

func (*RegistrationRequest) Reset added in v0.1.25 

func (x *RegistrationRequest) Reset()

func (*RegistrationRequest) String added in v0.1.25 

func (x *RegistrationRequest) String() string

type RegistrationServer added in v0.1.25 

type RegistrationServer interface {
	Register(context.Context, *RegistrationRequest) (*RegistrationReply, error)
	DeRegister(context.Context, *RegistrationRequest) (*RegistrationReply, error)
	// contains filtered or unexported methods
}

RegistrationServer is the server API for Registration service. All implementations must embed UnimplementedRegistrationServer for forward compatibility

type UnimplementedCacheStatusServer added in v0.1.7 

type UnimplementedCacheStatusServer struct {
}

UnimplementedCacheStatusServer must be embedded to have forward compatible implementations.

func (UnimplementedCacheStatusServer) Request added in v0.1.7 

func (UnimplementedCacheStatusServer) Request(context.Context, *CacheStatusRequest) (*CacheStatusReply, error)

type UnimplementedCacheUpdateServer added in v0.1.12 

type UnimplementedCacheUpdateServer struct {
}

UnimplementedCacheUpdateServer must be embedded to have forward compatible implementations.

func (UnimplementedCacheUpdateServer) Update added in v0.1.12 

func (UnimplementedCacheUpdateServer) Update(context.Context, *CacheUpdateRequest) (*CacheUpdateReply, error)

type UnimplementedDeviationUpdateServer added in v0.1.20 

type UnimplementedDeviationUpdateServer struct {
}

UnimplementedDeviationUpdateServer must be embedded to have forward compatible implementations.

func (UnimplementedDeviationUpdateServer) Update added in v0.1.20 

func (UnimplementedDeviationUpdateServer) Update(context.Context, *DeviationUpdateRequest) (*DeviationUpdateReply, error)

type UnimplementedRegistrationServer added in v0.1.25 

type UnimplementedRegistrationServer struct {
}

UnimplementedRegistrationServer must be embedded to have forward compatible implementations.

func (UnimplementedRegistrationServer) DeRegister added in v0.1.26 

func (UnimplementedRegistrationServer) DeRegister(context.Context, *RegistrationRequest) (*RegistrationReply, error)

func (UnimplementedRegistrationServer) Register added in v0.1.25 

func (UnimplementedRegistrationServer) Register(context.Context, *RegistrationRequest) (*RegistrationReply, error)

type UnsafeCacheStatusServer added in v0.1.7 

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

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

type UnsafeCacheUpdateServer added in v0.1.12 

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

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

type UnsafeDeviationUpdateServer added in v0.1.20 

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

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

type UnsafeRegistrationServer added in v0.1.25 

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

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

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.