Documentation ¶
Overview ¶
Package istio_v1_auth is a generated protocol buffer package. It is generated from these files: security/proto/ca_service.proto It has these top-level messages: CsrRequest CsrResponse
nolint
Package istio_v1_auth is a generated protocol buffer package. It is generated from these files: security/proto/nodeagent_service.proto It has these top-level messages: NodeAgentMgmtResponse WorkloadInfo Package istio_v1_auth is a generated protocol buffer package. It is generated from these files: security/proto/workload_service.proto It has these top-level messages: CheckRequest CheckResponse
Index ¶
- Variables
- func RegisterIstioCAServiceServer(s *grpc.Server, srv IstioCAServiceServer)
- func RegisterNodeAgentServiceServer(s *grpc.Server, srv NodeAgentServiceServer)
- func RegisterWorkloadServiceServer(s *grpc.Server, srv WorkloadServiceServer)
- type CheckRequest
- func (*CheckRequest) Descriptor() ([]byte, []int)
- func (this *CheckRequest) Equal(that interface{}) bool
- func (m *CheckRequest) GetName() string
- func (this *CheckRequest) GoString() string
- func (m *CheckRequest) Marshal() (dAtA []byte, err error)
- func (m *CheckRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CheckRequest) ProtoMessage()
- func (m *CheckRequest) Reset()
- func (m *CheckRequest) Size() (n int)
- func (this *CheckRequest) String() string
- func (m *CheckRequest) Unmarshal(dAtA []byte) error
- type CheckResponse
- func (*CheckResponse) Descriptor() ([]byte, []int)
- func (this *CheckResponse) Equal(that interface{}) bool
- func (m *CheckResponse) GetStatus() *google_rpc.Status
- func (this *CheckResponse) GoString() string
- func (m *CheckResponse) Marshal() (dAtA []byte, err error)
- func (m *CheckResponse) MarshalTo(dAtA []byte) (int, error)
- func (*CheckResponse) ProtoMessage()
- func (m *CheckResponse) Reset()
- func (m *CheckResponse) Size() (n int)
- func (this *CheckResponse) String() string
- func (m *CheckResponse) Unmarshal(dAtA []byte) error
- type CsrRequest
- func (*CsrRequest) Descriptor() ([]byte, []int)
- func (m *CsrRequest) Marshal() (dAtA []byte, err error)
- func (m *CsrRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CsrRequest) ProtoMessage()
- func (m *CsrRequest) Reset()
- func (m *CsrRequest) Size() (n int)
- func (this *CsrRequest) String() string
- func (m *CsrRequest) Unmarshal(dAtA []byte) error
- type CsrResponse
- func (*CsrResponse) Descriptor() ([]byte, []int)
- func (m *CsrResponse) Marshal() (dAtA []byte, err error)
- func (m *CsrResponse) MarshalTo(dAtA []byte) (int, error)
- func (*CsrResponse) ProtoMessage()
- func (m *CsrResponse) Reset()
- func (m *CsrResponse) Size() (n int)
- func (this *CsrResponse) String() string
- func (m *CsrResponse) Unmarshal(dAtA []byte) error
- type IstioCAServiceClient
- type IstioCAServiceServer
- type NodeAgentMgmtResponse
- func (*NodeAgentMgmtResponse) Descriptor() ([]byte, []int)
- func (this *NodeAgentMgmtResponse) Equal(that interface{}) bool
- func (m *NodeAgentMgmtResponse) GetStatus() *google_rpc.Status
- func (this *NodeAgentMgmtResponse) GoString() string
- func (m *NodeAgentMgmtResponse) Marshal() (dAtA []byte, err error)
- func (m *NodeAgentMgmtResponse) MarshalTo(dAtA []byte) (int, error)
- func (*NodeAgentMgmtResponse) ProtoMessage()
- func (m *NodeAgentMgmtResponse) Reset()
- func (m *NodeAgentMgmtResponse) Size() (n int)
- func (this *NodeAgentMgmtResponse) String() string
- func (m *NodeAgentMgmtResponse) Unmarshal(dAtA []byte) error
- type NodeAgentServiceClient
- type NodeAgentServiceServer
- type WorkloadInfo
- func (*WorkloadInfo) Descriptor() ([]byte, []int)
- func (this *WorkloadInfo) Equal(that interface{}) bool
- func (m *WorkloadInfo) GetAttrs() *WorkloadInfo_WorkloadAttributes
- func (m *WorkloadInfo) GetWorkloadpath() string
- func (this *WorkloadInfo) GoString() string
- func (m *WorkloadInfo) Marshal() (dAtA []byte, err error)
- func (m *WorkloadInfo) MarshalTo(dAtA []byte) (int, error)
- func (*WorkloadInfo) ProtoMessage()
- func (m *WorkloadInfo) Reset()
- func (m *WorkloadInfo) Size() (n int)
- func (this *WorkloadInfo) String() string
- func (m *WorkloadInfo) Unmarshal(dAtA []byte) error
- type WorkloadInfo_WorkloadAttributes
- func (*WorkloadInfo_WorkloadAttributes) Descriptor() ([]byte, []int)
- func (this *WorkloadInfo_WorkloadAttributes) Equal(that interface{}) bool
- func (m *WorkloadInfo_WorkloadAttributes) GetNamespace() string
- func (m *WorkloadInfo_WorkloadAttributes) GetServiceaccount() string
- func (m *WorkloadInfo_WorkloadAttributes) GetUid() string
- func (m *WorkloadInfo_WorkloadAttributes) GetWorkload() string
- func (this *WorkloadInfo_WorkloadAttributes) GoString() string
- func (m *WorkloadInfo_WorkloadAttributes) Marshal() (dAtA []byte, err error)
- func (m *WorkloadInfo_WorkloadAttributes) MarshalTo(dAtA []byte) (int, error)
- func (*WorkloadInfo_WorkloadAttributes) ProtoMessage()
- func (m *WorkloadInfo_WorkloadAttributes) Reset()
- func (m *WorkloadInfo_WorkloadAttributes) Size() (n int)
- func (this *WorkloadInfo_WorkloadAttributes) String() string
- func (m *WorkloadInfo_WorkloadAttributes) Unmarshal(dAtA []byte) error
- type WorkloadServiceClient
- type WorkloadServiceServer
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthCaService = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowCaService = fmt.Errorf("proto: integer overflow") )
View Source
var ( ErrInvalidLengthNodeagentService = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowNodeagentService = fmt.Errorf("proto: integer overflow") )
View Source
var ( ErrInvalidLengthWorkloadService = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowWorkloadService = fmt.Errorf("proto: integer overflow") )
Functions ¶
func RegisterIstioCAServiceServer ¶
func RegisterIstioCAServiceServer(s *grpc.Server, srv IstioCAServiceServer)
func RegisterNodeAgentServiceServer ¶
func RegisterNodeAgentServiceServer(s *grpc.Server, srv NodeAgentServiceServer)
func RegisterWorkloadServiceServer ¶
func RegisterWorkloadServiceServer(s *grpc.Server, srv WorkloadServiceServer)
Types ¶
type CheckRequest ¶
type CheckRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}
func (*CheckRequest) Descriptor ¶
func (*CheckRequest) Descriptor() ([]byte, []int)
func (*CheckRequest) Equal ¶
func (this *CheckRequest) Equal(that interface{}) bool
func (*CheckRequest) GetName ¶
func (m *CheckRequest) GetName() string
func (*CheckRequest) GoString ¶
func (this *CheckRequest) GoString() string
func (*CheckRequest) Marshal ¶
func (m *CheckRequest) Marshal() (dAtA []byte, err error)
func (*CheckRequest) ProtoMessage ¶
func (*CheckRequest) ProtoMessage()
func (*CheckRequest) Reset ¶
func (m *CheckRequest) Reset()
func (*CheckRequest) Size ¶
func (m *CheckRequest) Size() (n int)
func (*CheckRequest) String ¶
func (this *CheckRequest) String() string
func (*CheckRequest) Unmarshal ¶
func (m *CheckRequest) Unmarshal(dAtA []byte) error
type CheckResponse ¶
type CheckResponse struct {
Status *google_rpc.Status `protobuf:"bytes,1,opt,name=status" json:"status,omitempty"`
}
func (*CheckResponse) Descriptor ¶
func (*CheckResponse) Descriptor() ([]byte, []int)
func (*CheckResponse) Equal ¶
func (this *CheckResponse) Equal(that interface{}) bool
func (*CheckResponse) GetStatus ¶
func (m *CheckResponse) GetStatus() *google_rpc.Status
func (*CheckResponse) GoString ¶
func (this *CheckResponse) GoString() string
func (*CheckResponse) Marshal ¶
func (m *CheckResponse) Marshal() (dAtA []byte, err error)
func (*CheckResponse) ProtoMessage ¶
func (*CheckResponse) ProtoMessage()
func (*CheckResponse) Reset ¶
func (m *CheckResponse) Reset()
func (*CheckResponse) Size ¶
func (m *CheckResponse) Size() (n int)
func (*CheckResponse) String ¶
func (this *CheckResponse) String() string
func (*CheckResponse) Unmarshal ¶
func (m *CheckResponse) Unmarshal(dAtA []byte) error
type CsrRequest ¶
type CsrRequest struct { // PEM-encoded certificate signing request CsrPem []byte `protobuf:"bytes,1,opt,name=csr_pem,json=csrPem,proto3" json:"csr_pem,omitempty"` // opaque credential for node agent NodeAgentCredential []byte `protobuf:"bytes,2,opt,name=node_agent_credential,json=nodeAgentCredential,proto3" json:"node_agent_credential,omitempty"` // type of the node_agent_credential (aws/gcp/onprem/custom...) CredentialType string `protobuf:"bytes,3,opt,name=credential_type,json=credentialType,proto3" json:"credential_type,omitempty"` // the requested ttl of the certificate in minutes RequestedTtlMinutes int32 `protobuf:"varint,4,opt,name=requested_ttl_minutes,json=requestedTtlMinutes,proto3" json:"requested_ttl_minutes,omitempty"` }
func (*CsrRequest) Descriptor ¶
func (*CsrRequest) Descriptor() ([]byte, []int)
func (*CsrRequest) Marshal ¶
func (m *CsrRequest) Marshal() (dAtA []byte, err error)
func (*CsrRequest) ProtoMessage ¶
func (*CsrRequest) ProtoMessage()
func (*CsrRequest) Reset ¶
func (m *CsrRequest) Reset()
func (*CsrRequest) Size ¶
func (m *CsrRequest) Size() (n int)
func (*CsrRequest) String ¶
func (this *CsrRequest) String() string
func (*CsrRequest) Unmarshal ¶
func (m *CsrRequest) Unmarshal(dAtA []byte) error
type CsrResponse ¶
type CsrResponse struct { // Whether the CSR is approved. IsApproved bool `protobuf:"varint,1,opt,name=is_approved,json=isApproved,proto3" json:"is_approved,omitempty"` Status *google_rpc.Status `protobuf:"bytes,2,opt,name=status" json:"status,omitempty"` // The signed target cert. SignedCert []byte `protobuf:"bytes,3,opt,name=signed_cert,json=signedCert,proto3" json:"signed_cert,omitempty"` // The cert chain up to the trusted root cert. It includes all the certs between the // newly signed cert and the root cert. CertChain []byte `protobuf:"bytes,4,opt,name=cert_chain,json=certChain,proto3" json:"cert_chain,omitempty"` }
func (*CsrResponse) Descriptor ¶
func (*CsrResponse) Descriptor() ([]byte, []int)
func (*CsrResponse) Marshal ¶
func (m *CsrResponse) Marshal() (dAtA []byte, err error)
func (*CsrResponse) ProtoMessage ¶
func (*CsrResponse) ProtoMessage()
func (*CsrResponse) Reset ¶
func (m *CsrResponse) Reset()
func (*CsrResponse) Size ¶
func (m *CsrResponse) Size() (n int)
func (*CsrResponse) String ¶
func (this *CsrResponse) String() string
func (*CsrResponse) Unmarshal ¶
func (m *CsrResponse) Unmarshal(dAtA []byte) error
type IstioCAServiceClient ¶
type IstioCAServiceClient interface { // A request object includes a PEM-encoded certificate signing request that // is generated on the Node Agent. Additionaly credential can be attached // within the request object for a server to authenticate the originating // node agent. HandleCSR(ctx context.Context, in *CsrRequest, opts ...grpc.CallOption) (*CsrResponse, error) }
func NewIstioCAServiceClient ¶
func NewIstioCAServiceClient(cc *grpc.ClientConn) IstioCAServiceClient
type IstioCAServiceServer ¶
type IstioCAServiceServer interface { // A request object includes a PEM-encoded certificate signing request that // is generated on the Node Agent. Additionaly credential can be attached // within the request object for a server to authenticate the originating // node agent. HandleCSR(context.Context, *CsrRequest) (*CsrResponse, error) }
type NodeAgentMgmtResponse ¶
type NodeAgentMgmtResponse struct {
Status *google_rpc.Status `protobuf:"bytes,1,opt,name=status" json:"status,omitempty"`
}
func (*NodeAgentMgmtResponse) Descriptor ¶
func (*NodeAgentMgmtResponse) Descriptor() ([]byte, []int)
func (*NodeAgentMgmtResponse) Equal ¶
func (this *NodeAgentMgmtResponse) Equal(that interface{}) bool
func (*NodeAgentMgmtResponse) GetStatus ¶
func (m *NodeAgentMgmtResponse) GetStatus() *google_rpc.Status
func (*NodeAgentMgmtResponse) GoString ¶
func (this *NodeAgentMgmtResponse) GoString() string
func (*NodeAgentMgmtResponse) Marshal ¶
func (m *NodeAgentMgmtResponse) Marshal() (dAtA []byte, err error)
func (*NodeAgentMgmtResponse) MarshalTo ¶
func (m *NodeAgentMgmtResponse) MarshalTo(dAtA []byte) (int, error)
func (*NodeAgentMgmtResponse) ProtoMessage ¶
func (*NodeAgentMgmtResponse) ProtoMessage()
func (*NodeAgentMgmtResponse) Reset ¶
func (m *NodeAgentMgmtResponse) Reset()
func (*NodeAgentMgmtResponse) Size ¶
func (m *NodeAgentMgmtResponse) Size() (n int)
func (*NodeAgentMgmtResponse) String ¶
func (this *NodeAgentMgmtResponse) String() string
func (*NodeAgentMgmtResponse) Unmarshal ¶
func (m *NodeAgentMgmtResponse) Unmarshal(dAtA []byte) error
type NodeAgentServiceClient ¶
type NodeAgentServiceClient interface { // WorkloadAdded is used to notify Node Agent about a workload getting WorkloadAdded(ctx context.Context, in *WorkloadInfo, opts ...grpc.CallOption) (*NodeAgentMgmtResponse, error) // WorkloadDeleted is used to notify Node Agent about a workload getting // added on a node. WorkloadDeleted(ctx context.Context, in *WorkloadInfo, opts ...grpc.CallOption) (*NodeAgentMgmtResponse, error) }
func NewNodeAgentServiceClient ¶
func NewNodeAgentServiceClient(cc *grpc.ClientConn) NodeAgentServiceClient
type NodeAgentServiceServer ¶
type NodeAgentServiceServer interface { // WorkloadAdded is used to notify Node Agent about a workload getting WorkloadAdded(context.Context, *WorkloadInfo) (*NodeAgentMgmtResponse, error) // WorkloadDeleted is used to notify Node Agent about a workload getting // added on a node. WorkloadDeleted(context.Context, *WorkloadInfo) (*NodeAgentMgmtResponse, error) }
type WorkloadInfo ¶
type WorkloadInfo struct { // WorkloadAttributes are the properties of the workload that a caller, // Flexvolume driver knows off. // Node agent can use them to verify the credentials of the workload. Attrs *WorkloadInfo_WorkloadAttributes `protobuf:"bytes,1,opt,name=attrs" json:"attrs,omitempty"` // workloadpath is where the caller has hosted a volume specific for // the workload. The node agent will use this directory to communicate with the // specific workload. Workloadpath string `protobuf:"bytes,2,opt,name=workloadpath,proto3" json:"workloadpath,omitempty"` }
func (*WorkloadInfo) Descriptor ¶
func (*WorkloadInfo) Descriptor() ([]byte, []int)
func (*WorkloadInfo) Equal ¶
func (this *WorkloadInfo) Equal(that interface{}) bool
func (*WorkloadInfo) GetAttrs ¶
func (m *WorkloadInfo) GetAttrs() *WorkloadInfo_WorkloadAttributes
func (*WorkloadInfo) GetWorkloadpath ¶
func (m *WorkloadInfo) GetWorkloadpath() string
func (*WorkloadInfo) GoString ¶
func (this *WorkloadInfo) GoString() string
func (*WorkloadInfo) Marshal ¶
func (m *WorkloadInfo) Marshal() (dAtA []byte, err error)
func (*WorkloadInfo) ProtoMessage ¶
func (*WorkloadInfo) ProtoMessage()
func (*WorkloadInfo) Reset ¶
func (m *WorkloadInfo) Reset()
func (*WorkloadInfo) Size ¶
func (m *WorkloadInfo) Size() (n int)
func (*WorkloadInfo) String ¶
func (this *WorkloadInfo) String() string
func (*WorkloadInfo) Unmarshal ¶
func (m *WorkloadInfo) Unmarshal(dAtA []byte) error
type WorkloadInfo_WorkloadAttributes ¶
type WorkloadInfo_WorkloadAttributes struct { // uid: Unique Id of the Workload. // During delete the uid is mandatory. Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"` // workload identifier aka name. Workload string `protobuf:"bytes,2,opt,name=workload,proto3" json:"workload,omitempty"` // namespace of the workload. Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"` // service account of the workload. Serviceaccount string `protobuf:"bytes,4,opt,name=serviceaccount,proto3" json:"serviceaccount,omitempty"` }
func (*WorkloadInfo_WorkloadAttributes) Descriptor ¶
func (*WorkloadInfo_WorkloadAttributes) Descriptor() ([]byte, []int)
func (*WorkloadInfo_WorkloadAttributes) Equal ¶
func (this *WorkloadInfo_WorkloadAttributes) Equal(that interface{}) bool
func (*WorkloadInfo_WorkloadAttributes) GetNamespace ¶
func (m *WorkloadInfo_WorkloadAttributes) GetNamespace() string
func (*WorkloadInfo_WorkloadAttributes) GetServiceaccount ¶
func (m *WorkloadInfo_WorkloadAttributes) GetServiceaccount() string
func (*WorkloadInfo_WorkloadAttributes) GetUid ¶
func (m *WorkloadInfo_WorkloadAttributes) GetUid() string
func (*WorkloadInfo_WorkloadAttributes) GetWorkload ¶
func (m *WorkloadInfo_WorkloadAttributes) GetWorkload() string
func (*WorkloadInfo_WorkloadAttributes) GoString ¶
func (this *WorkloadInfo_WorkloadAttributes) GoString() string
func (*WorkloadInfo_WorkloadAttributes) Marshal ¶
func (m *WorkloadInfo_WorkloadAttributes) Marshal() (dAtA []byte, err error)
func (*WorkloadInfo_WorkloadAttributes) MarshalTo ¶
func (m *WorkloadInfo_WorkloadAttributes) MarshalTo(dAtA []byte) (int, error)
func (*WorkloadInfo_WorkloadAttributes) ProtoMessage ¶
func (*WorkloadInfo_WorkloadAttributes) ProtoMessage()
func (*WorkloadInfo_WorkloadAttributes) Reset ¶
func (m *WorkloadInfo_WorkloadAttributes) Reset()
func (*WorkloadInfo_WorkloadAttributes) Size ¶
func (m *WorkloadInfo_WorkloadAttributes) Size() (n int)
func (*WorkloadInfo_WorkloadAttributes) String ¶
func (this *WorkloadInfo_WorkloadAttributes) String() string
func (*WorkloadInfo_WorkloadAttributes) Unmarshal ¶
func (m *WorkloadInfo_WorkloadAttributes) Unmarshal(dAtA []byte) error
type WorkloadServiceClient ¶
type WorkloadServiceClient interface {
Check(ctx context.Context, in *CheckRequest, opts ...grpc.CallOption) (*CheckResponse, error)
}
func NewWorkloadServiceClient ¶
func NewWorkloadServiceClient(cc *grpc.ClientConn) WorkloadServiceClient
type WorkloadServiceServer ¶
type WorkloadServiceServer interface {
Check(context.Context, *CheckRequest) (*CheckResponse, error)
}
Click to show internal directories.
Click to hide internal directories.