Help us shape the future of Go! Take the 2026 Go Developer Survey

sync

package
v4.0.13 Latest Latest
Warning

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

 Go to latest Published: Oct 9, 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.