Documentation
¶
Index ¶
- func AddController(mgr manager.Manager) error
- type Controller
- func (c *Controller) CreatePrimitive(ctx context.Context, request *primitiveapi.CreatePrimitiveRequest) (*primitiveapi.CreatePrimitiveResponse, error)
- func (c *Controller) DeletePrimitive(ctx context.Context, request *primitiveapi.DeletePrimitiveRequest) (*primitiveapi.DeletePrimitiveResponse, error)
- func (c *Controller) GetDatabase(ctx context.Context, request *databaseapi.GetDatabaseRequest) (*databaseapi.GetDatabaseResponse, error)
- func (c *Controller) GetDatabases(ctx context.Context, request *databaseapi.GetDatabasesRequest) (*databaseapi.GetDatabasesResponse, error)
- func (c *Controller) GetPrimitive(ctx context.Context, request *primitiveapi.GetPrimitiveRequest) (*primitiveapi.GetPrimitiveResponse, error)
- func (c *Controller) GetPrimitives(ctx context.Context, request *primitiveapi.GetPrimitivesRequest) (*primitiveapi.GetPrimitivesResponse, error)
- func (c *Controller) JoinGroup(request *membershipapi.JoinGroupRequest, ...) error
- func (c *Controller) Start(stop <-chan struct{}) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddController ¶
AddController adds the Atomix controller to the k8s controller manager
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
Controller an implementation of the Atomix controller API
func (*Controller) CreatePrimitive ¶
func (c *Controller) CreatePrimitive(ctx context.Context, request *primitiveapi.CreatePrimitiveRequest) (*primitiveapi.CreatePrimitiveResponse, error)
CreatePrimitive handles a create primitive request
func (*Controller) DeletePrimitive ¶
func (c *Controller) DeletePrimitive(ctx context.Context, request *primitiveapi.DeletePrimitiveRequest) (*primitiveapi.DeletePrimitiveResponse, error)
DeletePrimitive handles a delete primitive request
func (*Controller) GetDatabase ¶
func (c *Controller) GetDatabase(ctx context.Context, request *databaseapi.GetDatabaseRequest) (*databaseapi.GetDatabaseResponse, error)
GetDatabase get a database managed by the controller
func (*Controller) GetDatabases ¶
func (c *Controller) GetDatabases(ctx context.Context, request *databaseapi.GetDatabasesRequest) (*databaseapi.GetDatabasesResponse, error)
GetDatabases get a list of databases managed by the controller
func (*Controller) GetPrimitive ¶
func (c *Controller) GetPrimitive(ctx context.Context, request *primitiveapi.GetPrimitiveRequest) (*primitiveapi.GetPrimitiveResponse, error)
GetPrimitive handles a get primitive request
func (*Controller) GetPrimitives ¶
func (c *Controller) GetPrimitives(ctx context.Context, request *primitiveapi.GetPrimitivesRequest) (*primitiveapi.GetPrimitivesResponse, error)
GetPrimitives handles a list primitives request
func (*Controller) JoinGroup ¶
func (c *Controller) JoinGroup(request *membershipapi.JoinGroupRequest, stream membershipapi.MembershipService_JoinGroupServer) error
JoinGroup handles a group join request
func (*Controller) Start ¶
func (c *Controller) Start(stop <-chan struct{}) error
Start starts the controller server
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.