a1

package
v0.6.7 Latest Latest
Warning

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

 Go to latest Published: Jun 2, 2020 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

Package a1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthA1        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowA1          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupA1 = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterA1Handler 

func RegisterA1Handler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterA1Handler registers the http handlers for service A1 to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterA1HandlerClient 

func RegisterA1HandlerClient(ctx context.Context, mux *runtime.ServeMux, client A1Client) error

RegisterA1HandlerClient registers the http handlers for service A1 to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "A1Client". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "A1Client" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "A1Client" to call the correct interceptors.

func RegisterA1HandlerFromEndpoint 

func RegisterA1HandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterA1HandlerFromEndpoint is same as RegisterA1Handler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterA1HandlerServer 

func RegisterA1HandlerServer(ctx context.Context, mux *runtime.ServeMux, server A1Server) error

RegisterA1HandlerServer registers the http handlers for service A1 to "mux". UnaryRPC :call A1Server directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterA1Server 

func RegisterA1Server(s *grpc.Server, srv A1Server)

Types

type A1Client 

type A1Client interface {
	// CreateOrUpdate creates an A1 policy
	CreateOrUpdate(ctx context.Context, in *CreateOrUpdateRequest, opts ...grpc.CallOption) (*CreateOrUpdateResponse, error)
	// Query queries about one or more than one A1 policies
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (A1_QueryClient, error)
	// Delete deletes an A1 policy
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	// Notify notify about an enforcement status change of a policy between 'enforced' and 'not enforced'.
	Notify(ctx context.Context, opts ...grpc.CallOption) (A1_NotifyClient, error)
}

A1Client is the client API for A1 service.

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

func NewA1Client 

func NewA1Client(cc *grpc.ClientConn) A1Client

type A1Server 

type A1Server interface {
	// CreateOrUpdate creates an A1 policy
	CreateOrUpdate(context.Context, *CreateOrUpdateRequest) (*CreateOrUpdateResponse, error)
	// Query queries about one or more than one A1 policies
	Query(*QueryRequest, A1_QueryServer) error
	// Delete deletes an A1 policy
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	// Notify notify about an enforcement status change of a policy between 'enforced' and 'not enforced'.
	Notify(A1_NotifyServer) error
}

A1Server is the server API for A1 service.

type A1_NotifyClient 

type A1_NotifyClient interface {
	Send(*NotifyRequest) error
	Recv() (*NotifyResponse, error)
	grpc.ClientStream
}

type A1_NotifyServer 

type A1_NotifyServer interface {
	Send(*NotifyResponse) error
	Recv() (*NotifyRequest, error)
	grpc.ServerStream
}

type A1_QueryClient 

type A1_QueryClient interface {
	Recv() (*QueryResponse, error)
	grpc.ClientStream
}

type A1_QueryServer 

type A1_QueryServer interface {
	Send(*QueryResponse) error
	grpc.ServerStream
}

type AllPolicyResponse 

type AllPolicyResponse struct {
	PolicyId []*types.PolicyID `protobuf:"bytes,1,rep,name=policy_id,json=policyId,proto3" json:"policy_id,omitempty"`
}

AllPolicyResponse representation of a A1 All policy response which contains list of all policy IDs

func (*AllPolicyResponse) Descriptor 

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

func (*AllPolicyResponse) GetPolicyId 

func (m *AllPolicyResponse) GetPolicyId() []*types.PolicyID

func (*AllPolicyResponse) Marshal 

func (m *AllPolicyResponse) Marshal() (dAtA []byte, err error)

func (*AllPolicyResponse) MarshalTo 

func (m *AllPolicyResponse) MarshalTo(dAtA []byte) (int, error)

func (*AllPolicyResponse) MarshalToSizedBuffer 

func (m *AllPolicyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AllPolicyResponse) ProtoMessage 

func (*AllPolicyResponse) ProtoMessage()

func (*AllPolicyResponse) Reset 

func (m *AllPolicyResponse) Reset()

func (*AllPolicyResponse) Size 

func (m *AllPolicyResponse) Size() (n int)

func (*AllPolicyResponse) String 

func (m *AllPolicyResponse) String() string

func (*AllPolicyResponse) Unmarshal 

func (m *AllPolicyResponse) Unmarshal(dAtA []byte) error

func (*AllPolicyResponse) XXX_DiscardUnknown 

func (m *AllPolicyResponse) XXX_DiscardUnknown()

func (*AllPolicyResponse) XXX_Marshal 

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

func (*AllPolicyResponse) XXX_Merge 

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

func (*AllPolicyResponse) XXX_Size 

func (m *AllPolicyResponse) XXX_Size() int

func (*AllPolicyResponse) XXX_Unmarshal 

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

type CreateOrUpdateRequest 

type CreateOrUpdateRequest struct {
	PolicyId *types.PolicyID `protobuf:"bytes,1,opt,name=policy_id,json=policyId,proto3" json:"policy_id,omitempty"`
	Policy   *Policy         `protobuf:"bytes,2,opt,name=policy,proto3" json:"policy,omitempty"`
}

CreateOrUpdateRequest a request to create or update a policy

func (*CreateOrUpdateRequest) Descriptor 

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

func (*CreateOrUpdateRequest) GetPolicy 

func (m *CreateOrUpdateRequest) GetPolicy() *Policy

func (*CreateOrUpdateRequest) GetPolicyId 

func (m *CreateOrUpdateRequest) GetPolicyId() *types.PolicyID

func (*CreateOrUpdateRequest) Marshal 

func (m *CreateOrUpdateRequest) Marshal() (dAtA []byte, err error)

func (*CreateOrUpdateRequest) MarshalTo 

func (m *CreateOrUpdateRequest) MarshalTo(dAtA []byte) (int, error)

func (*CreateOrUpdateRequest) MarshalToSizedBuffer 

func (m *CreateOrUpdateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateOrUpdateRequest) ProtoMessage 

func (*CreateOrUpdateRequest) ProtoMessage()

func (*CreateOrUpdateRequest) Reset 

func (m *CreateOrUpdateRequest) Reset()

func (*CreateOrUpdateRequest) Size 

func (m *CreateOrUpdateRequest) Size() (n int)

func (*CreateOrUpdateRequest) String 

func (m *CreateOrUpdateRequest) String() string

func (*CreateOrUpdateRequest) Unmarshal 

func (m *CreateOrUpdateRequest) Unmarshal(dAtA []byte) error

func (*CreateOrUpdateRequest) XXX_DiscardUnknown 

func (m *CreateOrUpdateRequest) XXX_DiscardUnknown()

func (*CreateOrUpdateRequest) XXX_Marshal 

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

func (*CreateOrUpdateRequest) XXX_Merge 

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

func (*CreateOrUpdateRequest) XXX_Size 

func (m *CreateOrUpdateRequest) XXX_Size() int

func (*CreateOrUpdateRequest) XXX_Unmarshal 

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

type CreateOrUpdateResponse 

type CreateOrUpdateResponse struct {
	Policy         *Policy               `protobuf:"bytes,1,opt,name=policy,proto3" json:"policy,omitempty"`
	Status         types.OperationStatus `protobuf:"varint,2,opt,name=status,proto3,enum=types.OperationStatus" json:"status,omitempty"`
	ProblemDetails *ProblemDetails       `protobuf:"bytes,3,opt,name=problem_details,json=problemDetails,proto3" json:"problem_details,omitempty"`
}

CreateOrUpdateResponse response to a CreateOrUpdateRequest

func (*CreateOrUpdateResponse) Descriptor 

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

func (*CreateOrUpdateResponse) GetPolicy 

func (m *CreateOrUpdateResponse) GetPolicy() *Policy

func (*CreateOrUpdateResponse) GetProblemDetails 

func (m *CreateOrUpdateResponse) GetProblemDetails() *ProblemDetails

func (*CreateOrUpdateResponse) GetStatus 

func (m *CreateOrUpdateResponse) GetStatus() types.OperationStatus

func (*CreateOrUpdateResponse) Marshal 

func (m *CreateOrUpdateResponse) Marshal() (dAtA []byte, err error)

func (*CreateOrUpdateResponse) MarshalTo 

func (m *CreateOrUpdateResponse) MarshalTo(dAtA []byte) (int, error)

func (*CreateOrUpdateResponse) MarshalToSizedBuffer 

func (m *CreateOrUpdateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateOrUpdateResponse) ProtoMessage 

func (*CreateOrUpdateResponse) ProtoMessage()

func (*CreateOrUpdateResponse) Reset 

func (m *CreateOrUpdateResponse) Reset()

func (*CreateOrUpdateResponse) Size 

func (m *CreateOrUpdateResponse) Size() (n int)

func (*CreateOrUpdateResponse) String 

func (m *CreateOrUpdateResponse) String() string

func (*CreateOrUpdateResponse) Unmarshal 

func (m *CreateOrUpdateResponse) Unmarshal(dAtA []byte) error

func (*CreateOrUpdateResponse) XXX_DiscardUnknown 

func (m *CreateOrUpdateResponse) XXX_DiscardUnknown()

func (*CreateOrUpdateResponse) XXX_Marshal 

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

func (*CreateOrUpdateResponse) XXX_Merge 

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

func (*CreateOrUpdateResponse) XXX_Size 

func (m *CreateOrUpdateResponse) XXX_Size() int

func (*CreateOrUpdateResponse) XXX_Unmarshal 

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

type DeleteRequest 

type DeleteRequest struct {
	PolicyId *types.PolicyID `protobuf:"bytes,1,opt,name=policy_id,json=policyId,proto3" json:"policy_id,omitempty"`
}

DeleteRequest a request to delete a policy

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetPolicyId 

func (m *DeleteRequest) GetPolicyId() *types.PolicyID

func (*DeleteRequest) Marshal 

func (m *DeleteRequest) Marshal() (dAtA []byte, err error)

func (*DeleteRequest) MarshalTo 

func (m *DeleteRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeleteRequest) MarshalToSizedBuffer 

func (m *DeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) Size 

func (m *DeleteRequest) Size() (n int)

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

func (*DeleteRequest) Unmarshal 

func (m *DeleteRequest) Unmarshal(dAtA []byte) error

func (*DeleteRequest) XXX_DiscardUnknown 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal 

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

func (*DeleteRequest) XXX_Merge 

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

func (*DeleteRequest) XXX_Size 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal 

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

type DeleteResponse 

type DeleteResponse struct {
	Status         types.OperationStatus `protobuf:"varint,1,opt,name=status,proto3,enum=types.OperationStatus" json:"status,omitempty"`
	ProblemDetails *ProblemDetails       `protobuf:"bytes,2,opt,name=problem_details,json=problemDetails,proto3" json:"problem_details,omitempty"`
}

DeleteResponse a response to a DeleteRequest

func (*DeleteResponse) Descriptor 

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

func (*DeleteResponse) GetProblemDetails 

func (m *DeleteResponse) GetProblemDetails() *ProblemDetails

func (*DeleteResponse) GetStatus 

func (m *DeleteResponse) GetStatus() types.OperationStatus

func (*DeleteResponse) Marshal 

func (m *DeleteResponse) Marshal() (dAtA []byte, err error)

func (*DeleteResponse) MarshalTo 

func (m *DeleteResponse) MarshalTo(dAtA []byte) (int, error)

func (*DeleteResponse) MarshalToSizedBuffer 

func (m *DeleteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset 

func (m *DeleteResponse) Reset()

func (*DeleteResponse) Size 

func (m *DeleteResponse) Size() (n int)

func (*DeleteResponse) String 

func (m *DeleteResponse) String() string

func (*DeleteResponse) Unmarshal 

func (m *DeleteResponse) Unmarshal(dAtA []byte) error

func (*DeleteResponse) XXX_DiscardUnknown 

func (m *DeleteResponse) XXX_DiscardUnknown()

func (*DeleteResponse) XXX_Marshal 

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

func (*DeleteResponse) XXX_Merge 

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

func (*DeleteResponse) XXX_Size 

func (m *DeleteResponse) XXX_Size() int

func (*DeleteResponse) XXX_Unmarshal 

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

type NotifyRequest 

type NotifyRequest struct {
}

NotifyRequest a request to get updates about changes in the policy enforcement status for an A1 policy;

func (*NotifyRequest) Descriptor 

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

func (*NotifyRequest) Marshal 

func (m *NotifyRequest) Marshal() (dAtA []byte, err error)

func (*NotifyRequest) MarshalTo 

func (m *NotifyRequest) MarshalTo(dAtA []byte) (int, error)

func (*NotifyRequest) MarshalToSizedBuffer 

func (m *NotifyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NotifyRequest) ProtoMessage 

func (*NotifyRequest) ProtoMessage()

func (*NotifyRequest) Reset 

func (m *NotifyRequest) Reset()

func (*NotifyRequest) Size 

func (m *NotifyRequest) Size() (n int)

func (*NotifyRequest) String 

func (m *NotifyRequest) String() string

func (*NotifyRequest) Unmarshal 

func (m *NotifyRequest) Unmarshal(dAtA []byte) error

func (*NotifyRequest) XXX_DiscardUnknown 

func (m *NotifyRequest) XXX_DiscardUnknown()

func (*NotifyRequest) XXX_Marshal 

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

func (*NotifyRequest) XXX_Merge 

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

func (*NotifyRequest) XXX_Size 

func (m *NotifyRequest) XXX_Size() int

func (*NotifyRequest) XXX_Unmarshal 

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

type NotifyResponse 

type NotifyResponse struct {
	PolicyStatus *PolicyStatus `protobuf:"bytes,1,opt,name=policy_status,json=policyStatus,proto3" json:"policy_status,omitempty"`
}

NotifyResponse a notification response contains the information about changes and causes

func (*NotifyResponse) Descriptor 

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

func (*NotifyResponse) GetPolicyStatus 

func (m *NotifyResponse) GetPolicyStatus() *PolicyStatus

func (*NotifyResponse) Marshal 

func (m *NotifyResponse) Marshal() (dAtA []byte, err error)

func (*NotifyResponse) MarshalTo 

func (m *NotifyResponse) MarshalTo(dAtA []byte) (int, error)

func (*NotifyResponse) MarshalToSizedBuffer 

func (m *NotifyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NotifyResponse) ProtoMessage 

func (*NotifyResponse) ProtoMessage()

func (*NotifyResponse) Reset 

func (m *NotifyResponse) Reset()

func (*NotifyResponse) Size 

func (m *NotifyResponse) Size() (n int)

func (*NotifyResponse) String 

func (m *NotifyResponse) String() string

func (*NotifyResponse) Unmarshal 

func (m *NotifyResponse) Unmarshal(dAtA []byte) error

func (*NotifyResponse) XXX_DiscardUnknown 

func (m *NotifyResponse) XXX_DiscardUnknown()

func (*NotifyResponse) XXX_Marshal 

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

func (*NotifyResponse) XXX_Merge 

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

func (*NotifyResponse) XXX_Size 

func (m *NotifyResponse) XXX_Size() int

func (*NotifyResponse) XXX_Unmarshal 

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

type Policy 

type Policy struct {
	ScopeId         *types.ScopeIdentifier `protobuf:"bytes,1,opt,name=scope_id,json=scopeId,proto3" json:"scope_id,omitempty"`
	PolicyStatement []*PolicyStatement     `protobuf:"bytes,2,rep,name=policy_statement,json=policyStatement,proto3" json:"policy_statement,omitempty"`
}

Policy an A1 policy which contains a scope identifier and one or more policy statements

func (*Policy) Descriptor 

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

func (*Policy) GetPolicyStatement 

func (m *Policy) GetPolicyStatement() []*PolicyStatement

func (*Policy) GetScopeId 

func (m *Policy) GetScopeId() *types.ScopeIdentifier

func (*Policy) Marshal 

func (m *Policy) Marshal() (dAtA []byte, err error)

func (*Policy) MarshalTo 

func (m *Policy) MarshalTo(dAtA []byte) (int, error)

func (*Policy) MarshalToSizedBuffer 

func (m *Policy) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Policy) ProtoMessage 

func (*Policy) ProtoMessage()

func (*Policy) Reset 

func (m *Policy) Reset()

func (*Policy) Size 

func (m *Policy) Size() (n int)

func (*Policy) String 

func (m *Policy) String() string

func (*Policy) Unmarshal 

func (m *Policy) Unmarshal(dAtA []byte) error

func (*Policy) XXX_DiscardUnknown 

func (m *Policy) XXX_DiscardUnknown()

func (*Policy) XXX_Marshal 

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

func (*Policy) XXX_Merge 

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

func (*Policy) XXX_Size 

func (m *Policy) XXX_Size() int

func (*Policy) XXX_Unmarshal 

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

type PolicyStatement 

type PolicyStatement struct {
	Type types.PolicyType `protobuf:"varint,1,opt,name=type,proto3,enum=types.PolicyType" json:"type,omitempty"`
	// Types that are valid to be assigned to Statement:
	//	*PolicyStatement_QosObjectives
	//	*PolicyStatement_TspResources
	Statement isPolicyStatement_Statement `protobuf_oneof:"statement"`
}

PolicyStatement Expression of a directive in an A1 policy that is related to policy objectives and/or policy resources and are to be applied to/for the entities identified by the scope identifier.

func (*PolicyStatement) Descriptor 

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

func (*PolicyStatement) GetQosObjectives 

func (m *PolicyStatement) GetQosObjectives() *qos.QosObjectives

func (*PolicyStatement) GetStatement 

func (m *PolicyStatement) GetStatement() isPolicyStatement_Statement

func (*PolicyStatement) GetTspResources 

func (m *PolicyStatement) GetTspResources() *tsp.TspResources

func (*PolicyStatement) GetType 

func (m *PolicyStatement) GetType() types.PolicyType

func (*PolicyStatement) Marshal 

func (m *PolicyStatement) Marshal() (dAtA []byte, err error)

func (*PolicyStatement) MarshalTo 

func (m *PolicyStatement) MarshalTo(dAtA []byte) (int, error)

func (*PolicyStatement) MarshalToSizedBuffer 

func (m *PolicyStatement) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PolicyStatement) ProtoMessage 

func (*PolicyStatement) ProtoMessage()

func (*PolicyStatement) Reset 

func (m *PolicyStatement) Reset()

func (*PolicyStatement) Size 

func (m *PolicyStatement) Size() (n int)

func (*PolicyStatement) String 

func (m *PolicyStatement) String() string

func (*PolicyStatement) Unmarshal 

func (m *PolicyStatement) Unmarshal(dAtA []byte) error

func (*PolicyStatement) XXX_DiscardUnknown 

func (m *PolicyStatement) XXX_DiscardUnknown()

func (*PolicyStatement) XXX_Marshal 

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

func (*PolicyStatement) XXX_Merge 

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

func (*PolicyStatement) XXX_OneofWrappers 

func (*PolicyStatement) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*PolicyStatement) XXX_Size 

func (m *PolicyStatement) XXX_Size() int

func (*PolicyStatement) XXX_Unmarshal 

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

type PolicyStatement_QosObjectives 

type PolicyStatement_QosObjectives struct {
	QosObjectives *qos.QosObjectives `protobuf:"bytes,2,opt,name=qos_objectives,json=qosObjectives,proto3,oneof" json:"qos_objectives,omitempty"`
}

func (*PolicyStatement_QosObjectives) MarshalTo 

func (m *PolicyStatement_QosObjectives) MarshalTo(dAtA []byte) (int, error)

func (*PolicyStatement_QosObjectives) MarshalToSizedBuffer 

func (m *PolicyStatement_QosObjectives) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PolicyStatement_QosObjectives) Size 

func (m *PolicyStatement_QosObjectives) Size() (n int)

type PolicyStatement_TspResources 

type PolicyStatement_TspResources struct {
	TspResources *tsp.TspResources `protobuf:"bytes,3,opt,name=tsp_resources,json=tspResources,proto3,oneof" json:"tsp_resources,omitempty"`
}

func (*PolicyStatement_TspResources) MarshalTo 

func (m *PolicyStatement_TspResources) MarshalTo(dAtA []byte) (int, error)

func (*PolicyStatement_TspResources) MarshalToSizedBuffer 

func (m *PolicyStatement_TspResources) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PolicyStatement_TspResources) Size 

func (m *PolicyStatement_TspResources) Size() (n int)

type PolicyStatus 

type PolicyStatus struct {
	EnforceStatus types.EnforcementStatusType `` /* 134-byte string literal not displayed */
	EnforceReason types.EnforcementReasonType `` /* 134-byte string literal not displayed */
}

PolicyStatus representation of a A1 policy enforcement status and reasons

func (*PolicyStatus) Descriptor 

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

func (*PolicyStatus) GetEnforceReason 

func (m *PolicyStatus) GetEnforceReason() types.EnforcementReasonType

func (*PolicyStatus) GetEnforceStatus 

func (m *PolicyStatus) GetEnforceStatus() types.EnforcementStatusType

func (*PolicyStatus) Marshal 

func (m *PolicyStatus) Marshal() (dAtA []byte, err error)

func (*PolicyStatus) MarshalTo 

func (m *PolicyStatus) MarshalTo(dAtA []byte) (int, error)

func (*PolicyStatus) MarshalToSizedBuffer 

func (m *PolicyStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PolicyStatus) ProtoMessage 

func (*PolicyStatus) ProtoMessage()

func (*PolicyStatus) Reset 

func (m *PolicyStatus) Reset()

func (*PolicyStatus) Size 

func (m *PolicyStatus) Size() (n int)

func (*PolicyStatus) String 

func (m *PolicyStatus) String() string

func (*PolicyStatus) Unmarshal 

func (m *PolicyStatus) Unmarshal(dAtA []byte) error

func (*PolicyStatus) XXX_DiscardUnknown 

func (m *PolicyStatus) XXX_DiscardUnknown()

func (*PolicyStatus) XXX_Marshal 

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

func (*PolicyStatus) XXX_Merge 

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

func (*PolicyStatus) XXX_Size 

func (m *PolicyStatus) XXX_Size() int

func (*PolicyStatus) XXX_Unmarshal 

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

type PolicyStatusResponse 

type PolicyStatusResponse struct {
	PolicyStatus *PolicyStatus `protobuf:"bytes,1,opt,name=policy_status,json=policyStatus,proto3" json:"policy_status,omitempty"`
}

PolicyStatusResponse

func (*PolicyStatusResponse) Descriptor 

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

func (*PolicyStatusResponse) GetPolicyStatus 

func (m *PolicyStatusResponse) GetPolicyStatus() *PolicyStatus

func (*PolicyStatusResponse) Marshal 

func (m *PolicyStatusResponse) Marshal() (dAtA []byte, err error)

func (*PolicyStatusResponse) MarshalTo 

func (m *PolicyStatusResponse) MarshalTo(dAtA []byte) (int, error)

func (*PolicyStatusResponse) MarshalToSizedBuffer 

func (m *PolicyStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PolicyStatusResponse) ProtoMessage 

func (*PolicyStatusResponse) ProtoMessage()

func (*PolicyStatusResponse) Reset 

func (m *PolicyStatusResponse) Reset()

func (*PolicyStatusResponse) Size 

func (m *PolicyStatusResponse) Size() (n int)

func (*PolicyStatusResponse) String 

func (m *PolicyStatusResponse) String() string

func (*PolicyStatusResponse) Unmarshal 

func (m *PolicyStatusResponse) Unmarshal(dAtA []byte) error

func (*PolicyStatusResponse) XXX_DiscardUnknown 

func (m *PolicyStatusResponse) XXX_DiscardUnknown()

func (*PolicyStatusResponse) XXX_Marshal 

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

func (*PolicyStatusResponse) XXX_Merge 

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

func (*PolicyStatusResponse) XXX_Size 

func (m *PolicyStatusResponse) XXX_Size() int

func (*PolicyStatusResponse) XXX_Unmarshal 

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

type ProblemDetails 

type ProblemDetails struct {
	Title  string `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Detail string `protobuf:"bytes,2,opt,name=detail,proto3" json:"detail,omitempty"`
}

ProblemDetails

func (*ProblemDetails) Descriptor 

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

func (*ProblemDetails) GetDetail 

func (m *ProblemDetails) GetDetail() string

func (*ProblemDetails) GetTitle 

func (m *ProblemDetails) GetTitle() string

func (*ProblemDetails) Marshal 

func (m *ProblemDetails) Marshal() (dAtA []byte, err error)

func (*ProblemDetails) MarshalTo 

func (m *ProblemDetails) MarshalTo(dAtA []byte) (int, error)

func (*ProblemDetails) MarshalToSizedBuffer 

func (m *ProblemDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProblemDetails) ProtoMessage 

func (*ProblemDetails) ProtoMessage()

func (*ProblemDetails) Reset 

func (m *ProblemDetails) Reset()

func (*ProblemDetails) Size 

func (m *ProblemDetails) Size() (n int)

func (*ProblemDetails) String 

func (m *ProblemDetails) String() string

func (*ProblemDetails) Unmarshal 

func (m *ProblemDetails) Unmarshal(dAtA []byte) error

func (*ProblemDetails) XXX_DiscardUnknown 

func (m *ProblemDetails) XXX_DiscardUnknown()

func (*ProblemDetails) XXX_Marshal 

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

func (*ProblemDetails) XXX_Merge 

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

func (*ProblemDetails) XXX_Size 

func (m *ProblemDetails) XXX_Size() int

func (*ProblemDetails) XXX_Unmarshal 

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

type QueryRequest 

type QueryRequest struct {
	// Policy Type
	Type types.PolicyQueryType `protobuf:"varint,1,opt,name=type,proto3,enum=types.PolicyQueryType" json:"type,omitempty"`
	// PolicyID
	PolicyId *types.PolicyID `protobuf:"bytes,2,opt,name=policy_id,json=policyId,proto3" json:"policy_id,omitempty"`
}

QueryRequest a request to query about one or more than one policy

func (*QueryRequest) Descriptor 

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

func (*QueryRequest) GetPolicyId 

func (m *QueryRequest) GetPolicyId() *types.PolicyID

func (*QueryRequest) GetType 

func (m *QueryRequest) GetType() types.PolicyQueryType

func (*QueryRequest) Marshal 

func (m *QueryRequest) Marshal() (dAtA []byte, err error)

func (*QueryRequest) MarshalTo 

func (m *QueryRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryRequest) MarshalToSizedBuffer 

func (m *QueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) Reset 

func (m *QueryRequest) Reset()

func (*QueryRequest) Size 

func (m *QueryRequest) Size() (n int)

func (*QueryRequest) String 

func (m *QueryRequest) String() string

func (*QueryRequest) Unmarshal 

func (m *QueryRequest) Unmarshal(dAtA []byte) error

func (*QueryRequest) XXX_DiscardUnknown 

func (m *QueryRequest) XXX_DiscardUnknown()

func (*QueryRequest) XXX_Marshal 

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

func (*QueryRequest) XXX_Merge 

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

func (*QueryRequest) XXX_Size 

func (m *QueryRequest) XXX_Size() int

func (*QueryRequest) XXX_Unmarshal 

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

type QueryResponse 

type QueryResponse struct {
	// Types that are valid to be assigned to Response:
	//	*QueryResponse_SinglePolicyResponse
	//	*QueryResponse_AllPolicyResponse
	//	*QueryResponse_PolicyStatusResponse
	Response       isQueryResponse_Response `protobuf_oneof:"response"`
	Status         types.OperationStatus    `protobuf:"varint,4,opt,name=status,proto3,enum=types.OperationStatus" json:"status,omitempty"`
	ProblemDetails *ProblemDetails          `protobuf:"bytes,5,opt,name=problem_details,json=problemDetails,proto3" json:"problem_details,omitempty"`
}

QueryResponse a response to a query request

func (*QueryResponse) Descriptor 

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

func (*QueryResponse) GetAllPolicyResponse 

func (m *QueryResponse) GetAllPolicyResponse() *AllPolicyResponse

func (*QueryResponse) GetPolicyStatusResponse 

func (m *QueryResponse) GetPolicyStatusResponse() *PolicyStatusResponse

func (*QueryResponse) GetProblemDetails 

func (m *QueryResponse) GetProblemDetails() *ProblemDetails

func (*QueryResponse) GetResponse 

func (m *QueryResponse) GetResponse() isQueryResponse_Response

func (*QueryResponse) GetSinglePolicyResponse 

func (m *QueryResponse) GetSinglePolicyResponse() *SinglePolicyResponse

func (*QueryResponse) GetStatus 

func (m *QueryResponse) GetStatus() types.OperationStatus

func (*QueryResponse) Marshal 

func (m *QueryResponse) Marshal() (dAtA []byte, err error)

func (*QueryResponse) MarshalTo 

func (m *QueryResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryResponse) MarshalToSizedBuffer 

func (m *QueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) Reset 

func (m *QueryResponse) Reset()

func (*QueryResponse) Size 

func (m *QueryResponse) Size() (n int)

func (*QueryResponse) String 

func (m *QueryResponse) String() string

func (*QueryResponse) Unmarshal 

func (m *QueryResponse) Unmarshal(dAtA []byte) error

func (*QueryResponse) XXX_DiscardUnknown 

func (m *QueryResponse) XXX_DiscardUnknown()

func (*QueryResponse) XXX_Marshal 

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

func (*QueryResponse) XXX_Merge 

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

func (*QueryResponse) XXX_OneofWrappers 

func (*QueryResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*QueryResponse) XXX_Size 

func (m *QueryResponse) XXX_Size() int

func (*QueryResponse) XXX_Unmarshal 

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

type QueryResponse_AllPolicyResponse 

type QueryResponse_AllPolicyResponse struct {
	AllPolicyResponse *AllPolicyResponse `protobuf:"bytes,2,opt,name=all_policy_response,json=allPolicyResponse,proto3,oneof" json:"all_policy_response,omitempty"`
}

func (*QueryResponse_AllPolicyResponse) MarshalTo 

func (m *QueryResponse_AllPolicyResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryResponse_AllPolicyResponse) MarshalToSizedBuffer 

func (m *QueryResponse_AllPolicyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryResponse_AllPolicyResponse) Size 

func (m *QueryResponse_AllPolicyResponse) Size() (n int)

type QueryResponse_PolicyStatusResponse 

type QueryResponse_PolicyStatusResponse struct {
	PolicyStatusResponse *PolicyStatusResponse `` /* 129-byte string literal not displayed */
}

func (*QueryResponse_PolicyStatusResponse) MarshalTo 

func (m *QueryResponse_PolicyStatusResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryResponse_PolicyStatusResponse) MarshalToSizedBuffer 

func (m *QueryResponse_PolicyStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryResponse_PolicyStatusResponse) Size 

func (m *QueryResponse_PolicyStatusResponse) Size() (n int)

type QueryResponse_SinglePolicyResponse 

type QueryResponse_SinglePolicyResponse struct {
	SinglePolicyResponse *SinglePolicyResponse `` /* 129-byte string literal not displayed */
}

func (*QueryResponse_SinglePolicyResponse) MarshalTo 

func (m *QueryResponse_SinglePolicyResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryResponse_SinglePolicyResponse) MarshalToSizedBuffer 

func (m *QueryResponse_SinglePolicyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryResponse_SinglePolicyResponse) Size 

func (m *QueryResponse_SinglePolicyResponse) Size() (n int)

type SinglePolicyResponse 

type SinglePolicyResponse struct {
	Policy *Policy `protobuf:"bytes,1,opt,name=policy,proto3" json:"policy,omitempty"`
}

SinglePolicyResponse representation of a A1 single policy response

func (*SinglePolicyResponse) Descriptor 

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

func (*SinglePolicyResponse) GetPolicy 

func (m *SinglePolicyResponse) GetPolicy() *Policy

func (*SinglePolicyResponse) Marshal 

func (m *SinglePolicyResponse) Marshal() (dAtA []byte, err error)

func (*SinglePolicyResponse) MarshalTo 

func (m *SinglePolicyResponse) MarshalTo(dAtA []byte) (int, error)

func (*SinglePolicyResponse) MarshalToSizedBuffer 

func (m *SinglePolicyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SinglePolicyResponse) ProtoMessage 

func (*SinglePolicyResponse) ProtoMessage()

func (*SinglePolicyResponse) Reset 

func (m *SinglePolicyResponse) Reset()

func (*SinglePolicyResponse) Size 

func (m *SinglePolicyResponse) Size() (n int)

func (*SinglePolicyResponse) String 

func (m *SinglePolicyResponse) String() string

func (*SinglePolicyResponse) Unmarshal 

func (m *SinglePolicyResponse) Unmarshal(dAtA []byte) error

func (*SinglePolicyResponse) XXX_DiscardUnknown 

func (m *SinglePolicyResponse) XXX_DiscardUnknown()

func (*SinglePolicyResponse) XXX_Marshal 

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

func (*SinglePolicyResponse) XXX_Merge 

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

func (*SinglePolicyResponse) XXX_Size 

func (m *SinglePolicyResponse) XXX_Size() int

func (*SinglePolicyResponse) XXX_Unmarshal 

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

type UnimplementedA1Server 

type UnimplementedA1Server struct {
}

UnimplementedA1Server can be embedded to have forward compatible implementations.

func (*UnimplementedA1Server) CreateOrUpdate 

func (*UnimplementedA1Server) CreateOrUpdate(ctx context.Context, req *CreateOrUpdateRequest) (*CreateOrUpdateResponse, error)

func (*UnimplementedA1Server) Delete 

func (*UnimplementedA1Server) Delete(ctx context.Context, req *DeleteRequest) (*DeleteResponse, error)

func (*UnimplementedA1Server) Notify 

func (*UnimplementedA1Server) Notify(srv A1_NotifyServer) error

func (*UnimplementedA1Server) Query 

func (*UnimplementedA1Server) Query(req *QueryRequest, srv A1_QueryServer) error

Source Files

View all Source files

Directories

Path Synopsis
a1-p
qos
tsp

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.