a1

package
v0.8.40 Latest Latest
Warning

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

 Go to latest Published: Jan 29, 2022 License: Apache-2.0 Imports: 11 Imported by: 4

Documentation

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")
)
View Source 
var (
	ErrInvalidLengthEi        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEi          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEi = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthPolicy        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPolicy          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPolicy = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Encoding_name = map[int32]string{
	0: "PROTO",
	1: "JSON",
}
View Source 
var Encoding_value = map[string]int32{
	"PROTO": 0,
	"JSON":  1,
}

Functions

func RegisterEIServiceServer 

func RegisterEIServiceServer(s *grpc.Server, srv EIServiceServer)

func RegisterPolicyServiceServer 

func RegisterPolicyServiceServer(s *grpc.Server, srv PolicyServiceServer)

Types

type AckMessage 

type AckMessage struct {
	Header  *Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Payload []byte  `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
}

func (*AckMessage) Descriptor 

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

func (*AckMessage) GetHeader 

func (m *AckMessage) GetHeader() *Header

func (*AckMessage) GetPayload 

func (m *AckMessage) GetPayload() []byte

func (*AckMessage) Marshal 

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

func (*AckMessage) MarshalTo 

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

func (*AckMessage) MarshalToSizedBuffer 

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

func (*AckMessage) ProtoMessage 

func (*AckMessage) ProtoMessage()

func (*AckMessage) Reset 

func (m *AckMessage) Reset()

func (*AckMessage) Size 

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

func (*AckMessage) String 

func (m *AckMessage) String() string

func (*AckMessage) Unmarshal 

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

func (*AckMessage) XXX_DiscardUnknown 

func (m *AckMessage) XXX_DiscardUnknown()

func (*AckMessage) XXX_Marshal 

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

func (*AckMessage) XXX_Merge 

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

func (*AckMessage) XXX_Size 

func (m *AckMessage) XXX_Size() int

func (*AckMessage) XXX_Unmarshal 

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

type EIAckMessage 

type EIAckMessage struct {
	EiJobId string      `protobuf:"bytes,1,opt,name=ei_job_id,json=eiJobId,proto3" json:"ei_job_id,omitempty"`
	Message *AckMessage `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

func (*EIAckMessage) Descriptor 

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

func (*EIAckMessage) GetEiJobId added in v0.8.38 

func (m *EIAckMessage) GetEiJobId() string

func (*EIAckMessage) GetMessage 

func (m *EIAckMessage) GetMessage() *AckMessage

func (*EIAckMessage) Marshal 

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

func (*EIAckMessage) MarshalTo 

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

func (*EIAckMessage) MarshalToSizedBuffer 

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

func (*EIAckMessage) ProtoMessage 

func (*EIAckMessage) ProtoMessage()

func (*EIAckMessage) Reset 

func (m *EIAckMessage) Reset()

func (*EIAckMessage) Size 

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

func (*EIAckMessage) String 

func (m *EIAckMessage) String() string

func (*EIAckMessage) Unmarshal 

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

func (*EIAckMessage) XXX_DiscardUnknown 

func (m *EIAckMessage) XXX_DiscardUnknown()

func (*EIAckMessage) XXX_Marshal 

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

func (*EIAckMessage) XXX_Merge 

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

func (*EIAckMessage) XXX_Size 

func (m *EIAckMessage) XXX_Size() int

func (*EIAckMessage) XXX_Unmarshal 

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

type EIRequestMessage 

type EIRequestMessage struct {
	EiJobId string          `protobuf:"bytes,1,opt,name=ei_job_id,json=eiJobId,proto3" json:"ei_job_id,omitempty"`
	Message *RequestMessage `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

func (*EIRequestMessage) Descriptor 

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

func (*EIRequestMessage) GetEiJobId added in v0.8.38 

func (m *EIRequestMessage) GetEiJobId() string

func (*EIRequestMessage) GetMessage 

func (m *EIRequestMessage) GetMessage() *RequestMessage

func (*EIRequestMessage) Marshal 

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

func (*EIRequestMessage) MarshalTo 

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

func (*EIRequestMessage) MarshalToSizedBuffer 

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

func (*EIRequestMessage) ProtoMessage 

func (*EIRequestMessage) ProtoMessage()

func (*EIRequestMessage) Reset 

func (m *EIRequestMessage) Reset()

func (*EIRequestMessage) Size 

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

func (*EIRequestMessage) String 

func (m *EIRequestMessage) String() string

func (*EIRequestMessage) Unmarshal 

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

func (*EIRequestMessage) XXX_DiscardUnknown 

func (m *EIRequestMessage) XXX_DiscardUnknown()

func (*EIRequestMessage) XXX_Marshal 

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

func (*EIRequestMessage) XXX_Merge 

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

func (*EIRequestMessage) XXX_Size 

func (m *EIRequestMessage) XXX_Size() int

func (*EIRequestMessage) XXX_Unmarshal 

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

type EIResultMessage 

type EIResultMessage struct {
	EiJobId string         `protobuf:"bytes,1,opt,name=ei_job_id,json=eiJobId,proto3" json:"ei_job_id,omitempty"`
	Message *ResultMessage `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

func (*EIResultMessage) Descriptor 

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

func (*EIResultMessage) GetEiJobId added in v0.8.38 

func (m *EIResultMessage) GetEiJobId() string

func (*EIResultMessage) GetMessage 

func (m *EIResultMessage) GetMessage() *ResultMessage

func (*EIResultMessage) Marshal 

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

func (*EIResultMessage) MarshalTo 

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

func (*EIResultMessage) MarshalToSizedBuffer 

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

func (*EIResultMessage) ProtoMessage 

func (*EIResultMessage) ProtoMessage()

func (*EIResultMessage) Reset 

func (m *EIResultMessage) Reset()

func (*EIResultMessage) Size 

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

func (*EIResultMessage) String 

func (m *EIResultMessage) String() string

func (*EIResultMessage) Unmarshal 

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

func (*EIResultMessage) XXX_DiscardUnknown 

func (m *EIResultMessage) XXX_DiscardUnknown()

func (*EIResultMessage) XXX_Marshal 

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

func (*EIResultMessage) XXX_Merge 

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

func (*EIResultMessage) XXX_Size 

func (m *EIResultMessage) XXX_Size() int

func (*EIResultMessage) XXX_Unmarshal 

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

type EIServiceClient 

type EIServiceClient interface {
	EIQuery(ctx context.Context, opts ...grpc.CallOption) (EIService_EIQueryClient, error)
	EIJobSetup(ctx context.Context, opts ...grpc.CallOption) (EIService_EIJobSetupClient, error)
	EIJobUpdate(ctx context.Context, opts ...grpc.CallOption) (EIService_EIJobUpdateClient, error)
	EIJobDelete(ctx context.Context, opts ...grpc.CallOption) (EIService_EIJobDeleteClient, error)
	EIJobStatusQuery(ctx context.Context, opts ...grpc.CallOption) (EIService_EIJobStatusQueryClient, error)
	EIJobStatusNotify(ctx context.Context, in *EIStatusMessage, opts ...grpc.CallOption) (*EIAckMessage, error)
	EIJobResultDelivery(ctx context.Context, in *EIResultMessage, opts ...grpc.CallOption) (*EIAckMessage, error)
}

EIServiceClient is the client API for EIService service.

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

func NewEIServiceClient 

func NewEIServiceClient(cc *grpc.ClientConn) EIServiceClient

type EIServiceServer 

type EIServiceServer interface {
	EIQuery(EIService_EIQueryServer) error
	EIJobSetup(EIService_EIJobSetupServer) error
	EIJobUpdate(EIService_EIJobUpdateServer) error
	EIJobDelete(EIService_EIJobDeleteServer) error
	EIJobStatusQuery(EIService_EIJobStatusQueryServer) error
	EIJobStatusNotify(context.Context, *EIStatusMessage) (*EIAckMessage, error)
	EIJobResultDelivery(context.Context, *EIResultMessage) (*EIAckMessage, error)
}

EIServiceServer is the server API for EIService service.

type EIService_EIJobDeleteClient 

type EIService_EIJobDeleteClient interface {
	Send(*EIResultMessage) error
	Recv() (*EIRequestMessage, error)
	grpc.ClientStream
}

type EIService_EIJobDeleteServer 

type EIService_EIJobDeleteServer interface {
	Send(*EIRequestMessage) error
	Recv() (*EIResultMessage, error)
	grpc.ServerStream
}

type EIService_EIJobSetupClient 

type EIService_EIJobSetupClient interface {
	Send(*EIResultMessage) error
	Recv() (*EIRequestMessage, error)
	grpc.ClientStream
}

type EIService_EIJobSetupServer 

type EIService_EIJobSetupServer interface {
	Send(*EIRequestMessage) error
	Recv() (*EIResultMessage, error)
	grpc.ServerStream
}

type EIService_EIJobStatusQueryClient 

type EIService_EIJobStatusQueryClient interface {
	Send(*EIResultMessage) error
	Recv() (*EIRequestMessage, error)
	grpc.ClientStream
}

type EIService_EIJobStatusQueryServer 

type EIService_EIJobStatusQueryServer interface {
	Send(*EIRequestMessage) error
	Recv() (*EIResultMessage, error)
	grpc.ServerStream
}

type EIService_EIJobUpdateClient 

type EIService_EIJobUpdateClient interface {
	Send(*EIResultMessage) error
	Recv() (*EIRequestMessage, error)
	grpc.ClientStream
}

type EIService_EIJobUpdateServer 

type EIService_EIJobUpdateServer interface {
	Send(*EIRequestMessage) error
	Recv() (*EIResultMessage, error)
	grpc.ServerStream
}

type EIService_EIQueryClient 

type EIService_EIQueryClient interface {
	Send(*EIResultMessage) error
	Recv() (*EIRequestMessage, error)
	grpc.ClientStream
}

type EIService_EIQueryServer 

type EIService_EIQueryServer interface {
	Send(*EIRequestMessage) error
	Recv() (*EIResultMessage, error)
	grpc.ServerStream
}

type EIStatusMessage 

type EIStatusMessage struct {
	EiJobId string         `protobuf:"bytes,1,opt,name=ei_job_id,json=eiJobId,proto3" json:"ei_job_id,omitempty"`
	Message *StatusMessage `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

func (*EIStatusMessage) Descriptor 

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

func (*EIStatusMessage) GetEiJobId added in v0.8.38 

func (m *EIStatusMessage) GetEiJobId() string

func (*EIStatusMessage) GetMessage 

func (m *EIStatusMessage) GetMessage() *StatusMessage

func (*EIStatusMessage) Marshal 

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

func (*EIStatusMessage) MarshalTo 

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

func (*EIStatusMessage) MarshalToSizedBuffer 

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

func (*EIStatusMessage) ProtoMessage 

func (*EIStatusMessage) ProtoMessage()

func (*EIStatusMessage) Reset 

func (m *EIStatusMessage) Reset()

func (*EIStatusMessage) Size 

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

func (*EIStatusMessage) String 

func (m *EIStatusMessage) String() string

func (*EIStatusMessage) Unmarshal 

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

func (*EIStatusMessage) XXX_DiscardUnknown 

func (m *EIStatusMessage) XXX_DiscardUnknown()

func (*EIStatusMessage) XXX_Marshal 

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

func (*EIStatusMessage) XXX_Merge 

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

func (*EIStatusMessage) XXX_Size 

func (m *EIStatusMessage) XXX_Size() int

func (*EIStatusMessage) XXX_Unmarshal 

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

type Encoding 

type Encoding int32
const (
	Encoding_PROTO Encoding = 0
	Encoding_JSON  Encoding = 1
)

func (Encoding) EnumDescriptor 

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

func (Encoding) String 

func (x Encoding) String() string
type Header struct {
	RequestId     string   `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	AppId         string   `protobuf:"bytes,2,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	AppInstanceId string   `protobuf:"bytes,3,opt,name=app_instance_id,json=appInstanceId,proto3" json:"app_instance_id,omitempty"`
	A1NodeId      string   `protobuf:"bytes,4,opt,name=a1_node_id,json=a1NodeId,proto3" json:"a1_node_id,omitempty"`
	Encoding      Encoding `protobuf:"varint,5,opt,name=encoding,proto3,enum=onos.a1t.a1.Encoding" json:"encoding,omitempty"`
}

func (*Header) Descriptor 

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

func (*Header) GetA1NodeId 

func (m *Header) GetA1NodeId() string

func (*Header) GetAppId 

func (m *Header) GetAppId() string

func (*Header) GetAppInstanceId 

func (m *Header) GetAppInstanceId() string

func (*Header) GetEncoding 

func (m *Header) GetEncoding() Encoding

func (*Header) GetRequestId added in v0.8.19 

func (m *Header) GetRequestId() string

func (*Header) Marshal 

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

func (*Header) MarshalTo 

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

func (*Header) MarshalToSizedBuffer 

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

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) Reset 

func (m *Header) Reset()

func (*Header) Size 

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

func (*Header) String 

func (m *Header) String() string

func (*Header) Unmarshal 

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

func (*Header) XXX_DiscardUnknown 

func (m *Header) XXX_DiscardUnknown()

func (*Header) XXX_Marshal 

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

func (*Header) XXX_Merge 

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

func (*Header) XXX_Size 

func (m *Header) XXX_Size() int

func (*Header) XXX_Unmarshal 

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

type PolicyAckMessage 

type PolicyAckMessage struct {
	PolicyId   string      `protobuf:"bytes,1,opt,name=policy_id,json=policyId,proto3" json:"policy_id,omitempty"`
	PolicyType *PolicyType `protobuf:"bytes,2,opt,name=policy_type,json=policyType,proto3" json:"policy_type,omitempty"`
	Message    *AckMessage `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
}

func (*PolicyAckMessage) Descriptor 

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

func (*PolicyAckMessage) GetMessage 

func (m *PolicyAckMessage) GetMessage() *AckMessage

func (*PolicyAckMessage) GetPolicyId added in v0.8.38 

func (m *PolicyAckMessage) GetPolicyId() string

func (*PolicyAckMessage) GetPolicyType 

func (m *PolicyAckMessage) GetPolicyType() *PolicyType

func (*PolicyAckMessage) Marshal 

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

func (*PolicyAckMessage) MarshalTo 

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

func (*PolicyAckMessage) MarshalToSizedBuffer 

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

func (*PolicyAckMessage) ProtoMessage 

func (*PolicyAckMessage) ProtoMessage()

func (*PolicyAckMessage) Reset 

func (m *PolicyAckMessage) Reset()

func (*PolicyAckMessage) Size 

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

func (*PolicyAckMessage) String 

func (m *PolicyAckMessage) String() string

func (*PolicyAckMessage) Unmarshal 

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

func (*PolicyAckMessage) XXX_DiscardUnknown 

func (m *PolicyAckMessage) XXX_DiscardUnknown()

func (*PolicyAckMessage) XXX_Marshal 

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

func (*PolicyAckMessage) XXX_Merge 

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

func (*PolicyAckMessage) XXX_Size 

func (m *PolicyAckMessage) XXX_Size() int

func (*PolicyAckMessage) XXX_Unmarshal 

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

type PolicyRequestMessage 

type PolicyRequestMessage struct {
	PolicyId   string          `protobuf:"bytes,1,opt,name=policy_id,json=policyId,proto3" json:"policy_id,omitempty"`
	PolicyType *PolicyType     `protobuf:"bytes,2,opt,name=policy_type,json=policyType,proto3" json:"policy_type,omitempty"`
	Message    *RequestMessage `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
}

func (*PolicyRequestMessage) Descriptor 

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

func (*PolicyRequestMessage) GetMessage 

func (m *PolicyRequestMessage) GetMessage() *RequestMessage

func (*PolicyRequestMessage) GetPolicyId added in v0.8.38 

func (m *PolicyRequestMessage) GetPolicyId() string

func (*PolicyRequestMessage) GetPolicyType 

func (m *PolicyRequestMessage) GetPolicyType() *PolicyType

func (*PolicyRequestMessage) Marshal 

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

func (*PolicyRequestMessage) MarshalTo 

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

func (*PolicyRequestMessage) MarshalToSizedBuffer 

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

func (*PolicyRequestMessage) ProtoMessage 

func (*PolicyRequestMessage) ProtoMessage()

func (*PolicyRequestMessage) Reset 

func (m *PolicyRequestMessage) Reset()

func (*PolicyRequestMessage) Size 

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

func (*PolicyRequestMessage) String 

func (m *PolicyRequestMessage) String() string

func (*PolicyRequestMessage) Unmarshal 

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

func (*PolicyRequestMessage) XXX_DiscardUnknown 

func (m *PolicyRequestMessage) XXX_DiscardUnknown()

func (*PolicyRequestMessage) XXX_Marshal 

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

func (*PolicyRequestMessage) XXX_Merge 

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

func (*PolicyRequestMessage) XXX_Size 

func (m *PolicyRequestMessage) XXX_Size() int

func (*PolicyRequestMessage) XXX_Unmarshal 

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

type PolicyResultMessage 

type PolicyResultMessage struct {
	PolicyId   string         `protobuf:"bytes,1,opt,name=policy_id,json=policyId,proto3" json:"policy_id,omitempty"`
	PolicyType *PolicyType    `protobuf:"bytes,2,opt,name=policy_type,json=policyType,proto3" json:"policy_type,omitempty"`
	Message    *ResultMessage `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
}

func (*PolicyResultMessage) Descriptor 

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

func (*PolicyResultMessage) GetMessage 

func (m *PolicyResultMessage) GetMessage() *ResultMessage

func (*PolicyResultMessage) GetPolicyId added in v0.8.38 

func (m *PolicyResultMessage) GetPolicyId() string

func (*PolicyResultMessage) GetPolicyType 

func (m *PolicyResultMessage) GetPolicyType() *PolicyType

func (*PolicyResultMessage) Marshal 

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

func (*PolicyResultMessage) MarshalTo 

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

func (*PolicyResultMessage) MarshalToSizedBuffer 

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

func (*PolicyResultMessage) ProtoMessage 

func (*PolicyResultMessage) ProtoMessage()

func (*PolicyResultMessage) Reset 

func (m *PolicyResultMessage) Reset()

func (*PolicyResultMessage) Size 

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

func (*PolicyResultMessage) String 

func (m *PolicyResultMessage) String() string

func (*PolicyResultMessage) Unmarshal 

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

func (*PolicyResultMessage) XXX_DiscardUnknown 

func (m *PolicyResultMessage) XXX_DiscardUnknown()

func (*PolicyResultMessage) XXX_Marshal 

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

func (*PolicyResultMessage) XXX_Merge 

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

func (*PolicyResultMessage) XXX_Size 

func (m *PolicyResultMessage) XXX_Size() int

func (*PolicyResultMessage) XXX_Unmarshal 

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

type PolicyServiceClient 

type PolicyServiceClient interface {
	PolicySetup(ctx context.Context, in *PolicyRequestMessage, opts ...grpc.CallOption) (*PolicyResultMessage, error)
	PolicyUpdate(ctx context.Context, in *PolicyRequestMessage, opts ...grpc.CallOption) (*PolicyResultMessage, error)
	PolicyDelete(ctx context.Context, in *PolicyRequestMessage, opts ...grpc.CallOption) (*PolicyResultMessage, error)
	PolicyQuery(ctx context.Context, in *PolicyRequestMessage, opts ...grpc.CallOption) (*PolicyResultMessage, error)
	PolicyStatus(ctx context.Context, opts ...grpc.CallOption) (PolicyService_PolicyStatusClient, error)
}

PolicyServiceClient is the client API for PolicyService service.

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

func NewPolicyServiceClient 

func NewPolicyServiceClient(cc *grpc.ClientConn) PolicyServiceClient

type PolicyServiceServer 

type PolicyServiceServer interface {
	PolicySetup(context.Context, *PolicyRequestMessage) (*PolicyResultMessage, error)
	PolicyUpdate(context.Context, *PolicyRequestMessage) (*PolicyResultMessage, error)
	PolicyDelete(context.Context, *PolicyRequestMessage) (*PolicyResultMessage, error)
	PolicyQuery(context.Context, *PolicyRequestMessage) (*PolicyResultMessage, error)
	PolicyStatus(PolicyService_PolicyStatusServer) error
}

PolicyServiceServer is the server API for PolicyService service.

type PolicyService_PolicyStatusClient 

type PolicyService_PolicyStatusClient interface {
	Send(*PolicyAckMessage) error
	Recv() (*PolicyStatusMessage, error)
	grpc.ClientStream
}

type PolicyService_PolicyStatusServer 

type PolicyService_PolicyStatusServer interface {
	Send(*PolicyStatusMessage) error
	Recv() (*PolicyAckMessage, error)
	grpc.ServerStream
}

type PolicyStatusMessage 

type PolicyStatusMessage struct {
	PolicyId   string         `protobuf:"bytes,1,opt,name=policy_id,json=policyId,proto3" json:"policy_id,omitempty"`
	PolicyType *PolicyType    `protobuf:"bytes,2,opt,name=policy_type,json=policyType,proto3" json:"policy_type,omitempty"`
	Message    *StatusMessage `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
}

func (*PolicyStatusMessage) Descriptor 

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

func (*PolicyStatusMessage) GetMessage 

func (m *PolicyStatusMessage) GetMessage() *StatusMessage

func (*PolicyStatusMessage) GetPolicyId added in v0.8.38 

func (m *PolicyStatusMessage) GetPolicyId() string

func (*PolicyStatusMessage) GetPolicyType 

func (m *PolicyStatusMessage) GetPolicyType() *PolicyType

func (*PolicyStatusMessage) Marshal 

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

func (*PolicyStatusMessage) MarshalTo 

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

func (*PolicyStatusMessage) MarshalToSizedBuffer 

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

func (*PolicyStatusMessage) ProtoMessage 

func (*PolicyStatusMessage) ProtoMessage()

func (*PolicyStatusMessage) Reset 

func (m *PolicyStatusMessage) Reset()

func (*PolicyStatusMessage) Size 

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

func (*PolicyStatusMessage) String 

func (m *PolicyStatusMessage) String() string

func (*PolicyStatusMessage) Unmarshal 

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

func (*PolicyStatusMessage) XXX_DiscardUnknown 

func (m *PolicyStatusMessage) XXX_DiscardUnknown()

func (*PolicyStatusMessage) XXX_Marshal 

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

func (*PolicyStatusMessage) XXX_Merge 

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

func (*PolicyStatusMessage) XXX_Size 

func (m *PolicyStatusMessage) XXX_Size() int

func (*PolicyStatusMessage) XXX_Unmarshal 

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

type PolicyType 

type PolicyType struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
}

func (*PolicyType) Descriptor 

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

func (*PolicyType) GetId 

func (m *PolicyType) GetId() string

func (*PolicyType) GetName 

func (m *PolicyType) GetName() string

func (*PolicyType) GetVersion 

func (m *PolicyType) GetVersion() string

func (*PolicyType) Marshal 

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

func (*PolicyType) MarshalTo 

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

func (*PolicyType) MarshalToSizedBuffer 

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

func (*PolicyType) ProtoMessage 

func (*PolicyType) ProtoMessage()

func (*PolicyType) Reset 

func (m *PolicyType) Reset()

func (*PolicyType) Size 

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

func (*PolicyType) String 

func (m *PolicyType) String() string

func (*PolicyType) Unmarshal 

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

func (*PolicyType) XXX_DiscardUnknown 

func (m *PolicyType) XXX_DiscardUnknown()

func (*PolicyType) XXX_Marshal 

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

func (*PolicyType) XXX_Merge 

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

func (*PolicyType) XXX_Size 

func (m *PolicyType) XXX_Size() int

func (*PolicyType) XXX_Unmarshal 

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

type RequestMessage 

type RequestMessage struct {
	Header  *Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Payload []byte  `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
}

func (*RequestMessage) Descriptor 

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

func (*RequestMessage) GetHeader 

func (m *RequestMessage) GetHeader() *Header

func (*RequestMessage) GetPayload 

func (m *RequestMessage) GetPayload() []byte

func (*RequestMessage) Marshal 

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

func (*RequestMessage) MarshalTo 

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

func (*RequestMessage) MarshalToSizedBuffer 

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

func (*RequestMessage) ProtoMessage 

func (*RequestMessage) ProtoMessage()

func (*RequestMessage) Reset 

func (m *RequestMessage) Reset()

func (*RequestMessage) Size 

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

func (*RequestMessage) String 

func (m *RequestMessage) String() string

func (*RequestMessage) Unmarshal 

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

func (*RequestMessage) XXX_DiscardUnknown 

func (m *RequestMessage) XXX_DiscardUnknown()

func (*RequestMessage) XXX_Marshal 

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

func (*RequestMessage) XXX_Merge 

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

func (*RequestMessage) XXX_Size 

func (m *RequestMessage) XXX_Size() int

func (*RequestMessage) XXX_Unmarshal 

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

type ResultMessage 

type ResultMessage struct {
	Header  *Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Payload []byte  `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
}

func (*ResultMessage) Descriptor 

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

func (*ResultMessage) GetHeader 

func (m *ResultMessage) GetHeader() *Header

func (*ResultMessage) GetPayload 

func (m *ResultMessage) GetPayload() []byte

func (*ResultMessage) Marshal 

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

func (*ResultMessage) MarshalTo 

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

func (*ResultMessage) MarshalToSizedBuffer 

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

func (*ResultMessage) ProtoMessage 

func (*ResultMessage) ProtoMessage()

func (*ResultMessage) Reset 

func (m *ResultMessage) Reset()

func (*ResultMessage) Size 

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

func (*ResultMessage) String 

func (m *ResultMessage) String() string

func (*ResultMessage) Unmarshal 

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

func (*ResultMessage) XXX_DiscardUnknown 

func (m *ResultMessage) XXX_DiscardUnknown()

func (*ResultMessage) XXX_Marshal 

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

func (*ResultMessage) XXX_Merge 

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

func (*ResultMessage) XXX_Size 

func (m *ResultMessage) XXX_Size() int

func (*ResultMessage) XXX_Unmarshal 

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

type StatusMessage 

type StatusMessage struct {
	Header  *Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Payload []byte  `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
}

func (*StatusMessage) Descriptor 

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

func (*StatusMessage) GetHeader 

func (m *StatusMessage) GetHeader() *Header

func (*StatusMessage) GetPayload 

func (m *StatusMessage) GetPayload() []byte

func (*StatusMessage) Marshal 

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

func (*StatusMessage) MarshalTo 

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

func (*StatusMessage) MarshalToSizedBuffer 

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

func (*StatusMessage) ProtoMessage 

func (*StatusMessage) ProtoMessage()

func (*StatusMessage) Reset 

func (m *StatusMessage) Reset()

func (*StatusMessage) Size 

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

func (*StatusMessage) String 

func (m *StatusMessage) String() string

func (*StatusMessage) Unmarshal 

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

func (*StatusMessage) XXX_DiscardUnknown 

func (m *StatusMessage) XXX_DiscardUnknown()

func (*StatusMessage) XXX_Marshal 

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

func (*StatusMessage) XXX_Merge 

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

func (*StatusMessage) XXX_Size 

func (m *StatusMessage) XXX_Size() int

func (*StatusMessage) XXX_Unmarshal 

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

type UnimplementedEIServiceServer 

type UnimplementedEIServiceServer struct {
}

UnimplementedEIServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedEIServiceServer) EIJobDelete 

func (*UnimplementedEIServiceServer) EIJobDelete(srv EIService_EIJobDeleteServer) error

func (*UnimplementedEIServiceServer) EIJobResultDelivery 

func (*UnimplementedEIServiceServer) EIJobResultDelivery(ctx context.Context, req *EIResultMessage) (*EIAckMessage, error)

func (*UnimplementedEIServiceServer) EIJobSetup 

func (*UnimplementedEIServiceServer) EIJobSetup(srv EIService_EIJobSetupServer) error

func (*UnimplementedEIServiceServer) EIJobStatusNotify 

func (*UnimplementedEIServiceServer) EIJobStatusNotify(ctx context.Context, req *EIStatusMessage) (*EIAckMessage, error)

func (*UnimplementedEIServiceServer) EIJobStatusQuery 

func (*UnimplementedEIServiceServer) EIJobStatusQuery(srv EIService_EIJobStatusQueryServer) error

func (*UnimplementedEIServiceServer) EIJobUpdate 

func (*UnimplementedEIServiceServer) EIJobUpdate(srv EIService_EIJobUpdateServer) error

func (*UnimplementedEIServiceServer) EIQuery 

func (*UnimplementedEIServiceServer) EIQuery(srv EIService_EIQueryServer) error

type UnimplementedPolicyServiceServer 

type UnimplementedPolicyServiceServer struct {
}

UnimplementedPolicyServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPolicyServiceServer) PolicyDelete 

func (*UnimplementedPolicyServiceServer) PolicyDelete(ctx context.Context, req *PolicyRequestMessage) (*PolicyResultMessage, error)

func (*UnimplementedPolicyServiceServer) PolicyQuery 

func (*UnimplementedPolicyServiceServer) PolicyQuery(ctx context.Context, req *PolicyRequestMessage) (*PolicyResultMessage, error)

func (*UnimplementedPolicyServiceServer) PolicySetup 

func (*UnimplementedPolicyServiceServer) PolicySetup(ctx context.Context, req *PolicyRequestMessage) (*PolicyResultMessage, error)

func (*UnimplementedPolicyServiceServer) PolicyStatus 

func (*UnimplementedPolicyServiceServer) PolicyStatus(srv PolicyService_PolicyStatusServer) error

func (*UnimplementedPolicyServiceServer) PolicyUpdate 

func (*UnimplementedPolicyServiceServer) PolicyUpdate(ctx context.Context, req *PolicyRequestMessage) (*PolicyResultMessage, 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.