rpc

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Dec 22, 2024 License: MIT Imports: 24 Imported by: 0

Documentation

Overview

Copyright (c) 2024 Eli Janssen Use of this source code is governed by an MIT-style license that can be found in the LICENSE file.

Copyright (c) 2024 Eli Janssen Use of this source code is governed by an MIT-style license that can be found in the LICENSE file.

Copyright (c) 2024 Eli Janssen Use of this source code is governed by an MIT-style license that can be found in the LICENSE file.

Copyright (c) 2024 Eli Janssen Use of this source code is governed by an MIT-style license that can be found in the LICENSE file.

Copyright (c) 2024 Eli Janssen Use of this source code is governed by an MIT-style license that can be found in the LICENSE file.

Copyright (c) 2024 Eli Janssen Use of this source code is governed by an MIT-style license that can be found in the LICENSE file.

Copyright (c) 2024 Eli Janssen Use of this source code is governed by an MIT-style license that can be found in the LICENSE file.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AuthError added in v1.1.0 

func AuthError(msg string) *connect.Error

func InternalError added in v1.1.0 

func InternalError(msg string) *connect.Error

func RequireApiKey added in v1.1.0 

func RequireApiKey(up GetUserProvider, opts ...connect.HandlerOption) func(http.Handler) http.Handler

Types

type GetUserProvider 

type GetUserProvider interface {
	GetUserByApiKey(context.Context, string) (*model.User, errs.Error)
}

type Options 

type Options struct {
	Db           model.PgxHandle   `validate:"required"`
	Redis        *redis.Client     `validate:"required"`
	Templates    resources.TGetter `validate:"required"`
	Mailer       mail.MailSender   `validate:"required"`
	HMACKeyBytes []byte            `validate:"required"`
	BaseURL      string            `validate:"required"`
	IsProd       bool
}

type Server 

type Server struct {
	// contains filtered or unexported fields
}

func New 

func New(opts Options) (*Server, error)

func (*Server) EarmarkCreate added in v1.0.1 

func (s *Server) EarmarkCreate(ctx context.Context,
	req *connect.Request[icbt.EarmarkCreateRequest],
) (*connect.Response[icbt.EarmarkCreateResponse], error)

func (*Server) EarmarkGetDetails added in v1.0.1 

func (s *Server) EarmarkGetDetails(ctx context.Context,
	req *connect.Request[icbt.EarmarkGetDetailsRequest],
) (*connect.Response[icbt.EarmarkGetDetailsResponse], error)

func (*Server) EarmarkRemove added in v1.0.1 

func (s *Server) EarmarkRemove(ctx context.Context,
	req *connect.Request[icbt.EarmarkRemoveRequest],
) (*connect.Response[emptypb.Empty], error)

func (*Server) EarmarksList added in v1.0.1 

func (s *Server) EarmarksList(ctx context.Context,
	req *connect.Request[icbt.EarmarksListRequest],
) (*connect.Response[icbt.EarmarksListResponse], error)

func (*Server) EventAddItem added in v1.0.1 

func (s *Server) EventAddItem(ctx context.Context,
	req *connect.Request[icbt.EventAddItemRequest],
) (*connect.Response[icbt.EventAddItemResponse], error)

func (*Server) EventCreate added in v1.0.1 

func (s *Server) EventCreate(ctx context.Context,
	req *connect.Request[icbt.EventCreateRequest],
) (*connect.Response[icbt.EventCreateResponse], error)

func (*Server) EventDelete added in v1.0.1 

func (s *Server) EventDelete(ctx context.Context,
	req *connect.Request[icbt.EventDeleteRequest],
) (*connect.Response[emptypb.Empty], error)

func (*Server) EventGetDetails added in v1.0.1 

func (s *Server) EventGetDetails(ctx context.Context,
	req *connect.Request[icbt.EventGetDetailsRequest],
) (*connect.Response[icbt.EventGetDetailsResponse], error)

func (*Server) EventListEarmarks added in v1.0.1 

func (s *Server) EventListEarmarks(ctx context.Context,
	req *connect.Request[icbt.EventListEarmarksRequest],
) (*connect.Response[icbt.EventListEarmarksResponse], error)

func (*Server) EventListItems added in v1.0.1 

func (s *Server) EventListItems(ctx context.Context,
	req *connect.Request[icbt.EventListItemsRequest],
) (*connect.Response[icbt.EventListItemsResponse], error)

func (*Server) EventRemoveItem added in v1.0.1 

func (s *Server) EventRemoveItem(ctx context.Context,
	req *connect.Request[icbt.EventRemoveItemRequest],
) (*connect.Response[emptypb.Empty], error)

func (*Server) EventUpdate added in v1.0.1 

func (s *Server) EventUpdate(ctx context.Context,
	req *connect.Request[icbt.EventUpdateRequest],
) (*connect.Response[emptypb.Empty], error)

func (*Server) EventUpdateItem added in v1.0.1 

func (s *Server) EventUpdateItem(ctx context.Context,
	req *connect.Request[icbt.EventUpdateItemRequest],
) (*connect.Response[icbt.EventUpdateItemResponse], error)

func (*Server) EventsList added in v1.0.1 

func (s *Server) EventsList(ctx context.Context,
	req *connect.Request[icbt.EventsListRequest],
) (*connect.Response[icbt.EventsListResponse], error)

func (*Server) FavoriteAdd added in v1.0.1 

func (s *Server) FavoriteAdd(ctx context.Context,
	req *connect.Request[icbt.FavoriteAddRequest],
) (*connect.Response[icbt.FavoriteAddResponse], error)

func (*Server) FavoriteListEvents added in v1.0.1 

func (s *Server) FavoriteListEvents(ctx context.Context,
	req *connect.Request[icbt.FavoriteListEventsRequest],
) (*connect.Response[icbt.FavoriteListEventsResponse], error)

func (*Server) FavoriteRemove added in v1.0.1 

func (s *Server) FavoriteRemove(ctx context.Context,
	req *connect.Request[icbt.FavoriteRemoveRequest],
) (*connect.Response[emptypb.Empty], error)

func (*Server) GenHandler 

func (s *Server) GenHandler() http.Handler

func (*Server) NotificationDelete added in v1.0.1 

func (s *Server) NotificationDelete(ctx context.Context,
	req *connect.Request[icbt.NotificationDeleteRequest],
) (*connect.Response[emptypb.Empty], error)

func (*Server) NotificationsDeleteAll added in v1.0.1 

func (s *Server) NotificationsDeleteAll(ctx context.Context,
	req *connect.Request[icbt.NotificationsDeleteAllRequest],
) (*connect.Response[emptypb.Empty], error)

func (*Server) NotificationsList added in v1.0.1 

func (s *Server) NotificationsList(ctx context.Context,
	req *connect.Request[icbt.NotificationsListRequest],
) (*connect.Response[icbt.NotificationsListResponse], 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.