netwdevpb

package module
v0.1.17 Latest Latest
Warning

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

 Go to latest Published: Mar 21, 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: "Replace",
		1: "Update",
		2: "Delete",
	}
	CacheUpdateRequest_ActionType_value = map[string]int32{
		"Replace": 0,
		"Update":  1,
		"Delete":  2,
	}
)

Enum value maps for CacheUpdateRequest_ActionType.

View Source 
var (
	CacheStatusReply_CacheResourceStatus_name = map[int32]string{
		0:  "ToBeProcessed",
		1:  "UpdateBeingProcessed",
		2:  "UpdateProcessedSuccess",
		3:  "UpdateProcessedSuccessNatsUpdatePending",
		4:  "UpdateProcessedFailed",
		5:  "UpdateProcessedFailedNatsUpdatePending",
		6:  "DependencyMissing",
		7:  "DeletePending",
		8:  "DeletePendingWithParentDependency",
		9:  "DeleteWithMissingDependency",
		10: "UpdatePending",
	}
	CacheStatusReply_CacheResourceStatus_value = map[string]int32{
		"ToBeProcessed":                           0,
		"UpdateBeingProcessed":                    1,
		"UpdateProcessedSuccess":                  2,
		"UpdateProcessedSuccessNatsUpdatePending": 3,
		"UpdateProcessedFailed":                   4,
		"UpdateProcessedFailedNatsUpdatePending":  5,
		"DependencyMissing":                       6,
		"DeletePending":                           7,
		"DeletePendingWithParentDependency":       8,
		"DeleteWithMissingDependency":             9,
		"UpdatePending":                           10,
	}
)

Enum value maps for CacheStatusReply_CacheResourceStatus.

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 File_configMessage_proto protoreflect.FileDescriptor

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)

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 (
	// ToBeProcessed -> new data, not processed
	CacheStatusReply_ToBeProcessed CacheStatusReply_CacheResourceStatus = 0
	// UpdateBeingProcessed -> data is merged in the tree
	CacheStatusReply_UpdateBeingProcessed CacheStatusReply_CacheResourceStatus = 1
	// UpdateProcessedSuccess -> data, processed successfully
	CacheStatusReply_UpdateProcessedSuccess CacheStatusReply_CacheResourceStatus = 2
	// UpdateProcessedSuccessNatsUpdatePending -> data, processed successfully but nats update is missing
	CacheStatusReply_UpdateProcessedSuccessNatsUpdatePending CacheStatusReply_CacheResourceStatus = 3
	// UpdateProcessedFailed -> data, processed unsuccessfully
	CacheStatusReply_UpdateProcessedFailed CacheStatusReply_CacheResourceStatus = 4
	// UpdateProcessedFailedNatsUpdatePending -> data, processing Failed but nats update is missing
	CacheStatusReply_UpdateProcessedFailedNatsUpdatePending CacheStatusReply_CacheResourceStatus = 5
	// DependencyMissing -> data with missing dependency
	CacheStatusReply_DependencyMissing CacheStatusReply_CacheResourceStatus = 6
	// DeletePending -> data with pending gnmi delete
	CacheStatusReply_DeletePending CacheStatusReply_CacheResourceStatus = 7
	// DeletePendingWithParentDependency -> data with pending parent gnmi delete
	CacheStatusReply_DeletePendingWithParentDependency CacheStatusReply_CacheResourceStatus = 8
	// DeleteWithMissingDependency -> data with No pending gnmi update
	CacheStatusReply_DeleteWithMissingDependency CacheStatusReply_CacheResourceStatus = 9
	// UpdatePending -> data with pending update
	CacheStatusReply_UpdatePending CacheStatusReply_CacheResourceStatus = 10
)

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"`
	// 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) 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_Replace CacheUpdateRequest_ActionType = 0
	CacheUpdateRequest_Update  CacheUpdateRequest_ActionType = 1
	CacheUpdateRequest_Delete  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 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 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.

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.