 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
  
    Index ¶
- Variables
- func NewConfigEndpoints() []*api.Endpoint
- func RegisterConfigHandler(s server.Server, hdlr ConfigHandler, opts ...server.HandlerOption) error
- func RegisterConfigServer(s *grpc.Server, srv ConfigServer)
- type Change
- func (*Change) Descriptor() ([]byte, []int)deprecated
- func (x *Change) GetChangeSet() *ChangeSet
- func (x *Change) GetNamespace() string
- func (x *Change) GetPath() string
- func (*Change) ProtoMessage()
- func (x *Change) ProtoReflect() protoreflect.Message
- func (x *Change) Reset()
- func (x *Change) String() string
 
- type ChangeSet
- func (*ChangeSet) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeSet) GetChecksum() string
- func (x *ChangeSet) GetData() string
- func (x *ChangeSet) GetFormat() string
- func (x *ChangeSet) GetSource() string
- func (x *ChangeSet) GetTimestamp() int64
- func (*ChangeSet) ProtoMessage()
- func (x *ChangeSet) ProtoReflect() protoreflect.Message
- func (x *ChangeSet) Reset()
- func (x *ChangeSet) String() string
 
- type ConfigClient
- type ConfigHandler
- type ConfigServer
- type ConfigService
- type Config_WatchClient
- type Config_WatchServer
- type Config_WatchService
- type Config_WatchStream
- type CreateRequest
- type CreateResponse
- type DeleteRequest
- type DeleteResponse
- type ListRequest
- type ListResponse
- type ReadRequest
- func (*ReadRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReadRequest) GetNamespace() string
- func (x *ReadRequest) GetPath() string
- func (*ReadRequest) ProtoMessage()
- func (x *ReadRequest) ProtoReflect() protoreflect.Message
- func (x *ReadRequest) Reset()
- func (x *ReadRequest) String() string
 
- type ReadResponse
- type UnimplementedConfigServer
- func (*UnimplementedConfigServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)
- func (*UnimplementedConfigServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
- func (*UnimplementedConfigServer) List(context.Context, *ListRequest) (*ListResponse, error)
- func (*UnimplementedConfigServer) Read(context.Context, *ReadRequest) (*ReadResponse, error)
- func (*UnimplementedConfigServer) Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
- func (*UnimplementedConfigServer) Watch(*WatchRequest, Config_WatchServer) error
 
- type UpdateRequest
- type UpdateResponse
- type WatchRequest
- func (*WatchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WatchRequest) GetNamespace() string
- func (x *WatchRequest) GetPath() string
- func (*WatchRequest) ProtoMessage()
- func (x *WatchRequest) ProtoReflect() protoreflect.Message
- func (x *WatchRequest) Reset()
- func (x *WatchRequest) String() string
 
- type WatchResponse
- func (*WatchResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WatchResponse) GetChangeSet() *ChangeSet
- func (x *WatchResponse) GetNamespace() string
- func (*WatchResponse) ProtoMessage()
- func (x *WatchResponse) ProtoReflect() protoreflect.Message
- func (x *WatchResponse) Reset()
- func (x *WatchResponse) String() string
 
Constants ¶
This section is empty.
Variables ¶
var File_config_source_service_proto_service_proto protoreflect.FileDescriptor
    Functions ¶
func NewConfigEndpoints ¶
func RegisterConfigHandler ¶
func RegisterConfigHandler(s server.Server, hdlr ConfigHandler, opts ...server.HandlerOption) error
func RegisterConfigServer ¶
func RegisterConfigServer(s *grpc.Server, srv ConfigServer)
Types ¶
type Change ¶
type Change struct {
	Namespace string     `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Path      string     `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	ChangeSet *ChangeSet `protobuf:"bytes,3,opt,name=changeSet,proto3" json:"changeSet,omitempty"`
	// contains filtered or unexported fields
}
    
        
          
            func (*Change) Descriptor
            deprecated
            
          
  
    
  
      
      
    func (*Change) GetChangeSet ¶
func (*Change) GetNamespace ¶
func (*Change) ProtoMessage ¶
func (*Change) ProtoMessage()
func (*Change) ProtoReflect ¶
func (x *Change) ProtoReflect() protoreflect.Message
type ChangeSet ¶
type ChangeSet struct {
	Data      string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Checksum  string `protobuf:"bytes,2,opt,name=checksum,proto3" json:"checksum,omitempty"`
	Format    string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	Source    string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
	Timestamp int64  `protobuf:"varint,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}
    
        
          
            func (*ChangeSet) Descriptor
            deprecated
            
          
  
    
  
      
      
    func (*ChangeSet) GetChecksum ¶
func (*ChangeSet) GetTimestamp ¶
func (*ChangeSet) ProtoMessage ¶
func (*ChangeSet) ProtoMessage()
func (*ChangeSet) ProtoReflect ¶
func (x *ChangeSet) ProtoReflect() protoreflect.Message
type ConfigClient ¶
type ConfigClient interface {
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)
	Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (Config_WatchClient, error)
}
    ConfigClient is the client API for Config service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewConfigClient ¶
func NewConfigClient(cc grpc.ClientConnInterface) ConfigClient
type ConfigHandler ¶
type ConfigHandler interface {
	Create(context.Context, *CreateRequest, *CreateResponse) error
	Update(context.Context, *UpdateRequest, *UpdateResponse) error
	Delete(context.Context, *DeleteRequest, *DeleteResponse) error
	List(context.Context, *ListRequest, *ListResponse) error
	Read(context.Context, *ReadRequest, *ReadResponse) error
	Watch(context.Context, *WatchRequest, Config_WatchStream) error
}
    type ConfigServer ¶
type ConfigServer interface {
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	List(context.Context, *ListRequest) (*ListResponse, error)
	Read(context.Context, *ReadRequest) (*ReadResponse, error)
	Watch(*WatchRequest, Config_WatchServer) error
}
    ConfigServer is the server API for Config service.
type ConfigService ¶
type ConfigService interface {
	Create(ctx context.Context, in *CreateRequest, opts ...client.CallOption) (*CreateResponse, error)
	Update(ctx context.Context, in *UpdateRequest, opts ...client.CallOption) (*UpdateResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...client.CallOption) (*DeleteResponse, error)
	List(ctx context.Context, in *ListRequest, opts ...client.CallOption) (*ListResponse, error)
	Read(ctx context.Context, in *ReadRequest, opts ...client.CallOption) (*ReadResponse, error)
	Watch(ctx context.Context, in *WatchRequest, opts ...client.CallOption) (Config_WatchService, error)
}
    func NewConfigService ¶
func NewConfigService(name string, c client.Client) ConfigService
type Config_WatchClient ¶
type Config_WatchClient interface {
	Recv() (*WatchResponse, error)
	grpc.ClientStream
}
    type Config_WatchServer ¶
type Config_WatchServer interface {
	Send(*WatchResponse) error
	grpc.ServerStream
}
    type Config_WatchService ¶
type Config_WatchStream ¶
type CreateRequest ¶
type CreateRequest struct {
	Change *Change `protobuf:"bytes,1,opt,name=change,proto3" json:"change,omitempty"`
	// contains filtered or unexported fields
}
    
        
          
            func (*CreateRequest) Descriptor
            deprecated
            
          
  
    
  
      
      func (*CreateRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.
func (*CreateRequest) GetChange ¶
func (x *CreateRequest) GetChange() *Change
func (*CreateRequest) ProtoMessage ¶
func (*CreateRequest) ProtoMessage()
func (*CreateRequest) ProtoReflect ¶
func (x *CreateRequest) ProtoReflect() protoreflect.Message
func (*CreateRequest) Reset ¶
func (x *CreateRequest) Reset()
func (*CreateRequest) String ¶
func (x *CreateRequest) String() string
type CreateResponse ¶
type CreateResponse struct {
	// contains filtered or unexported fields
}
    
        
          
            func (*CreateResponse) Descriptor
            deprecated
            
          
  
    
  
      
      func (*CreateResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.
func (*CreateResponse) ProtoMessage ¶
func (*CreateResponse) ProtoMessage()
func (*CreateResponse) ProtoReflect ¶
func (x *CreateResponse) ProtoReflect() protoreflect.Message
func (*CreateResponse) Reset ¶
func (x *CreateResponse) Reset()
func (*CreateResponse) String ¶
func (x *CreateResponse) String() string
type DeleteRequest ¶
type DeleteRequest struct {
	Change *Change `protobuf:"bytes,1,opt,name=change,proto3" json:"change,omitempty"`
	// contains filtered or unexported fields
}
    
        
          
            func (*DeleteRequest) Descriptor
            deprecated
            
          
  
    
  
      
      func (*DeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.
func (*DeleteRequest) GetChange ¶
func (x *DeleteRequest) GetChange() *Change
func (*DeleteRequest) ProtoMessage ¶
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) ProtoReflect ¶
func (x *DeleteRequest) ProtoReflect() protoreflect.Message
func (*DeleteRequest) Reset ¶
func (x *DeleteRequest) Reset()
func (*DeleteRequest) String ¶
func (x *DeleteRequest) String() string
type DeleteResponse ¶
type DeleteResponse struct {
	// contains filtered or unexported fields
}
    
        
          
            func (*DeleteResponse) Descriptor
            deprecated
            
          
  
    
  
      
      func (*DeleteResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.
func (*DeleteResponse) ProtoMessage ¶
func (*DeleteResponse) ProtoMessage()
func (*DeleteResponse) ProtoReflect ¶
func (x *DeleteResponse) ProtoReflect() protoreflect.Message
func (*DeleteResponse) Reset ¶
func (x *DeleteResponse) Reset()
func (*DeleteResponse) String ¶
func (x *DeleteResponse) String() string
type ListRequest ¶
type ListRequest struct {
	// contains filtered or unexported fields
}
    
        
          
            func (*ListRequest) Descriptor
            deprecated
            
          
  
    
  
      
      func (*ListRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) ProtoReflect ¶
func (x *ListRequest) ProtoReflect() protoreflect.Message
func (*ListRequest) Reset ¶
func (x *ListRequest) Reset()
func (*ListRequest) String ¶
func (x *ListRequest) String() string
type ListResponse ¶
type ListResponse struct {
	Values []*Change `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}
    
        
          
            func (*ListResponse) Descriptor
            deprecated
            
          
  
    
  
      
      func (*ListResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.
func (*ListResponse) GetValues ¶
func (x *ListResponse) GetValues() []*Change
func (*ListResponse) ProtoMessage ¶
func (*ListResponse) ProtoMessage()
func (*ListResponse) ProtoReflect ¶
func (x *ListResponse) ProtoReflect() protoreflect.Message
func (*ListResponse) Reset ¶
func (x *ListResponse) Reset()
func (*ListResponse) String ¶
func (x *ListResponse) String() string
type ReadRequest ¶
type ReadRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Path      string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}
    
        
          
            func (*ReadRequest) Descriptor
            deprecated
            
          
  
    
  
      
      func (*ReadRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadRequest.ProtoReflect.Descriptor instead.
func (*ReadRequest) GetNamespace ¶
func (x *ReadRequest) GetNamespace() string
func (*ReadRequest) GetPath ¶
func (x *ReadRequest) GetPath() string
func (*ReadRequest) ProtoMessage ¶
func (*ReadRequest) ProtoMessage()
func (*ReadRequest) ProtoReflect ¶
func (x *ReadRequest) ProtoReflect() protoreflect.Message
func (*ReadRequest) Reset ¶
func (x *ReadRequest) Reset()
func (*ReadRequest) String ¶
func (x *ReadRequest) String() string
type ReadResponse ¶
type ReadResponse struct {
	Change *Change `protobuf:"bytes,1,opt,name=change,proto3" json:"change,omitempty"`
	// contains filtered or unexported fields
}
    
        
          
            func (*ReadResponse) Descriptor
            deprecated
            
          
  
    
  
      
      func (*ReadResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReadResponse.ProtoReflect.Descriptor instead.
func (*ReadResponse) GetChange ¶
func (x *ReadResponse) GetChange() *Change
func (*ReadResponse) ProtoMessage ¶
func (*ReadResponse) ProtoMessage()
func (*ReadResponse) ProtoReflect ¶
func (x *ReadResponse) ProtoReflect() protoreflect.Message
func (*ReadResponse) Reset ¶
func (x *ReadResponse) Reset()
func (*ReadResponse) String ¶
func (x *ReadResponse) String() string
type UnimplementedConfigServer ¶
type UnimplementedConfigServer struct {
}
    UnimplementedConfigServer can be embedded to have forward compatible implementations.
func (*UnimplementedConfigServer) Create ¶
func (*UnimplementedConfigServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)
func (*UnimplementedConfigServer) Delete ¶
func (*UnimplementedConfigServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
func (*UnimplementedConfigServer) List ¶
func (*UnimplementedConfigServer) List(context.Context, *ListRequest) (*ListResponse, error)
func (*UnimplementedConfigServer) Read ¶
func (*UnimplementedConfigServer) Read(context.Context, *ReadRequest) (*ReadResponse, error)
func (*UnimplementedConfigServer) Update ¶
func (*UnimplementedConfigServer) Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
func (*UnimplementedConfigServer) Watch ¶
func (*UnimplementedConfigServer) Watch(*WatchRequest, Config_WatchServer) error
type UpdateRequest ¶
type UpdateRequest struct {
	Change *Change `protobuf:"bytes,1,opt,name=change,proto3" json:"change,omitempty"`
	// contains filtered or unexported fields
}
    
        
          
            func (*UpdateRequest) Descriptor
            deprecated
            
          
  
    
  
      
      func (*UpdateRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.
func (*UpdateRequest) GetChange ¶
func (x *UpdateRequest) GetChange() *Change
func (*UpdateRequest) ProtoMessage ¶
func (*UpdateRequest) ProtoMessage()
func (*UpdateRequest) ProtoReflect ¶
func (x *UpdateRequest) ProtoReflect() protoreflect.Message
func (*UpdateRequest) Reset ¶
func (x *UpdateRequest) Reset()
func (*UpdateRequest) String ¶
func (x *UpdateRequest) String() string
type UpdateResponse ¶
type UpdateResponse struct {
	// contains filtered or unexported fields
}
    
        
          
            func (*UpdateResponse) Descriptor
            deprecated
            
          
  
    
  
      
      func (*UpdateResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateResponse.ProtoReflect.Descriptor instead.
func (*UpdateResponse) ProtoMessage ¶
func (*UpdateResponse) ProtoMessage()
func (*UpdateResponse) ProtoReflect ¶
func (x *UpdateResponse) ProtoReflect() protoreflect.Message
func (*UpdateResponse) Reset ¶
func (x *UpdateResponse) Reset()
func (*UpdateResponse) String ¶
func (x *UpdateResponse) String() string
type WatchRequest ¶
type WatchRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Path      string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}
    
        
          
            func (*WatchRequest) Descriptor
            deprecated
            
          
  
    
  
      
      func (*WatchRequest) Descriptor() ([]byte, []int)
Deprecated: Use WatchRequest.ProtoReflect.Descriptor instead.
func (*WatchRequest) GetNamespace ¶
func (x *WatchRequest) GetNamespace() string
func (*WatchRequest) GetPath ¶
func (x *WatchRequest) GetPath() string
func (*WatchRequest) ProtoMessage ¶
func (*WatchRequest) ProtoMessage()
func (*WatchRequest) ProtoReflect ¶
func (x *WatchRequest) ProtoReflect() protoreflect.Message
func (*WatchRequest) Reset ¶
func (x *WatchRequest) Reset()
func (*WatchRequest) String ¶
func (x *WatchRequest) String() string
type WatchResponse ¶
type WatchResponse struct {
	Namespace string     `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ChangeSet *ChangeSet `protobuf:"bytes,2,opt,name=changeSet,proto3" json:"changeSet,omitempty"`
	// contains filtered or unexported fields
}
    
        
          
            func (*WatchResponse) Descriptor
            deprecated
            
          
  
    
  
      
      func (*WatchResponse) Descriptor() ([]byte, []int)
Deprecated: Use WatchResponse.ProtoReflect.Descriptor instead.
func (*WatchResponse) GetChangeSet ¶
func (x *WatchResponse) GetChangeSet() *ChangeSet
func (*WatchResponse) GetNamespace ¶
func (x *WatchResponse) GetNamespace() string
func (*WatchResponse) ProtoMessage ¶
func (*WatchResponse) ProtoMessage()
func (*WatchResponse) ProtoReflect ¶
func (x *WatchResponse) ProtoReflect() protoreflect.Message
func (*WatchResponse) Reset ¶
func (x *WatchResponse) Reset()
func (*WatchResponse) String ¶
func (x *WatchResponse) String() string