sync

package
v4.0.2 Latest Latest
Warning

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

 Go to latest Published: Mar 11, 2026 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Overview

Package sync is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthSync        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSync          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSync = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var SyncConfigType_name = map[int32]string{
	0: "CONFIGMAP",
	1: "DATABASE",
}
View Source 
var SyncConfigType_value = map[string]int32{
	"CONFIGMAP": 0,
	"DATABASE":  1,
}

Functions

func RegisterSyncServiceHandler 

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

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

func RegisterSyncServiceHandlerClient 

func RegisterSyncServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SyncServiceClient) error

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

func RegisterSyncServiceHandlerFromEndpoint 

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

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

func RegisterSyncServiceHandlerServer 

func RegisterSyncServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server SyncServiceServer) error

RegisterSyncServiceHandlerServer registers the http handlers for service SyncService to "mux". UnaryRPC :call SyncServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterSyncServiceHandlerFromEndpoint instead.

func RegisterSyncServiceServer 

func RegisterSyncServiceServer(s *grpc.Server, srv SyncServiceServer)

Types

type CreateSyncLimitRequest 

type CreateSyncLimitRequest struct {
	Type                 SyncConfigType `protobuf:"varint,1,opt,name=type,proto3,enum=sync.SyncConfigType" json:"type,omitempty"`
	Namespace            string         `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	CmName               string         `protobuf:"bytes,3,opt,name=cmName,proto3" json:"cmName,omitempty"`
	Key                  string         `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	Limit                int32          `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*CreateSyncLimitRequest) Descriptor 

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

func (*CreateSyncLimitRequest) GetCmName 

func (m *CreateSyncLimitRequest) GetCmName() string

func (*CreateSyncLimitRequest) GetKey 

func (m *CreateSyncLimitRequest) GetKey() string

func (*CreateSyncLimitRequest) GetLimit 

func (m *CreateSyncLimitRequest) GetLimit() int32

func (*CreateSyncLimitRequest) GetNamespace 

func (m *CreateSyncLimitRequest) GetNamespace() string

func (*CreateSyncLimitRequest) GetType 

func (m *CreateSyncLimitRequest) GetType() SyncConfigType

func (*CreateSyncLimitRequest) Marshal 

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

func (*CreateSyncLimitRequest) MarshalTo 

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

func (*CreateSyncLimitRequest) MarshalToSizedBuffer 

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

func (*CreateSyncLimitRequest) ProtoMessage 

func (*CreateSyncLimitRequest) ProtoMessage()

func (*CreateSyncLimitRequest) Reset 

func (m *CreateSyncLimitRequest) Reset()

func (*CreateSyncLimitRequest) Size 

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

func (*CreateSyncLimitRequest) String 

func (m *CreateSyncLimitRequest) String() string

func (*CreateSyncLimitRequest) Unmarshal 

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

func (*CreateSyncLimitRequest) XXX_DiscardUnknown 

func (m *CreateSyncLimitRequest) XXX_DiscardUnknown()

func (*CreateSyncLimitRequest) XXX_Marshal 

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

func (*CreateSyncLimitRequest) XXX_Merge 

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

func (*CreateSyncLimitRequest) XXX_Size 

func (m *CreateSyncLimitRequest) XXX_Size() int

func (*CreateSyncLimitRequest) XXX_Unmarshal 

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

type DeleteSyncLimitRequest 

type DeleteSyncLimitRequest struct {
	Type                 SyncConfigType `protobuf:"varint,1,opt,name=type,proto3,enum=sync.SyncConfigType" json:"type,omitempty"`
	Namespace            string         `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	CmName               string         `protobuf:"bytes,3,opt,name=cmName,proto3" json:"cmName,omitempty"`
	Key                  string         `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*DeleteSyncLimitRequest) Descriptor 

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

func (*DeleteSyncLimitRequest) GetCmName 

func (m *DeleteSyncLimitRequest) GetCmName() string

func (*DeleteSyncLimitRequest) GetKey 

func (m *DeleteSyncLimitRequest) GetKey() string

func (*DeleteSyncLimitRequest) GetNamespace 

func (m *DeleteSyncLimitRequest) GetNamespace() string

func (*DeleteSyncLimitRequest) GetType 

func (m *DeleteSyncLimitRequest) GetType() SyncConfigType

func (*DeleteSyncLimitRequest) Marshal 

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

func (*DeleteSyncLimitRequest) MarshalTo 

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

func (*DeleteSyncLimitRequest) MarshalToSizedBuffer 

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

func (*DeleteSyncLimitRequest) ProtoMessage 

func (*DeleteSyncLimitRequest) ProtoMessage()

func (*DeleteSyncLimitRequest) Reset 

func (m *DeleteSyncLimitRequest) Reset()

func (*DeleteSyncLimitRequest) Size 

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

func (*DeleteSyncLimitRequest) String 

func (m *DeleteSyncLimitRequest) String() string

func (*DeleteSyncLimitRequest) Unmarshal 

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

func (*DeleteSyncLimitRequest) XXX_DiscardUnknown 

func (m *DeleteSyncLimitRequest) XXX_DiscardUnknown()

func (*DeleteSyncLimitRequest) XXX_Marshal 

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

func (*DeleteSyncLimitRequest) XXX_Merge 

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

func (*DeleteSyncLimitRequest) XXX_Size 

func (m *DeleteSyncLimitRequest) XXX_Size() int

func (*DeleteSyncLimitRequest) XXX_Unmarshal 

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

type DeleteSyncLimitResponse 

type DeleteSyncLimitResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteSyncLimitResponse) Descriptor 

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

func (*DeleteSyncLimitResponse) Marshal 

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

func (*DeleteSyncLimitResponse) MarshalTo 

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

func (*DeleteSyncLimitResponse) MarshalToSizedBuffer 

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

func (*DeleteSyncLimitResponse) ProtoMessage 

func (*DeleteSyncLimitResponse) ProtoMessage()

func (*DeleteSyncLimitResponse) Reset 

func (m *DeleteSyncLimitResponse) Reset()

func (*DeleteSyncLimitResponse) Size 

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

func (*DeleteSyncLimitResponse) String 

func (m *DeleteSyncLimitResponse) String() string

func (*DeleteSyncLimitResponse) Unmarshal 

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

func (*DeleteSyncLimitResponse) XXX_DiscardUnknown 

func (m *DeleteSyncLimitResponse) XXX_DiscardUnknown()

func (*DeleteSyncLimitResponse) XXX_Marshal 

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

func (*DeleteSyncLimitResponse) XXX_Merge 

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

func (*DeleteSyncLimitResponse) XXX_Size 

func (m *DeleteSyncLimitResponse) XXX_Size() int

func (*DeleteSyncLimitResponse) XXX_Unmarshal 

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

type GetSyncLimitRequest 

type GetSyncLimitRequest struct {
	Type                 SyncConfigType `protobuf:"varint,1,opt,name=type,proto3,enum=sync.SyncConfigType" json:"type,omitempty"`
	Namespace            string         `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	CmName               string         `protobuf:"bytes,3,opt,name=cmName,proto3" json:"cmName,omitempty"`
	Key                  string         `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetSyncLimitRequest) Descriptor 

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

func (*GetSyncLimitRequest) GetCmName 

func (m *GetSyncLimitRequest) GetCmName() string

func (*GetSyncLimitRequest) GetKey 

func (m *GetSyncLimitRequest) GetKey() string

func (*GetSyncLimitRequest) GetNamespace 

func (m *GetSyncLimitRequest) GetNamespace() string

func (*GetSyncLimitRequest) GetType 

func (m *GetSyncLimitRequest) GetType() SyncConfigType

func (*GetSyncLimitRequest) Marshal 

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

func (*GetSyncLimitRequest) MarshalTo 

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

func (*GetSyncLimitRequest) MarshalToSizedBuffer 

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

func (*GetSyncLimitRequest) ProtoMessage 

func (*GetSyncLimitRequest) ProtoMessage()

func (*GetSyncLimitRequest) Reset 

func (m *GetSyncLimitRequest) Reset()

func (*GetSyncLimitRequest) Size 

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

func (*GetSyncLimitRequest) String 

func (m *GetSyncLimitRequest) String() string

func (*GetSyncLimitRequest) Unmarshal 

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

func (*GetSyncLimitRequest) XXX_DiscardUnknown 

func (m *GetSyncLimitRequest) XXX_DiscardUnknown()

func (*GetSyncLimitRequest) XXX_Marshal 

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

func (*GetSyncLimitRequest) XXX_Merge 

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

func (*GetSyncLimitRequest) XXX_Size 

func (m *GetSyncLimitRequest) XXX_Size() int

func (*GetSyncLimitRequest) XXX_Unmarshal 

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

type SyncConfigType 

type SyncConfigType int32
const (
	SyncConfigType_CONFIGMAP SyncConfigType = 0
	SyncConfigType_DATABASE  SyncConfigType = 1
)

func (SyncConfigType) EnumDescriptor 

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

func (SyncConfigType) String 

func (x SyncConfigType) String() string

type SyncLimitResponse 

type SyncLimitResponse struct {
	Type                 SyncConfigType `protobuf:"varint,1,opt,name=type,proto3,enum=sync.SyncConfigType" json:"type,omitempty"`
	Namespace            string         `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	CmName               string         `protobuf:"bytes,3,opt,name=cmName,proto3" json:"cmName,omitempty"`
	Key                  string         `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	Limit                int32          `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*SyncLimitResponse) Descriptor 

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

func (*SyncLimitResponse) GetCmName 

func (m *SyncLimitResponse) GetCmName() string

func (*SyncLimitResponse) GetKey 

func (m *SyncLimitResponse) GetKey() string

func (*SyncLimitResponse) GetLimit 

func (m *SyncLimitResponse) GetLimit() int32

func (*SyncLimitResponse) GetNamespace 

func (m *SyncLimitResponse) GetNamespace() string

func (*SyncLimitResponse) GetType 

func (m *SyncLimitResponse) GetType() SyncConfigType

func (*SyncLimitResponse) Marshal 

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

func (*SyncLimitResponse) MarshalTo 

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

func (*SyncLimitResponse) MarshalToSizedBuffer 

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

func (*SyncLimitResponse) ProtoMessage 

func (*SyncLimitResponse) ProtoMessage()

func (*SyncLimitResponse) Reset 

func (m *SyncLimitResponse) Reset()

func (*SyncLimitResponse) Size 

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

func (*SyncLimitResponse) String 

func (m *SyncLimitResponse) String() string

func (*SyncLimitResponse) Unmarshal 

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

func (*SyncLimitResponse) XXX_DiscardUnknown 

func (m *SyncLimitResponse) XXX_DiscardUnknown()

func (*SyncLimitResponse) XXX_Marshal 

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

func (*SyncLimitResponse) XXX_Merge 

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

func (*SyncLimitResponse) XXX_Size 

func (m *SyncLimitResponse) XXX_Size() int

func (*SyncLimitResponse) XXX_Unmarshal 

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

type SyncServiceClient 

type SyncServiceClient interface {
	CreateSyncLimit(ctx context.Context, in *CreateSyncLimitRequest, opts ...grpc.CallOption) (*SyncLimitResponse, error)
	GetSyncLimit(ctx context.Context, in *GetSyncLimitRequest, opts ...grpc.CallOption) (*SyncLimitResponse, error)
	UpdateSyncLimit(ctx context.Context, in *UpdateSyncLimitRequest, opts ...grpc.CallOption) (*SyncLimitResponse, error)
	DeleteSyncLimit(ctx context.Context, in *DeleteSyncLimitRequest, opts ...grpc.CallOption) (*DeleteSyncLimitResponse, error)
}

SyncServiceClient is the client API for SyncService service.

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

func NewSyncServiceClient 

func NewSyncServiceClient(cc *grpc.ClientConn) SyncServiceClient

type SyncServiceServer 

type SyncServiceServer interface {
	CreateSyncLimit(context.Context, *CreateSyncLimitRequest) (*SyncLimitResponse, error)
	GetSyncLimit(context.Context, *GetSyncLimitRequest) (*SyncLimitResponse, error)
	UpdateSyncLimit(context.Context, *UpdateSyncLimitRequest) (*SyncLimitResponse, error)
	DeleteSyncLimit(context.Context, *DeleteSyncLimitRequest) (*DeleteSyncLimitResponse, error)
}

SyncServiceServer is the server API for SyncService service.

type UnimplementedSyncServiceServer 

type UnimplementedSyncServiceServer struct {
}

UnimplementedSyncServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSyncServiceServer) CreateSyncLimit 

func (*UnimplementedSyncServiceServer) CreateSyncLimit(ctx context.Context, req *CreateSyncLimitRequest) (*SyncLimitResponse, error)

func (*UnimplementedSyncServiceServer) DeleteSyncLimit 

func (*UnimplementedSyncServiceServer) DeleteSyncLimit(ctx context.Context, req *DeleteSyncLimitRequest) (*DeleteSyncLimitResponse, error)

func (*UnimplementedSyncServiceServer) GetSyncLimit 

func (*UnimplementedSyncServiceServer) GetSyncLimit(ctx context.Context, req *GetSyncLimitRequest) (*SyncLimitResponse, error)

func (*UnimplementedSyncServiceServer) UpdateSyncLimit 

func (*UnimplementedSyncServiceServer) UpdateSyncLimit(ctx context.Context, req *UpdateSyncLimitRequest) (*SyncLimitResponse, error)

type UpdateSyncLimitRequest 

type UpdateSyncLimitRequest struct {
	Type                 SyncConfigType `protobuf:"varint,1,opt,name=type,proto3,enum=sync.SyncConfigType" json:"type,omitempty"`
	Namespace            string         `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	CmName               string         `protobuf:"bytes,3,opt,name=cmName,proto3" json:"cmName,omitempty"`
	Key                  string         `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	Limit                int32          `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*UpdateSyncLimitRequest) Descriptor 

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

func (*UpdateSyncLimitRequest) GetCmName 

func (m *UpdateSyncLimitRequest) GetCmName() string

func (*UpdateSyncLimitRequest) GetKey 

func (m *UpdateSyncLimitRequest) GetKey() string

func (*UpdateSyncLimitRequest) GetLimit 

func (m *UpdateSyncLimitRequest) GetLimit() int32

func (*UpdateSyncLimitRequest) GetNamespace 

func (m *UpdateSyncLimitRequest) GetNamespace() string

func (*UpdateSyncLimitRequest) GetType 

func (m *UpdateSyncLimitRequest) GetType() SyncConfigType

func (*UpdateSyncLimitRequest) Marshal 

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

func (*UpdateSyncLimitRequest) MarshalTo 

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

func (*UpdateSyncLimitRequest) MarshalToSizedBuffer 

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

func (*UpdateSyncLimitRequest) ProtoMessage 

func (*UpdateSyncLimitRequest) ProtoMessage()

func (*UpdateSyncLimitRequest) Reset 

func (m *UpdateSyncLimitRequest) Reset()

func (*UpdateSyncLimitRequest) Size 

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

func (*UpdateSyncLimitRequest) String 

func (m *UpdateSyncLimitRequest) String() string

func (*UpdateSyncLimitRequest) Unmarshal 

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

func (*UpdateSyncLimitRequest) XXX_DiscardUnknown 

func (m *UpdateSyncLimitRequest) XXX_DiscardUnknown()

func (*UpdateSyncLimitRequest) XXX_Marshal 

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

func (*UpdateSyncLimitRequest) XXX_Merge 

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

func (*UpdateSyncLimitRequest) XXX_Size 

func (m *UpdateSyncLimitRequest) XXX_Size() int

func (*UpdateSyncLimitRequest) XXX_Unmarshal 

func (m *UpdateSyncLimitRequest) XXX_Unmarshal(b []byte) 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.