launcher

package
v0.11.22 Latest Latest
Warning

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

 Go to latest Published: Jul 27, 2021 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var HealthCheckResponse_ServingStatus_name = map[int32]string{
	0: "UNKNOWN",
	1: "SERVING",
	2: "NOT_SERVING",
}
View Source 
var HealthCheckResponse_ServingStatus_value = map[string]int32{
	"UNKNOWN":     0,
	"SERVING":     1,
	"NOT_SERVING": 2,
}
View Source 
var LogCollection_LogType_name = map[int32]string{
	0: "RESULT",
	1: "STATUS",
	2: "AGENT",
}
View Source 
var LogCollection_LogType_value = map[string]int32{
	"RESULT": 0,
	"STATUS": 1,
	"AGENT":  2,
}

Functions

func RegisterApiServer 

func RegisterApiServer(s *grpc.Server, srv ApiServer)

Types

type AgentApiRequest 

type AgentApiRequest struct {
	NodeKey              string   `protobuf:"bytes,1,opt,name=node_key,json=nodeKey,proto3" json:"node_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentApiRequest) Descriptor 

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

func (*AgentApiRequest) GetNodeKey 

func (m *AgentApiRequest) GetNodeKey() string

func (*AgentApiRequest) ProtoMessage 

func (*AgentApiRequest) ProtoMessage()

func (*AgentApiRequest) Reset 

func (m *AgentApiRequest) Reset()

func (*AgentApiRequest) String 

func (m *AgentApiRequest) String() string

func (*AgentApiRequest) XXX_DiscardUnknown 

func (m *AgentApiRequest) XXX_DiscardUnknown()

func (*AgentApiRequest) XXX_Marshal 

func (m *AgentApiRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AgentApiRequest) XXX_Merge 

func (m *AgentApiRequest) XXX_Merge(src proto.Message)

func (*AgentApiRequest) XXX_Size 

func (m *AgentApiRequest) XXX_Size() int

func (*AgentApiRequest) XXX_Unmarshal 

func (m *AgentApiRequest) XXX_Unmarshal(b []byte) error

type AgentApiResponse 

type AgentApiResponse struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	ErrorCode            string   `protobuf:"bytes,2,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
	NodeInvalid          bool     `protobuf:"varint,3,opt,name=node_invalid,json=nodeInvalid,proto3" json:"node_invalid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentApiResponse) Descriptor 

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

func (*AgentApiResponse) GetErrorCode 

func (m *AgentApiResponse) GetErrorCode() string

func (*AgentApiResponse) GetMessage 

func (m *AgentApiResponse) GetMessage() string

func (*AgentApiResponse) GetNodeInvalid 

func (m *AgentApiResponse) GetNodeInvalid() bool

func (*AgentApiResponse) ProtoMessage 

func (*AgentApiResponse) ProtoMessage()

func (*AgentApiResponse) Reset 

func (m *AgentApiResponse) Reset()

func (*AgentApiResponse) String 

func (m *AgentApiResponse) String() string

func (*AgentApiResponse) XXX_DiscardUnknown 

func (m *AgentApiResponse) XXX_DiscardUnknown()

func (*AgentApiResponse) XXX_Marshal 

func (m *AgentApiResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AgentApiResponse) XXX_Merge 

func (m *AgentApiResponse) XXX_Merge(src proto.Message)

func (*AgentApiResponse) XXX_Size 

func (m *AgentApiResponse) XXX_Size() int

func (*AgentApiResponse) XXX_Unmarshal 

func (m *AgentApiResponse) XXX_Unmarshal(b []byte) error

type ApiClient 

type ApiClient interface {
	// Attempt to enroll a host with kolide/cloud
	RequestEnrollment(ctx context.Context, in *EnrollmentRequest, opts ...grpc.CallOption) (*EnrollmentResponse, error)
	// request an updated configuration from kolide/cloud
	// a generic request object is sent
	RequestConfig(ctx context.Context, in *AgentApiRequest, opts ...grpc.CallOption) (*ConfigResponse, error)
	// request/pull Dist queries from kolide/cloud
	// a generic request object is sent
	RequestQueries(ctx context.Context, in *AgentApiRequest, opts ...grpc.CallOption) (*QueryCollection, error)
	// publish logs from osqueryd to kolide/cloud
	// a generic response object is returned
	PublishLogs(ctx context.Context, in *LogCollection, opts ...grpc.CallOption) (*AgentApiResponse, error)
	// publish results from Dist queries to kolide/cloud
	// a generic response object is returned
	PublishResults(ctx context.Context, in *ResultCollection, opts ...grpc.CallOption) (*AgentApiResponse, error)
	// check the health of the GRPC server
	// a value indicating healthiness is returned
	// if you don't hear from this endpoint assume the worst
	CheckHealth(ctx context.Context, in *AgentApiRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
}

ApiClient is the client API for Api service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewApiClient 

func NewApiClient(cc *grpc.ClientConn) ApiClient

type ApiServer 

type ApiServer interface {
	// Attempt to enroll a host with kolide/cloud
	RequestEnrollment(context.Context, *EnrollmentRequest) (*EnrollmentResponse, error)
	// request an updated configuration from kolide/cloud
	// a generic request object is sent
	RequestConfig(context.Context, *AgentApiRequest) (*ConfigResponse, error)
	// request/pull Dist queries from kolide/cloud
	// a generic request object is sent
	RequestQueries(context.Context, *AgentApiRequest) (*QueryCollection, error)
	// publish logs from osqueryd to kolide/cloud
	// a generic response object is returned
	PublishLogs(context.Context, *LogCollection) (*AgentApiResponse, error)
	// publish results from Dist queries to kolide/cloud
	// a generic response object is returned
	PublishResults(context.Context, *ResultCollection) (*AgentApiResponse, error)
	// check the health of the GRPC server
	// a value indicating healthiness is returned
	// if you don't hear from this endpoint assume the worst
	CheckHealth(context.Context, *AgentApiRequest) (*HealthCheckResponse, error)
}

ApiServer is the server API for Api service.

type ConfigResponse 

type ConfigResponse struct {
	ConfigJsonBlob       string   `protobuf:"bytes,1,opt,name=config_json_blob,json=configJsonBlob,proto3" json:"config_json_blob,omitempty"`
	NodeInvalid          bool     `protobuf:"varint,2,opt,name=node_invalid,json=nodeInvalid,proto3" json:"node_invalid,omitempty"`
	ErrorCode            string   `protobuf:"bytes,3,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

kolide/cloud will be generating well-structured json already, so forward it along instead of de/re/de-serializing it as a protobuf too this might make sense to convert to full proto later

func (*ConfigResponse) Descriptor 

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

func (*ConfigResponse) GetConfigJsonBlob 

func (m *ConfigResponse) GetConfigJsonBlob() string

func (*ConfigResponse) GetErrorCode 

func (m *ConfigResponse) GetErrorCode() string

func (*ConfigResponse) GetNodeInvalid 

func (m *ConfigResponse) GetNodeInvalid() bool

func (*ConfigResponse) ProtoMessage 

func (*ConfigResponse) ProtoMessage()

func (*ConfigResponse) Reset 

func (m *ConfigResponse) Reset()

func (*ConfigResponse) String 

func (m *ConfigResponse) String() string

func (*ConfigResponse) XXX_DiscardUnknown 

func (m *ConfigResponse) XXX_DiscardUnknown()

func (*ConfigResponse) XXX_Marshal 

func (m *ConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigResponse) XXX_Merge 

func (m *ConfigResponse) XXX_Merge(src proto.Message)

func (*ConfigResponse) XXX_Size 

func (m *ConfigResponse) XXX_Size() int

func (*ConfigResponse) XXX_Unmarshal 

func (m *ConfigResponse) XXX_Unmarshal(b []byte) error

type EnrollmentDetails 

type EnrollmentDetails struct {
	OsVersion            string   `protobuf:"bytes,1,opt,name=os_version,json=osVersion,proto3" json:"os_version,omitempty"`
	OsBuild              string   `protobuf:"bytes,2,opt,name=os_build,json=osBuild,proto3" json:"os_build,omitempty"`
	OsPlatform           string   `protobuf:"bytes,3,opt,name=os_platform,json=osPlatform,proto3" json:"os_platform,omitempty"`
	Hostname             string   `protobuf:"bytes,4,opt,name=hostname,proto3" json:"hostname,omitempty"`
	HardwareVendor       string   `protobuf:"bytes,5,opt,name=hardware_vendor,json=hardwareVendor,proto3" json:"hardware_vendor,omitempty"`
	HardwareModel        string   `protobuf:"bytes,6,opt,name=hardware_model,json=hardwareModel,proto3" json:"hardware_model,omitempty"`
	HardwareSerial       string   `protobuf:"bytes,7,opt,name=hardware_serial,json=hardwareSerial,proto3" json:"hardware_serial,omitempty"`
	OsqueryVersion       string   `protobuf:"bytes,8,opt,name=osquery_version,json=osqueryVersion,proto3" json:"osquery_version,omitempty"`
	LauncherVersion      string   `protobuf:"bytes,9,opt,name=launcher_version,json=launcherVersion,proto3" json:"launcher_version,omitempty"`
	OsName               string   `protobuf:"bytes,10,opt,name=os_name,json=osName,proto3" json:"os_name,omitempty"`
	OsPlatformLike       string   `protobuf:"bytes,11,opt,name=os_platform_like,json=osPlatformLike,proto3" json:"os_platform_like,omitempty"`
	HardwareUuid         string   `protobuf:"bytes,12,opt,name=hardware_uuid,json=hardwareUuid,proto3" json:"hardware_uuid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EnrollmentDetails) Descriptor 

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

func (*EnrollmentDetails) GetHardwareModel 

func (m *EnrollmentDetails) GetHardwareModel() string

func (*EnrollmentDetails) GetHardwareSerial 

func (m *EnrollmentDetails) GetHardwareSerial() string

func (*EnrollmentDetails) GetHardwareUuid added in v0.11.15 

func (m *EnrollmentDetails) GetHardwareUuid() string

func (*EnrollmentDetails) GetHardwareVendor 

func (m *EnrollmentDetails) GetHardwareVendor() string

func (*EnrollmentDetails) GetHostname 

func (m *EnrollmentDetails) GetHostname() string

func (*EnrollmentDetails) GetLauncherVersion 

func (m *EnrollmentDetails) GetLauncherVersion() string

func (*EnrollmentDetails) GetOsBuild 

func (m *EnrollmentDetails) GetOsBuild() string

func (*EnrollmentDetails) GetOsName 

func (m *EnrollmentDetails) GetOsName() string

func (*EnrollmentDetails) GetOsPlatform 

func (m *EnrollmentDetails) GetOsPlatform() string

func (*EnrollmentDetails) GetOsPlatformLike 

func (m *EnrollmentDetails) GetOsPlatformLike() string

func (*EnrollmentDetails) GetOsVersion 

func (m *EnrollmentDetails) GetOsVersion() string

func (*EnrollmentDetails) GetOsqueryVersion 

func (m *EnrollmentDetails) GetOsqueryVersion() string

func (*EnrollmentDetails) ProtoMessage 

func (*EnrollmentDetails) ProtoMessage()

func (*EnrollmentDetails) Reset 

func (m *EnrollmentDetails) Reset()

func (*EnrollmentDetails) String 

func (m *EnrollmentDetails) String() string

func (*EnrollmentDetails) XXX_DiscardUnknown 

func (m *EnrollmentDetails) XXX_DiscardUnknown()

func (*EnrollmentDetails) XXX_Marshal 

func (m *EnrollmentDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EnrollmentDetails) XXX_Merge 

func (m *EnrollmentDetails) XXX_Merge(src proto.Message)

func (*EnrollmentDetails) XXX_Size 

func (m *EnrollmentDetails) XXX_Size() int

func (*EnrollmentDetails) XXX_Unmarshal 

func (m *EnrollmentDetails) XXX_Unmarshal(b []byte) error

type EnrollmentRequest 

type EnrollmentRequest struct {
	EnrollSecret         string             `protobuf:"bytes,1,opt,name=enroll_secret,json=enrollSecret,proto3" json:"enroll_secret,omitempty"`
	HostIdentifier       string             `protobuf:"bytes,2,opt,name=host_identifier,json=hostIdentifier,proto3" json:"host_identifier,omitempty"`
	EnrollmentDetails    *EnrollmentDetails `protobuf:"bytes,3,opt,name=enrollment_details,json=enrollmentDetails,proto3" json:"enrollment_details,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*EnrollmentRequest) Descriptor 

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

func (*EnrollmentRequest) GetEnrollSecret 

func (m *EnrollmentRequest) GetEnrollSecret() string

func (*EnrollmentRequest) GetEnrollmentDetails 

func (m *EnrollmentRequest) GetEnrollmentDetails() *EnrollmentDetails

func (*EnrollmentRequest) GetHostIdentifier 

func (m *EnrollmentRequest) GetHostIdentifier() string

func (*EnrollmentRequest) ProtoMessage 

func (*EnrollmentRequest) ProtoMessage()

func (*EnrollmentRequest) Reset 

func (m *EnrollmentRequest) Reset()

func (*EnrollmentRequest) String 

func (m *EnrollmentRequest) String() string

func (*EnrollmentRequest) XXX_DiscardUnknown 

func (m *EnrollmentRequest) XXX_DiscardUnknown()

func (*EnrollmentRequest) XXX_Marshal 

func (m *EnrollmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EnrollmentRequest) XXX_Merge 

func (m *EnrollmentRequest) XXX_Merge(src proto.Message)

func (*EnrollmentRequest) XXX_Size 

func (m *EnrollmentRequest) XXX_Size() int

func (*EnrollmentRequest) XXX_Unmarshal 

func (m *EnrollmentRequest) XXX_Unmarshal(b []byte) error

type EnrollmentResponse 

type EnrollmentResponse struct {
	NodeKey              string   `protobuf:"bytes,1,opt,name=node_key,json=nodeKey,proto3" json:"node_key,omitempty"`
	NodeInvalid          bool     `protobuf:"varint,2,opt,name=node_invalid,json=nodeInvalid,proto3" json:"node_invalid,omitempty"`
	ErrorCode            string   `protobuf:"bytes,3,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EnrollmentResponse) Descriptor 

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

func (*EnrollmentResponse) GetErrorCode 

func (m *EnrollmentResponse) GetErrorCode() string

func (*EnrollmentResponse) GetNodeInvalid 

func (m *EnrollmentResponse) GetNodeInvalid() bool

func (*EnrollmentResponse) GetNodeKey 

func (m *EnrollmentResponse) GetNodeKey() string

func (*EnrollmentResponse) ProtoMessage 

func (*EnrollmentResponse) ProtoMessage()

func (*EnrollmentResponse) Reset 

func (m *EnrollmentResponse) Reset()

func (*EnrollmentResponse) String 

func (m *EnrollmentResponse) String() string

func (*EnrollmentResponse) XXX_DiscardUnknown 

func (m *EnrollmentResponse) XXX_DiscardUnknown()

func (*EnrollmentResponse) XXX_Marshal 

func (m *EnrollmentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EnrollmentResponse) XXX_Merge 

func (m *EnrollmentResponse) XXX_Merge(src proto.Message)

func (*EnrollmentResponse) XXX_Size 

func (m *EnrollmentResponse) XXX_Size() int

func (*EnrollmentResponse) XXX_Unmarshal 

func (m *EnrollmentResponse) XXX_Unmarshal(b []byte) error

type HealthCheckResponse 

type HealthCheckResponse struct {
	Status               HealthCheckResponse_ServingStatus `protobuf:"varint,1,opt,name=status,proto3,enum=kolide.agent.HealthCheckResponse_ServingStatus" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

func (*HealthCheckResponse) Descriptor 

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

func (*HealthCheckResponse) GetStatus 

func (m *HealthCheckResponse) GetStatus() HealthCheckResponse_ServingStatus

func (*HealthCheckResponse) ProtoMessage 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) Reset 

func (m *HealthCheckResponse) Reset()

func (*HealthCheckResponse) String 

func (m *HealthCheckResponse) String() string

func (*HealthCheckResponse) XXX_DiscardUnknown 

func (m *HealthCheckResponse) XXX_DiscardUnknown()

func (*HealthCheckResponse) XXX_Marshal 

func (m *HealthCheckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HealthCheckResponse) XXX_Merge 

func (m *HealthCheckResponse) XXX_Merge(src proto.Message)

func (*HealthCheckResponse) XXX_Size 

func (m *HealthCheckResponse) XXX_Size() int

func (*HealthCheckResponse) XXX_Unmarshal 

func (m *HealthCheckResponse) XXX_Unmarshal(b []byte) error

type HealthCheckResponse_ServingStatus 

type HealthCheckResponse_ServingStatus int32
const (
	HealthCheckResponse_UNKNOWN     HealthCheckResponse_ServingStatus = 0
	HealthCheckResponse_SERVING     HealthCheckResponse_ServingStatus = 1
	HealthCheckResponse_NOT_SERVING HealthCheckResponse_ServingStatus = 2
)

func (HealthCheckResponse_ServingStatus) EnumDescriptor 

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

func (HealthCheckResponse_ServingStatus) String 

func (x HealthCheckResponse_ServingStatus) String() string

type LogCollection 

type LogCollection struct {
	NodeKey              string                `protobuf:"bytes,1,opt,name=node_key,json=nodeKey,proto3" json:"node_key,omitempty"`
	LogType              LogCollection_LogType `protobuf:"varint,2,opt,name=log_type,json=logType,proto3,enum=kolide.agent.LogCollection_LogType" json:"log_type,omitempty"`
	Logs                 []*LogCollection_Log  `protobuf:"bytes,3,rep,name=logs,proto3" json:"logs,omitempty"`
	ErrorCode            string                `protobuf:"bytes,4,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*LogCollection) Descriptor 

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

func (*LogCollection) GetErrorCode 

func (m *LogCollection) GetErrorCode() string

func (*LogCollection) GetLogType 

func (m *LogCollection) GetLogType() LogCollection_LogType

func (*LogCollection) GetLogs 

func (m *LogCollection) GetLogs() []*LogCollection_Log

func (*LogCollection) GetNodeKey 

func (m *LogCollection) GetNodeKey() string

func (*LogCollection) ProtoMessage 

func (*LogCollection) ProtoMessage()

func (*LogCollection) Reset 

func (m *LogCollection) Reset()

func (*LogCollection) String 

func (m *LogCollection) String() string

func (*LogCollection) XXX_DiscardUnknown 

func (m *LogCollection) XXX_DiscardUnknown()

func (*LogCollection) XXX_Marshal 

func (m *LogCollection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogCollection) XXX_Merge 

func (m *LogCollection) XXX_Merge(src proto.Message)

func (*LogCollection) XXX_Size 

func (m *LogCollection) XXX_Size() int

func (*LogCollection) XXX_Unmarshal 

func (m *LogCollection) XXX_Unmarshal(b []byte) error

type LogCollection_Log 

type LogCollection_Log struct {
	Data                 string   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogCollection_Log) Descriptor 

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

func (*LogCollection_Log) GetData 

func (m *LogCollection_Log) GetData() string

func (*LogCollection_Log) ProtoMessage 

func (*LogCollection_Log) ProtoMessage()

func (*LogCollection_Log) Reset 

func (m *LogCollection_Log) Reset()

func (*LogCollection_Log) String 

func (m *LogCollection_Log) String() string

func (*LogCollection_Log) XXX_DiscardUnknown 

func (m *LogCollection_Log) XXX_DiscardUnknown()

func (*LogCollection_Log) XXX_Marshal 

func (m *LogCollection_Log) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogCollection_Log) XXX_Merge 

func (m *LogCollection_Log) XXX_Merge(src proto.Message)

func (*LogCollection_Log) XXX_Size 

func (m *LogCollection_Log) XXX_Size() int

func (*LogCollection_Log) XXX_Unmarshal 

func (m *LogCollection_Log) XXX_Unmarshal(b []byte) error

type LogCollection_LogType 

type LogCollection_LogType int32

AGENT is added as a new log type, for adding new logging capabilities from kolide/agent 

const (
	LogCollection_RESULT LogCollection_LogType = 0
	LogCollection_STATUS LogCollection_LogType = 1
	LogCollection_AGENT  LogCollection_LogType = 2
)

func (LogCollection_LogType) EnumDescriptor 

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

func (LogCollection_LogType) String 

func (x LogCollection_LogType) String() string

type QueryCollection 

type QueryCollection struct {
	Queries              []*QueryCollection_Query `protobuf:"bytes,1,rep,name=queries,proto3" json:"queries,omitempty"`
	NodeInvalid          bool                     `protobuf:"varint,2,opt,name=node_invalid,json=nodeInvalid,proto3" json:"node_invalid,omitempty"`
	ErrorCode            string                   `protobuf:"bytes,3,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

a query collection contains many queries

func (*QueryCollection) Descriptor 

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

func (*QueryCollection) GetErrorCode 

func (m *QueryCollection) GetErrorCode() string

func (*QueryCollection) GetNodeInvalid 

func (m *QueryCollection) GetNodeInvalid() bool

func (*QueryCollection) GetQueries 

func (m *QueryCollection) GetQueries() []*QueryCollection_Query

func (*QueryCollection) ProtoMessage 

func (*QueryCollection) ProtoMessage()

func (*QueryCollection) Reset 

func (m *QueryCollection) Reset()

func (*QueryCollection) String 

func (m *QueryCollection) String() string

func (*QueryCollection) XXX_DiscardUnknown 

func (m *QueryCollection) XXX_DiscardUnknown()

func (*QueryCollection) XXX_Marshal 

func (m *QueryCollection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryCollection) XXX_Merge 

func (m *QueryCollection) XXX_Merge(src proto.Message)

func (*QueryCollection) XXX_Size 

func (m *QueryCollection) XXX_Size() int

func (*QueryCollection) XXX_Unmarshal 

func (m *QueryCollection) XXX_Unmarshal(b []byte) error

type QueryCollection_Query 

type QueryCollection_Query struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Query                string   `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryCollection_Query) Descriptor 

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

func (*QueryCollection_Query) GetId 

func (m *QueryCollection_Query) GetId() string

func (*QueryCollection_Query) GetQuery 

func (m *QueryCollection_Query) GetQuery() string

func (*QueryCollection_Query) ProtoMessage 

func (*QueryCollection_Query) ProtoMessage()

func (*QueryCollection_Query) Reset 

func (m *QueryCollection_Query) Reset()

func (*QueryCollection_Query) String 

func (m *QueryCollection_Query) String() string

func (*QueryCollection_Query) XXX_DiscardUnknown 

func (m *QueryCollection_Query) XXX_DiscardUnknown()

func (*QueryCollection_Query) XXX_Marshal 

func (m *QueryCollection_Query) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryCollection_Query) XXX_Merge 

func (m *QueryCollection_Query) XXX_Merge(src proto.Message)

func (*QueryCollection_Query) XXX_Size 

func (m *QueryCollection_Query) XXX_Size() int

func (*QueryCollection_Query) XXX_Unmarshal 

func (m *QueryCollection_Query) XXX_Unmarshal(b []byte) error

type ResultCollection 

type ResultCollection struct {
	NodeKey              string                     `protobuf:"bytes,1,opt,name=node_key,json=nodeKey,proto3" json:"node_key,omitempty"`
	Results              []*ResultCollection_Result `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
	ErrorCode            string                     `protobuf:"bytes,3,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

a result collection contains many results

func (*ResultCollection) Descriptor 

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

func (*ResultCollection) GetErrorCode 

func (m *ResultCollection) GetErrorCode() string

func (*ResultCollection) GetNodeKey 

func (m *ResultCollection) GetNodeKey() string

func (*ResultCollection) GetResults 

func (m *ResultCollection) GetResults() []*ResultCollection_Result

func (*ResultCollection) ProtoMessage 

func (*ResultCollection) ProtoMessage()

func (*ResultCollection) Reset 

func (m *ResultCollection) Reset()

func (*ResultCollection) String 

func (m *ResultCollection) String() string

func (*ResultCollection) XXX_DiscardUnknown 

func (m *ResultCollection) XXX_DiscardUnknown()

func (*ResultCollection) XXX_Marshal 

func (m *ResultCollection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResultCollection) XXX_Merge 

func (m *ResultCollection) XXX_Merge(src proto.Message)

func (*ResultCollection) XXX_Size 

func (m *ResultCollection) XXX_Size() int

func (*ResultCollection) XXX_Unmarshal 

func (m *ResultCollection) XXX_Unmarshal(b []byte) error

type ResultCollection_Result 

type ResultCollection_Result struct {
	Id                   string                               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Rows                 []*ResultCollection_Result_ResultRow `protobuf:"bytes,2,rep,name=rows,proto3" json:"rows,omitempty"`
	Status               int32                                `protobuf:"varint,3,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                             `json:"-"`
	XXX_unrecognized     []byte                               `json:"-"`
	XXX_sizecache        int32                                `json:"-"`
}

status is moved here instead of appearing as a map of id[status] on the ResultCollection, as it does in the osq docs

func (*ResultCollection_Result) Descriptor 

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

func (*ResultCollection_Result) GetId 

func (m *ResultCollection_Result) GetId() string

func (*ResultCollection_Result) GetRows 

func (m *ResultCollection_Result) GetRows() []*ResultCollection_Result_ResultRow

func (*ResultCollection_Result) GetStatus 

func (m *ResultCollection_Result) GetStatus() int32

func (*ResultCollection_Result) ProtoMessage 

func (*ResultCollection_Result) ProtoMessage()

func (*ResultCollection_Result) Reset 

func (m *ResultCollection_Result) Reset()

func (*ResultCollection_Result) String 

func (m *ResultCollection_Result) String() string

func (*ResultCollection_Result) XXX_DiscardUnknown 

func (m *ResultCollection_Result) XXX_DiscardUnknown()

func (*ResultCollection_Result) XXX_Marshal 

func (m *ResultCollection_Result) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResultCollection_Result) XXX_Merge 

func (m *ResultCollection_Result) XXX_Merge(src proto.Message)

func (*ResultCollection_Result) XXX_Size 

func (m *ResultCollection_Result) XXX_Size() int

func (*ResultCollection_Result) XXX_Unmarshal 

func (m *ResultCollection_Result) XXX_Unmarshal(b []byte) error

type ResultCollection_Result_ResultRow 

type ResultCollection_Result_ResultRow struct {
	Columns              []*ResultCollection_Result_ResultRow_Column `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

func (*ResultCollection_Result_ResultRow) Descriptor 

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

func (*ResultCollection_Result_ResultRow) GetColumns 

func (m *ResultCollection_Result_ResultRow) GetColumns() []*ResultCollection_Result_ResultRow_Column

func (*ResultCollection_Result_ResultRow) ProtoMessage 

func (*ResultCollection_Result_ResultRow) ProtoMessage()

func (*ResultCollection_Result_ResultRow) Reset 

func (m *ResultCollection_Result_ResultRow) Reset()

func (*ResultCollection_Result_ResultRow) String 

func (m *ResultCollection_Result_ResultRow) String() string

func (*ResultCollection_Result_ResultRow) XXX_DiscardUnknown 

func (m *ResultCollection_Result_ResultRow) XXX_DiscardUnknown()

func (*ResultCollection_Result_ResultRow) XXX_Marshal 

func (m *ResultCollection_Result_ResultRow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResultCollection_Result_ResultRow) XXX_Merge 

func (m *ResultCollection_Result_ResultRow) XXX_Merge(src proto.Message)

func (*ResultCollection_Result_ResultRow) XXX_Size 

func (m *ResultCollection_Result_ResultRow) XXX_Size() int

func (*ResultCollection_Result_ResultRow) XXX_Unmarshal 

func (m *ResultCollection_Result_ResultRow) XXX_Unmarshal(b []byte) error

type ResultCollection_Result_ResultRow_Column 

type ResultCollection_Result_ResultRow_Column struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResultCollection_Result_ResultRow_Column) Descriptor 

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

func (*ResultCollection_Result_ResultRow_Column) GetName 

func (m *ResultCollection_Result_ResultRow_Column) GetName() string

func (*ResultCollection_Result_ResultRow_Column) GetValue 

func (m *ResultCollection_Result_ResultRow_Column) GetValue() string

func (*ResultCollection_Result_ResultRow_Column) ProtoMessage 

func (*ResultCollection_Result_ResultRow_Column) ProtoMessage()

func (*ResultCollection_Result_ResultRow_Column) Reset 

func (m *ResultCollection_Result_ResultRow_Column) Reset()

func (*ResultCollection_Result_ResultRow_Column) String 

func (m *ResultCollection_Result_ResultRow_Column) String() string

func (*ResultCollection_Result_ResultRow_Column) XXX_DiscardUnknown 

func (m *ResultCollection_Result_ResultRow_Column) XXX_DiscardUnknown()

func (*ResultCollection_Result_ResultRow_Column) XXX_Marshal 

func (m *ResultCollection_Result_ResultRow_Column) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResultCollection_Result_ResultRow_Column) XXX_Merge 

func (m *ResultCollection_Result_ResultRow_Column) XXX_Merge(src proto.Message)

func (*ResultCollection_Result_ResultRow_Column) XXX_Size 

func (m *ResultCollection_Result_ResultRow_Column) XXX_Size() int

func (*ResultCollection_Result_ResultRow_Column) XXX_Unmarshal 

func (m *ResultCollection_Result_ResultRow_Column) XXX_Unmarshal(b []byte) error

type UnimplementedApiServer added in v0.11.15 

type UnimplementedApiServer struct {
}

UnimplementedApiServer can be embedded to have forward compatible implementations.

func (*UnimplementedApiServer) CheckHealth added in v0.11.15 

func (*UnimplementedApiServer) CheckHealth(ctx context.Context, req *AgentApiRequest) (*HealthCheckResponse, error)

func (*UnimplementedApiServer) PublishLogs added in v0.11.15 

func (*UnimplementedApiServer) PublishLogs(ctx context.Context, req *LogCollection) (*AgentApiResponse, error)

func (*UnimplementedApiServer) PublishResults added in v0.11.15 

func (*UnimplementedApiServer) PublishResults(ctx context.Context, req *ResultCollection) (*AgentApiResponse, error)

func (*UnimplementedApiServer) RequestConfig added in v0.11.15 

func (*UnimplementedApiServer) RequestConfig(ctx context.Context, req *AgentApiRequest) (*ConfigResponse, error)

func (*UnimplementedApiServer) RequestEnrollment added in v0.11.15 

func (*UnimplementedApiServer) RequestEnrollment(ctx context.Context, req *EnrollmentRequest) (*EnrollmentResponse, error)

func (*UnimplementedApiServer) RequestQueries added in v0.11.15 

func (*UnimplementedApiServer) RequestQueries(ctx context.Context, req *AgentApiRequest) (*QueryCollection, error)

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.