cdk

package
v1.50.0 Latest Latest
Warning

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

 Go to latest Published: Apr 29, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Core_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cdk.v1.Core",
	HandlerType: (*CoreServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _Core_Ping_Handler,
		},
		{
			MethodName: "Honeyvent",
			Handler:    _Core_Honeyvent_Handler,
		},
		{
			MethodName: "ReadCache",
			Handler:    _Core_ReadCache_Handler,
		},
		{
			MethodName: "WriteCache",
			Handler:    _Core_WriteCache_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/v1/cdk.proto",
}

Core_ServiceDesc is the grpc.ServiceDesc for Core 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_proto_v1_cdk_proto protoreflect.FileDescriptor

Functions

func RegisterCoreServer 

func RegisterCoreServer(s grpc.ServiceRegistrar, srv CoreServer)

Types

type CoreClient 

type CoreClient interface {
	// Sends a ping -> pong between server and client
	//
	//	Component -> CDK Server
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PongReply, error)
	// Sends a Honeyvent
	Honeyvent(ctx context.Context, in *HoneyventRequest, opts ...grpc.CallOption) (*Reply, error)
	// Read from CLI cache
	ReadCache(ctx context.Context, in *ReadCacheRequest, opts ...grpc.CallOption) (*ReadCacheResponse, error)
	// Write to CLI cache
	WriteCache(ctx context.Context, in *WriteCacheRequest, opts ...grpc.CallOption) (*WriteCacheResult, error)
}

CoreClient is the client API for Core 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 NewCoreClient 

func NewCoreClient(cc grpc.ClientConnInterface) CoreClient

type CoreServer 

type CoreServer interface {
	// Sends a ping -> pong between server and client
	//
	//	Component -> CDK Server
	Ping(context.Context, *PingRequest) (*PongReply, error)
	// Sends a Honeyvent
	Honeyvent(context.Context, *HoneyventRequest) (*Reply, error)
	// Read from CLI cache
	ReadCache(context.Context, *ReadCacheRequest) (*ReadCacheResponse, error)
	// Write to CLI cache
	WriteCache(context.Context, *WriteCacheRequest) (*WriteCacheResult, error)
	// contains filtered or unexported methods
}

CoreServer is the server API for Core service. All implementations must embed UnimplementedCoreServer for forward compatibility

type HoneyventRequest 

type HoneyventRequest struct {
	Feature     string            `protobuf:"bytes,1,opt,name=feature,proto3" json:"feature,omitempty"`
	FeatureData map[string]string `` /* 182-byte string literal not displayed */
	Error       string            `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	DurationMs  int64             `protobuf:"varint,4,opt,name=duration_ms,json=durationMs,proto3" json:"duration_ms,omitempty"`
	// contains filtered or unexported fields
}

func (*HoneyventRequest) Descriptor deprecated 

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

Deprecated: Use HoneyventRequest.ProtoReflect.Descriptor instead.

func (*HoneyventRequest) GetDurationMs 

func (x *HoneyventRequest) GetDurationMs() int64

func (*HoneyventRequest) GetError 

func (x *HoneyventRequest) GetError() string

func (*HoneyventRequest) GetFeature 

func (x *HoneyventRequest) GetFeature() string

func (*HoneyventRequest) GetFeatureData 

func (x *HoneyventRequest) GetFeatureData() map[string]string

func (*HoneyventRequest) ProtoMessage 

func (*HoneyventRequest) ProtoMessage()

func (*HoneyventRequest) ProtoReflect 

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

func (*HoneyventRequest) Reset 

func (x *HoneyventRequest) Reset()

func (*HoneyventRequest) String 

func (x *HoneyventRequest) String() string

type PingRequest 

type PingRequest struct {
	ComponentName string `protobuf:"bytes,1,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	// contains filtered or unexported fields
}

func (*PingRequest) Descriptor deprecated 

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) GetComponentName 

func (x *PingRequest) GetComponentName() string

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect 

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

func (*PingRequest) Reset 

func (x *PingRequest) Reset()

func (*PingRequest) String 

func (x *PingRequest) String() string

type PongReply 

type PongReply struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*PongReply) Descriptor deprecated 

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

Deprecated: Use PongReply.ProtoReflect.Descriptor instead.

func (*PongReply) GetMessage 

func (x *PongReply) GetMessage() string

func (*PongReply) ProtoMessage 

func (*PongReply) ProtoMessage()

func (*PongReply) ProtoReflect 

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

func (*PongReply) Reset 

func (x *PongReply) Reset()

func (*PongReply) String 

func (x *PongReply) String() string

type ReadCacheRequest added in v1.43.0 

type ReadCacheRequest struct {

	// name of the cache key to read
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

ReadCacheRequest is used to fetch data from the cache

func (*ReadCacheRequest) Descriptor deprecated added in v1.43.0 

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

Deprecated: Use ReadCacheRequest.ProtoReflect.Descriptor instead.

func (*ReadCacheRequest) GetKey added in v1.43.0 

func (x *ReadCacheRequest) GetKey() string

func (*ReadCacheRequest) ProtoMessage added in v1.43.0 

func (*ReadCacheRequest) ProtoMessage()

func (*ReadCacheRequest) ProtoReflect added in v1.43.0 

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

func (*ReadCacheRequest) Reset added in v1.43.0 

func (x *ReadCacheRequest) Reset()

func (*ReadCacheRequest) String added in v1.43.0 

func (x *ReadCacheRequest) String() string

type ReadCacheResponse added in v1.43.0 

type ReadCacheResponse struct {

	// hit is true when data was found, false otherwise
	Hit bool `protobuf:"varint,1,opt,name=hit,proto3" json:"hit,omitempty"`
	// empty if cache miss (hit == false)
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

ReadCacheResponse is the response type after a ReadCacheRequest is made

func (*ReadCacheResponse) Descriptor deprecated added in v1.43.0 

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

Deprecated: Use ReadCacheResponse.ProtoReflect.Descriptor instead.

func (*ReadCacheResponse) GetData added in v1.43.0 

func (x *ReadCacheResponse) GetData() []byte

func (*ReadCacheResponse) GetHit added in v1.43.0 

func (x *ReadCacheResponse) GetHit() bool

func (*ReadCacheResponse) ProtoMessage added in v1.43.0 

func (*ReadCacheResponse) ProtoMessage()

func (*ReadCacheResponse) ProtoReflect added in v1.43.0 

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

func (*ReadCacheResponse) Reset added in v1.43.0 

func (x *ReadCacheResponse) Reset()

func (*ReadCacheResponse) String added in v1.43.0 

func (x *ReadCacheResponse) String() string

type Reply 

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

Reply is a generic reply for for rpc definitions that only requires acknowledgement of the remote procedure

func (*Reply) Descriptor deprecated 

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

Deprecated: Use Reply.ProtoReflect.Descriptor instead.

func (*Reply) ProtoMessage 

func (*Reply) ProtoMessage()

func (*Reply) ProtoReflect 

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

func (*Reply) Reset 

func (x *Reply) Reset()

func (*Reply) String 

func (x *Reply) String() string

type UnimplementedCoreServer 

type UnimplementedCoreServer struct {
}

UnimplementedCoreServer must be embedded to have forward compatible implementations.

func (UnimplementedCoreServer) Honeyvent 

func (UnimplementedCoreServer) Honeyvent(context.Context, *HoneyventRequest) (*Reply, error)

func (UnimplementedCoreServer) Ping 

func (UnimplementedCoreServer) Ping(context.Context, *PingRequest) (*PongReply, error)

func (UnimplementedCoreServer) ReadCache added in v1.43.0 

func (UnimplementedCoreServer) ReadCache(context.Context, *ReadCacheRequest) (*ReadCacheResponse, error)

func (UnimplementedCoreServer) WriteCache added in v1.43.0 

func (UnimplementedCoreServer) WriteCache(context.Context, *WriteCacheRequest) (*WriteCacheResult, error)

type UnsafeCoreServer 

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

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

type WriteCacheRequest added in v1.43.0 

type WriteCacheRequest struct {

	// name of the cache key to write
	Key     string               `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Data    []byte               `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Expires *timestamp.Timestamp `protobuf:"bytes,3,opt,name=expires,proto3" json:"expires,omitempty"`
	// contains filtered or unexported fields
}

WriteCacheRequest is used to submit data that should be written to cache, included its expiry

func (*WriteCacheRequest) Descriptor deprecated added in v1.43.0 

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

Deprecated: Use WriteCacheRequest.ProtoReflect.Descriptor instead.

func (*WriteCacheRequest) GetData added in v1.43.0 

func (x *WriteCacheRequest) GetData() []byte

func (*WriteCacheRequest) GetExpires added in v1.43.0 

func (x *WriteCacheRequest) GetExpires() *timestamp.Timestamp

func (*WriteCacheRequest) GetKey added in v1.43.0 

func (x *WriteCacheRequest) GetKey() string

func (*WriteCacheRequest) ProtoMessage added in v1.43.0 

func (*WriteCacheRequest) ProtoMessage()

func (*WriteCacheRequest) ProtoReflect added in v1.43.0 

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

func (*WriteCacheRequest) Reset added in v1.43.0 

func (x *WriteCacheRequest) Reset()

func (*WriteCacheRequest) String added in v1.43.0 

func (x *WriteCacheRequest) String() string

type WriteCacheResult added in v1.43.0 

type WriteCacheResult struct {
	Error bool `protobuf:"varint,1,opt,name=error,proto3" json:"error,omitempty"`
	// message stores the error body if error == true, otherwise empty
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

WriteCacheResult is the response type after a WriteCacheRequest is made

func (*WriteCacheResult) Descriptor deprecated added in v1.43.0 

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

Deprecated: Use WriteCacheResult.ProtoReflect.Descriptor instead.

func (*WriteCacheResult) GetError added in v1.43.0 

func (x *WriteCacheResult) GetError() bool

func (*WriteCacheResult) GetMessage added in v1.43.0 

func (x *WriteCacheResult) GetMessage() string

func (*WriteCacheResult) ProtoMessage added in v1.43.0 

func (*WriteCacheResult) ProtoMessage()

func (*WriteCacheResult) ProtoReflect added in v1.43.0 

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

func (*WriteCacheResult) Reset added in v1.43.0 

func (x *WriteCacheResult) Reset()

func (*WriteCacheResult) String added in v1.43.0 

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