v2

package
v0.0.0-...-87cf5a2 Latest Latest
Warning

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

 Go to latest Published: Apr 2, 2022 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRpc = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRpc   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthTypes = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterPoolServer 

func RegisterPoolServer(s *grpc.Server, srv PoolServer)

func RegisterValidatorServer 

func RegisterValidatorServer(s *grpc.Server, srv ValidatorServer)

Types

type DeleteProxyRequest 

type DeleteProxyRequest struct {
	Proxy                *Proxy   `protobuf:"bytes,1,opt,name=proxy,proto3" json:"proxy,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteProxyRequest) Descriptor 

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

func (*DeleteProxyRequest) Marshal 

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

func (*DeleteProxyRequest) MarshalTo 

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

func (*DeleteProxyRequest) ProtoMessage 

func (*DeleteProxyRequest) ProtoMessage()

func (*DeleteProxyRequest) Reset 

func (m *DeleteProxyRequest) Reset()

func (*DeleteProxyRequest) Size 

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

func (*DeleteProxyRequest) String 

func (m *DeleteProxyRequest) String() string

func (*DeleteProxyRequest) Unmarshal 

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

func (*DeleteProxyRequest) Validate 

func (this *DeleteProxyRequest) Validate() error

func (*DeleteProxyRequest) XXX_DiscardUnknown 

func (m *DeleteProxyRequest) XXX_DiscardUnknown()

func (*DeleteProxyRequest) XXX_Marshal 

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

func (*DeleteProxyRequest) XXX_Merge 

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

func (*DeleteProxyRequest) XXX_Size 

func (m *DeleteProxyRequest) XXX_Size() int

func (*DeleteProxyRequest) XXX_Unmarshal 

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

type GetProxyRequest 

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

func (*GetProxyRequest) Descriptor 

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

func (*GetProxyRequest) Marshal 

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

func (*GetProxyRequest) MarshalTo 

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

func (*GetProxyRequest) ProtoMessage 

func (*GetProxyRequest) ProtoMessage()

func (*GetProxyRequest) Reset 

func (m *GetProxyRequest) Reset()

func (*GetProxyRequest) Size 

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

func (*GetProxyRequest) String 

func (m *GetProxyRequest) String() string

func (*GetProxyRequest) Unmarshal 

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

func (*GetProxyRequest) Validate 

func (this *GetProxyRequest) Validate() error

func (*GetProxyRequest) XXX_DiscardUnknown 

func (m *GetProxyRequest) XXX_DiscardUnknown()

func (*GetProxyRequest) XXX_Marshal 

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

func (*GetProxyRequest) XXX_Merge 

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

func (*GetProxyRequest) XXX_Size 

func (m *GetProxyRequest) XXX_Size() int

func (*GetProxyRequest) XXX_Unmarshal 

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

type PoolClient 

type PoolClient interface {
	GetProxy(ctx context.Context, in *GetProxyRequest, opts ...grpc.CallOption) (*Proxy, error)
	DeleteProxy(ctx context.Context, in *DeleteProxyRequest, opts ...grpc.CallOption) (*types.Empty, error)
}

PoolClient is the client API for Pool service.

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

func NewPoolClient 

func NewPoolClient(cc *grpc.ClientConn) PoolClient

type PoolServer 

type PoolServer interface {
	GetProxy(context.Context, *GetProxyRequest) (*Proxy, error)
	DeleteProxy(context.Context, *DeleteProxyRequest) (*types.Empty, error)
}

PoolServer is the server API for Pool service.

type Proxy 

type Proxy struct {
	Validator            string   `protobuf:"bytes,1,opt,name=validator,proto3" json:"validator,omitempty"`
	Addr                 string   `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	CreateTime           string   `protobuf:"bytes,3,opt,name=createTime,proto3" json:"createTime,omitempty"`
	ExpiredSeconds       int32    `protobuf:"varint,4,opt,name=expiredSeconds,proto3" json:"expiredSeconds,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Proxy) Descriptor 

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

func (*Proxy) Expired 

func (p *Proxy) Expired(second int32) bool

func (*Proxy) Marshal 

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

func (*Proxy) MarshalTo 

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

func (*Proxy) ProtoMessage 

func (*Proxy) ProtoMessage()

func (*Proxy) Reset 

func (m *Proxy) Reset()

func (*Proxy) Size 

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

func (*Proxy) String 

func (m *Proxy) String() string

func (*Proxy) Unmarshal 

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

func (*Proxy) Validate 

func (this *Proxy) Validate() error

func (*Proxy) XXX_DiscardUnknown 

func (m *Proxy) XXX_DiscardUnknown()

func (*Proxy) XXX_Marshal 

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

func (*Proxy) XXX_Merge 

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

func (*Proxy) XXX_Size 

func (m *Proxy) XXX_Size() int

func (*Proxy) XXX_Unmarshal 

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

type ProxyValidateRequest 

type ProxyValidateRequest struct {
	Validator            string   `protobuf:"bytes,1,opt,name=validator,proto3" json:"validator,omitempty"`
	ProxyAddr            string   `protobuf:"bytes,2,opt,name=proxyAddr,proto3" json:"proxyAddr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProxyValidateRequest) Descriptor 

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

func (*ProxyValidateRequest) Marshal 

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

func (*ProxyValidateRequest) MarshalTo 

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

func (*ProxyValidateRequest) ProtoMessage 

func (*ProxyValidateRequest) ProtoMessage()

func (*ProxyValidateRequest) Reset 

func (m *ProxyValidateRequest) Reset()

func (*ProxyValidateRequest) Size 

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

func (*ProxyValidateRequest) String 

func (m *ProxyValidateRequest) String() string

func (*ProxyValidateRequest) Unmarshal 

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

func (*ProxyValidateRequest) Validate 

func (this *ProxyValidateRequest) Validate() error

func (*ProxyValidateRequest) XXX_DiscardUnknown 

func (m *ProxyValidateRequest) XXX_DiscardUnknown()

func (*ProxyValidateRequest) XXX_Marshal 

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

func (*ProxyValidateRequest) XXX_Merge 

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

func (*ProxyValidateRequest) XXX_Size 

func (m *ProxyValidateRequest) XXX_Size() int

func (*ProxyValidateRequest) XXX_Unmarshal 

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

type ProxyValidateResponse 

type ProxyValidateResponse struct {
	Proxy                *Proxy   `protobuf:"bytes,1,opt,name=proxy,proto3" json:"proxy,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProxyValidateResponse) Descriptor 

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

func (*ProxyValidateResponse) Marshal 

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

func (*ProxyValidateResponse) MarshalTo 

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

func (*ProxyValidateResponse) ProtoMessage 

func (*ProxyValidateResponse) ProtoMessage()

func (*ProxyValidateResponse) Reset 

func (m *ProxyValidateResponse) Reset()

func (*ProxyValidateResponse) Size 

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

func (*ProxyValidateResponse) String 

func (m *ProxyValidateResponse) String() string

func (*ProxyValidateResponse) Unmarshal 

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

func (*ProxyValidateResponse) Validate 

func (this *ProxyValidateResponse) Validate() error

func (*ProxyValidateResponse) XXX_DiscardUnknown 

func (m *ProxyValidateResponse) XXX_DiscardUnknown()

func (*ProxyValidateResponse) XXX_Marshal 

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

func (*ProxyValidateResponse) XXX_Merge 

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

func (*ProxyValidateResponse) XXX_Size 

func (m *ProxyValidateResponse) XXX_Size() int

func (*ProxyValidateResponse) XXX_Unmarshal 

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

type ValidateStreamCancelRequest 

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

func (*ValidateStreamCancelRequest) Descriptor 

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

func (*ValidateStreamCancelRequest) Marshal 

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

func (*ValidateStreamCancelRequest) MarshalTo 

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

func (*ValidateStreamCancelRequest) ProtoMessage 

func (*ValidateStreamCancelRequest) ProtoMessage()

func (*ValidateStreamCancelRequest) Reset 

func (m *ValidateStreamCancelRequest) Reset()

func (*ValidateStreamCancelRequest) Size 

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

func (*ValidateStreamCancelRequest) String 

func (m *ValidateStreamCancelRequest) String() string

func (*ValidateStreamCancelRequest) Unmarshal 

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

func (*ValidateStreamCancelRequest) Validate 

func (this *ValidateStreamCancelRequest) Validate() error

func (*ValidateStreamCancelRequest) XXX_DiscardUnknown 

func (m *ValidateStreamCancelRequest) XXX_DiscardUnknown()

func (*ValidateStreamCancelRequest) XXX_Marshal 

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

func (*ValidateStreamCancelRequest) XXX_Merge 

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

func (*ValidateStreamCancelRequest) XXX_Size 

func (m *ValidateStreamCancelRequest) XXX_Size() int

func (*ValidateStreamCancelRequest) XXX_Unmarshal 

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

type ValidateStreamCancelResponse 

type ValidateStreamCancelResponse struct {
	Name                 string      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Canceled             bool        `protobuf:"varint,2,opt,name=canceled,proto3" json:"canceled,omitempty"`
	Status               *rpc.Status `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ValidateStreamCancelResponse) Descriptor 

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

func (*ValidateStreamCancelResponse) Marshal 

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

func (*ValidateStreamCancelResponse) MarshalTo 

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

func (*ValidateStreamCancelResponse) ProtoMessage 

func (*ValidateStreamCancelResponse) ProtoMessage()

func (*ValidateStreamCancelResponse) Reset 

func (m *ValidateStreamCancelResponse) Reset()

func (*ValidateStreamCancelResponse) Size 

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

func (*ValidateStreamCancelResponse) String 

func (m *ValidateStreamCancelResponse) String() string

func (*ValidateStreamCancelResponse) Unmarshal 

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

func (*ValidateStreamCancelResponse) Validate 

func (this *ValidateStreamCancelResponse) Validate() error

func (*ValidateStreamCancelResponse) XXX_DiscardUnknown 

func (m *ValidateStreamCancelResponse) XXX_DiscardUnknown()

func (*ValidateStreamCancelResponse) XXX_Marshal 

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

func (*ValidateStreamCancelResponse) XXX_Merge 

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

func (*ValidateStreamCancelResponse) XXX_Size 

func (m *ValidateStreamCancelResponse) XXX_Size() int

func (*ValidateStreamCancelResponse) XXX_Unmarshal 

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

type ValidateStreamCreateRequest 

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

func (*ValidateStreamCreateRequest) Descriptor 

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

func (*ValidateStreamCreateRequest) Marshal 

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

func (*ValidateStreamCreateRequest) MarshalTo 

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

func (*ValidateStreamCreateRequest) ProtoMessage 

func (*ValidateStreamCreateRequest) ProtoMessage()

func (*ValidateStreamCreateRequest) Reset 

func (m *ValidateStreamCreateRequest) Reset()

func (*ValidateStreamCreateRequest) Size 

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

func (*ValidateStreamCreateRequest) String 

func (m *ValidateStreamCreateRequest) String() string

func (*ValidateStreamCreateRequest) Unmarshal 

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

func (*ValidateStreamCreateRequest) Validate 

func (this *ValidateStreamCreateRequest) Validate() error

func (*ValidateStreamCreateRequest) XXX_DiscardUnknown 

func (m *ValidateStreamCreateRequest) XXX_DiscardUnknown()

func (*ValidateStreamCreateRequest) XXX_Marshal 

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

func (*ValidateStreamCreateRequest) XXX_Merge 

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

func (*ValidateStreamCreateRequest) XXX_Size 

func (m *ValidateStreamCreateRequest) XXX_Size() int

func (*ValidateStreamCreateRequest) XXX_Unmarshal 

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

type ValidateStreamCreateResponse 

type ValidateStreamCreateResponse struct {
	Name                 string      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Created              bool        `protobuf:"varint,2,opt,name=created,proto3" json:"created,omitempty"`
	Status               *rpc.Status `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ValidateStreamCreateResponse) Descriptor 

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

func (*ValidateStreamCreateResponse) Marshal 

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

func (*ValidateStreamCreateResponse) MarshalTo 

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

func (*ValidateStreamCreateResponse) ProtoMessage 

func (*ValidateStreamCreateResponse) ProtoMessage()

func (*ValidateStreamCreateResponse) Reset 

func (m *ValidateStreamCreateResponse) Reset()

func (*ValidateStreamCreateResponse) Size 

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

func (*ValidateStreamCreateResponse) String 

func (m *ValidateStreamCreateResponse) String() string

func (*ValidateStreamCreateResponse) Unmarshal 

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

func (*ValidateStreamCreateResponse) Validate 

func (this *ValidateStreamCreateResponse) Validate() error

func (*ValidateStreamCreateResponse) XXX_DiscardUnknown 

func (m *ValidateStreamCreateResponse) XXX_DiscardUnknown()

func (*ValidateStreamCreateResponse) XXX_Marshal 

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

func (*ValidateStreamCreateResponse) XXX_Merge 

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

func (*ValidateStreamCreateResponse) XXX_Size 

func (m *ValidateStreamCreateResponse) XXX_Size() int

func (*ValidateStreamCreateResponse) XXX_Unmarshal 

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

type ValidateStreamRequest 

type ValidateStreamRequest struct {
	// Types that are valid to be assigned to RequestUnion:
	//	*ValidateStreamRequest_CreateRequest
	//	*ValidateStreamRequest_CancelRequest
	//	*ValidateStreamRequest_ProxyResponse
	RequestUnion         isValidateStreamRequest_RequestUnion `protobuf_oneof:"request_union"`
	XXX_NoUnkeyedLiteral struct{}                             `json:"-"`
	XXX_unrecognized     []byte                               `json:"-"`
	XXX_sizecache        int32                                `json:"-"`
}

func (*ValidateStreamRequest) Descriptor 

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

func (*ValidateStreamRequest) GetCancelRequest 

func (m *ValidateStreamRequest) GetCancelRequest() *ValidateStreamCancelRequest

func (*ValidateStreamRequest) GetCreateRequest 

func (m *ValidateStreamRequest) GetCreateRequest() *ValidateStreamCreateRequest

func (*ValidateStreamRequest) GetProxyResponse 

func (m *ValidateStreamRequest) GetProxyResponse() *ProxyValidateResponse

func (*ValidateStreamRequest) GetRequestUnion 

func (m *ValidateStreamRequest) GetRequestUnion() isValidateStreamRequest_RequestUnion

func (*ValidateStreamRequest) Marshal 

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

func (*ValidateStreamRequest) MarshalTo 

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

func (*ValidateStreamRequest) ProtoMessage 

func (*ValidateStreamRequest) ProtoMessage()

func (*ValidateStreamRequest) Reset 

func (m *ValidateStreamRequest) Reset()

func (*ValidateStreamRequest) Size 

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

func (*ValidateStreamRequest) String 

func (m *ValidateStreamRequest) String() string

func (*ValidateStreamRequest) Unmarshal 

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

func (*ValidateStreamRequest) Validate 

func (this *ValidateStreamRequest) Validate() error

func (*ValidateStreamRequest) XXX_DiscardUnknown 

func (m *ValidateStreamRequest) XXX_DiscardUnknown()

func (*ValidateStreamRequest) XXX_Marshal 

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

func (*ValidateStreamRequest) XXX_Merge 

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

func (*ValidateStreamRequest) XXX_OneofFuncs 

func (*ValidateStreamRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*ValidateStreamRequest) XXX_Size 

func (m *ValidateStreamRequest) XXX_Size() int

func (*ValidateStreamRequest) XXX_Unmarshal 

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

type ValidateStreamRequest_CancelRequest 

type ValidateStreamRequest_CancelRequest struct {
	CancelRequest *ValidateStreamCancelRequest `protobuf:"bytes,2,opt,name=cancelRequest,proto3,oneof"`
}

func (*ValidateStreamRequest_CancelRequest) MarshalTo 

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

func (*ValidateStreamRequest_CancelRequest) Size 

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

type ValidateStreamRequest_CreateRequest 

type ValidateStreamRequest_CreateRequest struct {
	CreateRequest *ValidateStreamCreateRequest `protobuf:"bytes,1,opt,name=createRequest,proto3,oneof"`
}

func (*ValidateStreamRequest_CreateRequest) MarshalTo 

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

func (*ValidateStreamRequest_CreateRequest) Size 

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

type ValidateStreamRequest_ProxyResponse 

type ValidateStreamRequest_ProxyResponse struct {
	ProxyResponse *ProxyValidateResponse `protobuf:"bytes,3,opt,name=proxyResponse,proto3,oneof"`
}

func (*ValidateStreamRequest_ProxyResponse) MarshalTo 

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

func (*ValidateStreamRequest_ProxyResponse) Size 

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

type ValidateStreamResponse 

type ValidateStreamResponse struct {
	StreamID int64 `protobuf:"varint,1,opt,name=streamID,proto3" json:"streamID,omitempty"`
	// Types that are valid to be assigned to ResponseUnion:
	//	*ValidateStreamResponse_CreateResponse
	//	*ValidateStreamResponse_CancelResponse
	//	*ValidateStreamResponse_ProxyRequest
	ResponseUnion        isValidateStreamResponse_ResponseUnion `protobuf_oneof:"response_union"`
	XXX_NoUnkeyedLiteral struct{}                               `json:"-"`
	XXX_unrecognized     []byte                                 `json:"-"`
	XXX_sizecache        int32                                  `json:"-"`
}

func (*ValidateStreamResponse) Descriptor 

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

func (*ValidateStreamResponse) GetCancelResponse 

func (m *ValidateStreamResponse) GetCancelResponse() *ValidateStreamCancelResponse

func (*ValidateStreamResponse) GetCreateResponse 

func (m *ValidateStreamResponse) GetCreateResponse() *ValidateStreamCreateResponse

func (*ValidateStreamResponse) GetProxyRequest 

func (m *ValidateStreamResponse) GetProxyRequest() *ProxyValidateRequest

func (*ValidateStreamResponse) GetResponseUnion 

func (m *ValidateStreamResponse) GetResponseUnion() isValidateStreamResponse_ResponseUnion

func (*ValidateStreamResponse) Marshal 

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

func (*ValidateStreamResponse) MarshalTo 

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

func (*ValidateStreamResponse) ProtoMessage 

func (*ValidateStreamResponse) ProtoMessage()

func (*ValidateStreamResponse) Reset 

func (m *ValidateStreamResponse) Reset()

func (*ValidateStreamResponse) Size 

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

func (*ValidateStreamResponse) String 

func (m *ValidateStreamResponse) String() string

func (*ValidateStreamResponse) Unmarshal 

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

func (*ValidateStreamResponse) Validate 

func (this *ValidateStreamResponse) Validate() error

func (*ValidateStreamResponse) XXX_DiscardUnknown 

func (m *ValidateStreamResponse) XXX_DiscardUnknown()

func (*ValidateStreamResponse) XXX_Marshal 

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

func (*ValidateStreamResponse) XXX_Merge 

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

func (*ValidateStreamResponse) XXX_OneofFuncs 

func (*ValidateStreamResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*ValidateStreamResponse) XXX_Size 

func (m *ValidateStreamResponse) XXX_Size() int

func (*ValidateStreamResponse) XXX_Unmarshal 

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

type ValidateStreamResponse_CancelResponse 

type ValidateStreamResponse_CancelResponse struct {
	CancelResponse *ValidateStreamCancelResponse `protobuf:"bytes,3,opt,name=cancelResponse,proto3,oneof"`
}

func (*ValidateStreamResponse_CancelResponse) MarshalTo 

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

func (*ValidateStreamResponse_CancelResponse) Size 

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

type ValidateStreamResponse_CreateResponse 

type ValidateStreamResponse_CreateResponse struct {
	CreateResponse *ValidateStreamCreateResponse `protobuf:"bytes,2,opt,name=createResponse,proto3,oneof"`
}

func (*ValidateStreamResponse_CreateResponse) MarshalTo 

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

func (*ValidateStreamResponse_CreateResponse) Size 

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

type ValidateStreamResponse_ProxyRequest 

type ValidateStreamResponse_ProxyRequest struct {
	ProxyRequest *ProxyValidateRequest `protobuf:"bytes,4,opt,name=proxyRequest,proto3,oneof"`
}

func (*ValidateStreamResponse_ProxyRequest) MarshalTo 

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

func (*ValidateStreamResponse_ProxyRequest) Size 

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

type ValidatorClient 

type ValidatorClient interface {
	ValidateStream(ctx context.Context, opts ...grpc.CallOption) (Validator_ValidateStreamClient, error)
}

ValidatorClient is the client API for Validator service.

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

func NewValidatorClient 

func NewValidatorClient(cc *grpc.ClientConn) ValidatorClient

type ValidatorServer 

type ValidatorServer interface {
	ValidateStream(Validator_ValidateStreamServer) error
}

ValidatorServer is the server API for Validator service.

type Validator_ValidateStreamClient 

type Validator_ValidateStreamClient interface {
	Send(*ValidateStreamRequest) error
	Recv() (*ValidateStreamResponse, error)
	grpc.ClientStream
}

type Validator_ValidateStreamServer 

type Validator_ValidateStreamServer interface {
	Send(*ValidateStreamResponse) error
	Recv() (*ValidateStreamRequest, error)
	grpc.ServerStream
}

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.