Documentation
¶
Index ¶
- type AppLogsService
- type AppService
- func (s *AppService) Create(ctx context.Context, req *connect.Request[flyteapp.CreateRequest]) (*connect.Response[flyteapp.CreateResponse], error)
- func (s *AppService) Delete(ctx context.Context, req *connect.Request[flyteapp.DeleteRequest]) (*connect.Response[flyteapp.DeleteResponse], error)
- func (s *AppService) Get(ctx context.Context, req *connect.Request[flyteapp.GetRequest]) (*connect.Response[flyteapp.GetResponse], error)
- func (s *AppService) List(ctx context.Context, req *connect.Request[flyteapp.ListRequest]) (*connect.Response[flyteapp.ListResponse], error)
- func (s *AppService) Update(ctx context.Context, req *connect.Request[flyteapp.UpdateRequest]) (*connect.Response[flyteapp.UpdateResponse], error)
- func (s *AppService) Watch(ctx context.Context, req *connect.Request[flyteapp.WatchRequest], ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AppLogsService ¶
type AppLogsService struct {
appconnect.UnimplementedAppLogsServiceHandler
// contains filtered or unexported fields
}
AppLogsService is the control plane implementation of AppLogsServiceHandler. It proxies the server-streaming TailLogs RPC to the data plane.
func NewAppLogsService ¶
func NewAppLogsService(internalClient appconnect.AppLogsServiceClient) *AppLogsService
NewAppLogsService creates a new AppLogsService.
func (*AppLogsService) TailLogs ¶
func (s *AppLogsService) TailLogs( ctx context.Context, req *connect.Request[flyteapp.TailLogsRequest], stream *connect.ServerStream[flyteapp.TailLogsResponse], ) error
TailLogs proxies the server-streaming TailLogs RPC to InternalAppLogsService.
type AppService ¶
type AppService struct {
appconnect.UnimplementedAppServiceHandler
// contains filtered or unexported fields
}
AppService is the control plane implementation of AppServiceHandler. It proxies all RPCs to InternalAppService (data plane) and maintains a per-instance TTL cache to reduce cross-plane RPC calls on Get.
func NewAppService ¶
func NewAppService(internalClient appconnect.AppServiceClient, cacheTTL time.Duration) *AppService
NewAppService creates a new AppService. cacheTTL=0 disables caching (every Get calls InternalAppService).
func (*AppService) Create ¶
func (s *AppService) Create( ctx context.Context, req *connect.Request[flyteapp.CreateRequest], ) (*connect.Response[flyteapp.CreateResponse], error)
Create forwards to InternalAppService and invalidates the cache entry.
func (*AppService) Delete ¶
func (s *AppService) Delete( ctx context.Context, req *connect.Request[flyteapp.DeleteRequest], ) (*connect.Response[flyteapp.DeleteResponse], error)
Delete forwards to InternalAppService and invalidates the cache entry.
func (*AppService) Get ¶
func (s *AppService) Get( ctx context.Context, req *connect.Request[flyteapp.GetRequest], ) (*connect.Response[flyteapp.GetResponse], error)
Get returns the app, using the cache on hit and calling InternalAppService on miss.
func (*AppService) List ¶
func (s *AppService) List( ctx context.Context, req *connect.Request[flyteapp.ListRequest], ) (*connect.Response[flyteapp.ListResponse], error)
List always forwards to InternalAppService — results vary by filter/pagination.
func (*AppService) Update ¶
func (s *AppService) Update( ctx context.Context, req *connect.Request[flyteapp.UpdateRequest], ) (*connect.Response[flyteapp.UpdateResponse], error)
Update forwards to InternalAppService and invalidates the cache entry.
func (*AppService) Watch ¶
func (s *AppService) Watch( ctx context.Context, req *connect.Request[flyteapp.WatchRequest], stream *connect.ServerStream[flyteapp.WatchResponse], ) error
Watch proxies the server-streaming Watch RPC to InternalAppService.
Source Files