 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
  
    Index ¶
- Variables
- func RegisterCoreServer(s grpc.ServiceRegistrar, srv CoreServer)
- type CoreClient
- type CoreServer
- type HoneyventRequest
- func (*HoneyventRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HoneyventRequest) GetDurationMs() int64
- func (x *HoneyventRequest) GetError() string
- func (x *HoneyventRequest) GetFeature() string
- func (x *HoneyventRequest) GetFeatureData() map[string]string
- func (*HoneyventRequest) ProtoMessage()
- func (x *HoneyventRequest) ProtoReflect() protoreflect.Message
- func (x *HoneyventRequest) Reset()
- func (x *HoneyventRequest) String() string
 
- type PingRequest
- type PongReply
- type ReadCacheRequest
- type ReadCacheResponse
- func (*ReadCacheResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReadCacheResponse) GetData() []byte
- func (x *ReadCacheResponse) GetHit() bool
- func (*ReadCacheResponse) ProtoMessage()
- func (x *ReadCacheResponse) ProtoReflect() protoreflect.Message
- func (x *ReadCacheResponse) Reset()
- func (x *ReadCacheResponse) String() string
 
- type Reply
- type UnimplementedCoreServer
- func (UnimplementedCoreServer) Honeyvent(context.Context, *HoneyventRequest) (*Reply, error)
- func (UnimplementedCoreServer) Ping(context.Context, *PingRequest) (*PongReply, error)
- func (UnimplementedCoreServer) ReadCache(context.Context, *ReadCacheRequest) (*ReadCacheResponse, error)
- func (UnimplementedCoreServer) WriteCache(context.Context, *WriteCacheRequest) (*WriteCacheResult, error)
 
- type UnsafeCoreServer
- type WriteCacheRequest
- func (*WriteCacheRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WriteCacheRequest) GetData() []byte
- func (x *WriteCacheRequest) GetExpires() *timestamp.Timestamp
- func (x *WriteCacheRequest) GetKey() string
- func (*WriteCacheRequest) ProtoMessage()
- func (x *WriteCacheRequest) ProtoReflect() protoreflect.Message
- func (x *WriteCacheRequest) Reset()
- func (x *WriteCacheRequest) String() string
 
- type WriteCacheResult
- func (*WriteCacheResult) Descriptor() ([]byte, []int)deprecated
- func (x *WriteCacheResult) GetError() bool
- func (x *WriteCacheResult) GetMessage() string
- func (*WriteCacheResult) ProtoMessage()
- func (x *WriteCacheResult) ProtoReflect() protoreflect.Message
- func (x *WriteCacheResult) Reset()
- func (x *WriteCacheResult) String() string
 
Constants ¶
This section is empty.
Variables ¶
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)
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) GetMessage ¶
func (*PongReply) ProtoMessage ¶
func (*PongReply) ProtoMessage()
func (*PongReply) ProtoReflect ¶
func (x *PongReply) ProtoReflect() protoreflect.Message
type ReadCacheRequest ¶
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
            
          
  
    
  
      
      func (*ReadCacheRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadCacheRequest.ProtoReflect.Descriptor instead.
func (*ReadCacheRequest) GetKey ¶
func (x *ReadCacheRequest) GetKey() string
func (*ReadCacheRequest) ProtoMessage ¶
func (*ReadCacheRequest) ProtoMessage()
func (*ReadCacheRequest) ProtoReflect ¶
func (x *ReadCacheRequest) ProtoReflect() protoreflect.Message
func (*ReadCacheRequest) Reset ¶
func (x *ReadCacheRequest) Reset()
func (*ReadCacheRequest) String ¶
func (x *ReadCacheRequest) String() string
type ReadCacheResponse ¶
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
            
          
  
    
  
      
      func (*ReadCacheResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReadCacheResponse.ProtoReflect.Descriptor instead.
func (*ReadCacheResponse) GetData ¶
func (x *ReadCacheResponse) GetData() []byte
func (*ReadCacheResponse) GetHit ¶
func (x *ReadCacheResponse) GetHit() bool
func (*ReadCacheResponse) ProtoMessage ¶
func (*ReadCacheResponse) ProtoMessage()
func (*ReadCacheResponse) ProtoReflect ¶
func (x *ReadCacheResponse) ProtoReflect() protoreflect.Message
func (*ReadCacheResponse) Reset ¶
func (x *ReadCacheResponse) Reset()
func (*ReadCacheResponse) String ¶
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) ProtoMessage ¶
func (*Reply) ProtoMessage()
func (*Reply) ProtoReflect ¶
func (x *Reply) ProtoReflect() protoreflect.Message
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 ¶
func (UnimplementedCoreServer) ReadCache(context.Context, *ReadCacheRequest) (*ReadCacheResponse, error)
func (UnimplementedCoreServer) WriteCache ¶
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 ¶
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
            
          
  
    
  
      
      func (*WriteCacheRequest) Descriptor() ([]byte, []int)
Deprecated: Use WriteCacheRequest.ProtoReflect.Descriptor instead.
func (*WriteCacheRequest) GetData ¶
func (x *WriteCacheRequest) GetData() []byte
func (*WriteCacheRequest) GetExpires ¶
func (x *WriteCacheRequest) GetExpires() *timestamp.Timestamp
func (*WriteCacheRequest) GetKey ¶
func (x *WriteCacheRequest) GetKey() string
func (*WriteCacheRequest) ProtoMessage ¶
func (*WriteCacheRequest) ProtoMessage()
func (*WriteCacheRequest) ProtoReflect ¶
func (x *WriteCacheRequest) ProtoReflect() protoreflect.Message
func (*WriteCacheRequest) Reset ¶
func (x *WriteCacheRequest) Reset()
func (*WriteCacheRequest) String ¶
func (x *WriteCacheRequest) String() string
type WriteCacheResult ¶
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
            
          
  
    
  
      
      func (*WriteCacheResult) Descriptor() ([]byte, []int)
Deprecated: Use WriteCacheResult.ProtoReflect.Descriptor instead.
func (*WriteCacheResult) GetError ¶
func (x *WriteCacheResult) GetError() bool
func (*WriteCacheResult) GetMessage ¶
func (x *WriteCacheResult) GetMessage() string
func (*WriteCacheResult) ProtoMessage ¶
func (*WriteCacheResult) ProtoMessage()
func (*WriteCacheResult) ProtoReflect ¶
func (x *WriteCacheResult) ProtoReflect() protoreflect.Message
func (*WriteCacheResult) Reset ¶
func (x *WriteCacheResult) Reset()
func (*WriteCacheResult) String ¶
func (x *WriteCacheResult) String() string